2#include "dbc_statement_handler.h"
4#include "multiplex_graph.h"
5#include "signal_layout.h"
15 std::uint32_t ParseDecimal(
const std::string &text,
16 std::uint32_t maximum,
18 std::uint32_t value = 0U;
19 const std::from_chars_result parsed = std::from_chars(text.data(), text.data() + text.size(), value);
20 if (text.empty() || parsed.ec != std::errc() ||
21 parsed.ptr != text.data() + text.size() || value > maximum)
22 throw std::runtime_error(std::string(
"Invalid ") + field +
": " + text);
26 std::uint32_t ParseCanId(
const std::string &text) {
27 const std::uint32_t rawId = ParseDecimal(
28 text, std::numeric_limits<std::uint32_t>::max(),
"CAN ID");
30 if ((rawId & 0x60000000U) != 0U)
31 throw std::runtime_error(
"CAN ID exceeds the 29-bit identifier range.");
35 double ParsePhysicalValue(
const std::string &text,
const char *field) {
36 static const std::regex number(
37 R
"(^[+-]?(?:[0-9]+(?:\.[0-9]*)?|\.[0-9]+)(?:[eE][+-]?[0-9]+)?$)");
38 if (!std::regex_match(text, number))
39 throw std::runtime_error(std::string(
"Invalid ") + field +
": " + text);
42 const char *begin = text.data();
43 const char *end = begin + text.size();
47 const std::from_chars_result parsed =
48 std::from_chars(begin, end, value, std::chars_format::general);
50 if (parsed.ec != std::errc() || parsed.ptr != end || !std::isfinite(value) ||
51 std::fpclassify(value) == FP_SUBNORMAL)
52 throw std::runtime_error(std::string(
"Invalid ") + field +
": " + text);
56 Multiplexing ParseMultiplexingMarker(
const std::string &marker) {
59 result.role = MultiplexRole::Selector;
60 else if (!marker.empty()) {
62 throw std::runtime_error(
"Unsupported multiplexing marker.");
63 const bool nested = marker.back() ==
'M';
64 const std::string value = marker.substr(1U, marker.size() - (nested ? 2U : 1U));
65 const std::from_chars_result parsed =
66 std::from_chars(value.data(), value.data() + value.size(), result.
value);
67 if (value.empty() || parsed.ec != std::errc() || parsed.ptr != value.data() + value.size())
68 throw std::runtime_error(
"Invalid or unsupported multiplexing marker.");
69 result.role = nested ? MultiplexRole::BranchSelector : MultiplexRole::Branch;
75 RawSignalValue ParseValueKey(
const std::string &number) {
77 if (!number.empty() && number[0] ==
'-') {
78 std::int64_t value = 0;
79 const std::from_chars_result parsed =
80 std::from_chars(number.data(), number.data() + number.size(), value);
81 if (parsed.ec != std::errc() || parsed.ptr != number.data() + number.size())
82 throw std::runtime_error(
"Invalid VAL_ integer: " + number);
83 key = NormalizeValueKey(RawSignalValue(value));
85 std::uint64_t value = 0;
86 const std::from_chars_result parsed =
87 std::from_chars(number.data(), number.data() + number.size(), value);
88 if (number.empty() || parsed.ec != std::errc() || parsed.ptr != number.data() + number.size())
89 throw std::runtime_error(
"Invalid VAL_ integer: " + number);
95 std::string UnescapeDescription(
const std::string "ed) {
96 std::string description;
97 for (std::size_t i = 0; i < quoted.size(); ++i) {
98 if (quoted[i] ==
'\\')
100 description += quoted[i];
105 FrameInfo *FindUniqueFrame(
DbcDatabase &database, std::uint32_t canId,
bool isExtended,
const std::string &statement =
"VAL_") {
107 for (
FrameInfo &candidate : database.frames) {
108 if (candidate.canId == canId && candidate.isExtended == isExtended) {
110 throw std::runtime_error(
"Ambiguous " + statement +
" frame reference.");
115 throw std::runtime_error(
"Unresolved " + statement +
" frame reference.");
119 SignalInfo *FindUniqueSignal(
FrameInfo &frame,
const std::string &signalName,
const std::string &statement =
"VAL_") {
122 if (candidate.name == signalName) {
124 throw std::runtime_error(
"Ambiguous " + statement +
" signal reference: " + signalName);
129 throw std::runtime_error(
"Unresolved " + statement +
" signal reference: " + signalName);
133 std::uint64_t NextSignalBit(std::uint64_t bit,
bool isLittleEndian) {
137 return bit % 8U == 0U ? bit + 15U : bit - 1U;
145 std::vector<std::string> SplitReceivers(
const std::string &text) {
146 std::vector<std::string> receivers;
148 std::istringstream stream(text);
150 while (std::getline(stream, token,
',')) {
151 token = dbc_detail::TrimText(token);
153 receivers.push_back(token);
159 void NormalizeCanId(std::uint32_t rawCanId, std::uint32_t &normalizedCanId,
bool &isExtended) {
165 isExtended = (rawCanId & 0x80000000U) != 0U || rawCanId > 0x7FFU;
166 normalizedCanId = rawCanId & 0x1FFFFFFFU;
170FrameInfo DbcFrameHandler::ParseFrameLine(
const std::string &line) {
176 std::istringstream stream(line);
179 if (!(stream >> keyword >> idText) || keyword !=
"BO_")
180 throw std::runtime_error(
"Missing CAN ID in frame definition.");
182 const std::uint32_t rawCanId = ParseCanId(idText);
184 std::string nameText;
185 if (!std::getline(stream, nameText,
':') || stream.eof())
186 throw std::runtime_error(
"Missing ':' in frame definition.");
187 std::istringstream nameStream(nameText);
190 if (!(nameStream >> frame.
name) || (nameStream >> extra))
191 throw std::runtime_error(
"Missing or invalid frame name.");
193 std::string lengthText;
194 if (!(stream >> lengthText))
195 throw std::runtime_error(
"Missing payload length in frame definition.");
196 frame.
dlc =
static_cast<std::uint8_t
>(ParseDecimal(
197 lengthText, std::numeric_limits<std::uint8_t>::max(),
"payload length"));
199 throw std::runtime_error(
"Missing transmitter in frame definition.");
201 throw std::runtime_error(
"Unexpected trailing field in frame definition: " + extra);
208SignalInfo DbcSignalHandler::ParseSignalLine(
const std::string &line) {
211 NameAndMarker = 1, StartBit, BitLength,
ByteOrder, Signedness,
212 Factor, Offset, Minimum, Maximum, Unit, Receivers
214 static const std::regex syntax(
216 R
"dbc(^SG_[ \t]+([^:]+):[ \t]*)dbc"
218 R
"dbc(([^| \t]+)[ \t]*\|[ \t]*([^@ \t]+)[ \t]*@[ \t]*([01])([+-])[ \t]*)dbc"
220 R
"dbc(\([ \t]*([^, \t]+)[ \t]*,[ \t]*([^ )\t]+)[ \t]*\)[ \t]*)dbc"
222 R
"dbc(\[[ \t]*([^| \t]+)[ \t]*\|[ \t]*([^\] \t]+)[ \t]*\][ \t]*)dbc"
224 R
"dbc("([^"\r\n]*)"[ \t]+([^ \t,]+(?:[ \t]*,[ \t]*[^ \t,]+)*)[ \t]*$)dbc");
226 if (!std::regex_match(line, fields, syntax))
227 throw std::runtime_error(
"Malformed or unsupported SG_ signal definition.");
230 std::istringstream nameFields(fields[NameAndMarker].str());
233 nameFields >> signal.
name >> marker;
234 if (signal.
name.empty() || (nameFields >> extra))
235 throw std::runtime_error(
"Invalid signal name or multiplexing marker.");
238 signal.
startBit = ParseDecimal(fields[StartBit].str(),
239 std::numeric_limits<std::uint32_t>::max(),
"signal start bit");
240 signal.
length = ParseDecimal(fields[BitLength].str(), 64U,
"signal length");
242 throw std::runtime_error(
"Signal length must be within 1..64 bits.");
244 signal.
isSigned = fields[Signedness].str() ==
"-";
246 signal.
factor = ParsePhysicalValue(fields[Factor].str(),
"signal factor");
247 signal.
offset = ParsePhysicalValue(fields[Offset].str(),
"signal offset");
248 signal.
minimum = ParsePhysicalValue(fields[Minimum].str(),
"signal minimum");
249 signal.
maximum = ParsePhysicalValue(fields[Maximum].str(),
"signal maximum");
251 throw std::runtime_error(
"Signal minimum exceeds maximum.");
252 signal.
unit = fields[Unit].str();
253 signal.
receivers = SplitReceivers(fields[Receivers].str());
262 for (
FrameInfo &frame : database.frames) {
272 if (signal.
name == signalName)
284 frame.
pgn = ExtractJ1939Pgn(frame.
canId);
287 throw std::runtime_error(
"Duplicate " + std::string(frame.
isExtended ?
"extended" :
"standard") +
288 " frame CAN ID: " + std::to_string(frame.
canId));
296 throw std::runtime_error(
"Signal found before any frame definition.");
299 throw std::runtime_error(
"Duplicate signal name '" + signal.
name +
303 throw std::runtime_error(
"Signal exceeds the frame payload length.");
304 context.
currentFrame->signals.push_back(std::move(signal));
309 std::istringstream stream(line);
312 stream >> keyword >> target;
313 if (keyword !=
"CM_" || (target !=
"BO_" && target !=
"SG_"))
320 if (!(stream >> idText))
321 throw std::runtime_error(
"Missing CAN ID in CM_ statement.");
324 pending.
signalName.find_first_of(
"\";") != std::string::npos))
325 throw std::runtime_error(
"Missing or invalid signal name in CM_ statement.");
328 if (stream.get() !=
'"')
329 throw std::runtime_error(
"Missing opening quote in CM_ statement.");
332 while (stream.get(character)) {
333 if (character ==
'"') {
337 if (character ==
'\\') {
338 if (!stream.get(character) || (character !=
'"' && character !=
'\\'))
339 throw std::runtime_error(
"Invalid escape in CM_ statement.");
344 throw std::runtime_error(
"Unterminated CM_ comment.");
346 if (stream.get() !=
';')
347 throw std::runtime_error(
"Missing semicolon in CM_ statement.");
350 throw std::runtime_error(
"Unexpected trailing text in CM_ statement.");
359 pending.lineNumber,
"Unresolved CM_ frame reference.");
360 if (pending.isSignal) {
361 SignalInfo *signal = FindSignalByName(*frame, pending.signalName);
364 pending.lineNumber,
"Unresolved CM_ signal reference: " + pending.signalName);
365 signal->
comment = pending.comment;
367 frame->
comment = pending.comment;
373 RegisterType<DbcHeaderHandler>(
"VERSION");
374 RegisterType<DbcHeaderHandler>(
"NS_");
375 RegisterType<DbcHeaderHandler>(
"NS_:");
376 RegisterType<DbcHeaderHandler>(
"BS_");
377 RegisterType<DbcHeaderHandler>(
"BS_:");
378 RegisterType<DbcHeaderHandler>(
"BU_");
379 RegisterType<DbcHeaderHandler>(
"BU_:");
380 RegisterType<DbcMultiplexingHandler>(
"SG_MUL_VAL_");
381 RegisterType<DbcFrameHandler>(
"BO_");
382 RegisterType<DbcSignalHandler>(
"SG_");
383 RegisterType<DbcCommentHandler>(
"CM_");
384 RegisterType<DbcValueDescriptionHandler>(
"VAL_");
385 RegisterType<DbcAttributeHandler>(
"BA_DEF_");
386 RegisterType<DbcAttributeHandler>(
"BA_DEF_DEF_");
387 RegisterType<DbcAttributeHandler>(
"BA_");
394 std::istringstream stream(line);
397 const HandlerMap::const_iterator handler = m_handlers.find(keyword);
398 if (handler == m_handlers.end())
400 handler->second->Handle(line, context);
405 static const std::regex header(R
"(^VAL_[ \t]+([^ \t]+)[ \t]+([^ \t;]+)[ \t]+(.*)$)");
406 static const std::regex pair(R
"dbc(^([^ \t]+)[ \t]+"((?:[^"\\]|\\["\\])*)")dbc");
408 if (!std::regex_match(line, fields, header))
409 throw std::runtime_error(
"Malformed or unsupported VAL_ statement.");
410 const std::uint32_t rawId = ParseDecimal(fields[1].str(), std::numeric_limits<std::uint32_t>::max(),
"VAL_ CAN ID");
411 if ((rawId & 0x60000000U) != 0U)
412 throw std::runtime_error(
"VAL_ CAN ID exceeds the 29-bit identifier range.");
417 std::string rest = fields[3].str();
418 while (rest !=
";") {
419 if (!std::regex_search(rest, fields, pair))
420 throw std::runtime_error(
"Malformed VAL_ value/description pair or missing semicolon.");
421 const std::string number = fields[1].str();
422 const RawSignalValue key = ParseValueKey(number);
423 const std::string description = UnescapeDescription(fields[2].str());
424 if (!pending.
descriptions.emplace(key, description).second)
425 throw std::runtime_error(
"Duplicate VAL_ value key: " + number);
426 const std::size_t consumed =
static_cast<std::size_t
>(fields.length());
427 rest.erase(0, consumed);
428 if (!rest.empty() && rest[0] !=
';' && rest[0] !=
' ' && rest[0] !=
'\t')
429 throw std::runtime_error(
"Missing whitespace between VAL_ pairs.");
430 rest = dbc_detail::TrimText(rest);
433 throw std::runtime_error(
"VAL_ requires at least one value/description pair.");
441 SignalInfo *signal = FindUniqueSignal(*frame, pending.signalName);
442 for (
const ValueDescriptions::value_type &entry: pending.descriptions) {
444 throw std::runtime_error(
"Duplicate VAL_ value key for signal: " + pending.signalName);
446 }
catch (
const std::exception &error) {
448 filePath, pending.lineNumber, error.what());
454 static const std::regex syntax(R
"(^SG_MUL_VAL_[ \t]+([0-9]+)[ \t]+([^ \t;]+)[ \t]+([^ \t;]+)[ \t]+(.+);[ \t]*$)");
455 static const std::regex rangeSyntax(R
"(^[ \t]*([0-9]+)[ \t]*-[ \t]*([0-9]+)[ \t]*$)");
457 if (!std::regex_match(line, fields, syntax))
458 throw std::runtime_error(
"Malformed SG_MUL_VAL_ statement.");
460 NormalizeCanId(ParseCanId(fields[1].str()), pending.canId, pending.isExtended);
461 pending.signalName = fields[2].str();
462 pending.selectorName = fields[3].str();
464 const std::string list = fields[4].str();
465 std::size_t begin = 0U;
467 const std::size_t comma = list.find(
',', begin);
468 const std::string item = list.substr(begin, comma == std::string::npos ? comma : comma - begin);
469 if (!std::regex_match(item, fields, rangeSyntax))
470 throw std::runtime_error(
"Malformed multiplex range.");
472 const std::string lower = fields[1].str();
473 const std::string upper = fields[2].str();
474 const std::from_chars_result low = std::from_chars(lower.data(), lower.data() + lower.size(), range.minimum);
475 const std::from_chars_result high = std::from_chars(upper.data(), upper.data() + upper.size(), range.maximum);
476 if (low.ec != std::errc() || high.ec != std::errc() || range.minimum > range.maximum)
477 throw std::runtime_error(
"Invalid multiplex range.");
478 pending.ranges.push_back(range);
479 if (comma == std::string::npos)
483 context.pendingMultiplexing.push_back(std::move(pending));
486void DbcParseContext::ResolveMultiplexing(
const std::string &filePath) {
489 FrameInfo *frame = FindUniqueFrame(
database, pending.canId, pending.isExtended,
"SG_MUL_VAL_");
490 SignalInfo *signal = FindUniqueSignal(*frame, pending.signalName,
"SG_MUL_VAL_");
491 SignalInfo *selector = FindUniqueSignal(*frame, pending.selectorName,
"SG_MUL_VAL_");
493 throw std::runtime_error(
"Referenced signal must be an unsigned multiplex selector.");
495 throw std::runtime_error(
"Multiple parent selectors for one signal are unsupported.");
497 if (selector->
length < 64U && range.maximum >= (std::uint64_t(1U) << selector->
length))
498 throw std::runtime_error(
"Branch value exceeds selector raw range.");
505 signal->
multiplexing.role = MultiplexRole::BranchSelector;
506 }
catch (
const std::exception &error) {
507 throw DbcDiagnosticError(DbcDiagnosticCode::InvalidMultiplexing, filePath, pending.lineNumber, error.what());
513 std::vector<std::uint64_t> SignalBits(
const SignalInfo &signal) {
514 std::vector<std::uint64_t> bits;
515 std::uint64_t bit = signal.
startBit;
516 for (std::uint32_t index = 0U; index < signal.
length; ++index) {
524 const std::vector<std::uint64_t> firstBits = SignalBits(first);
525 const std::vector<std::uint64_t> secondBits = SignalBits(second);
526 for (
const std::uint64_t firstBit : firstBits) {
527 for (
const std::uint64_t secondBit : secondBits) {
528 if (firstBit == secondBit)
537 for (std::size_t frameIndex = 0U; frameIndex <
database.
frames.size(); ++frameIndex) {
541 for (std::size_t index = 0U; index < frame.signals.size(); ++index) {
542 const SignalInfo &signal = frame.signals[index];
545 for (std::size_t previous = 0U; previous < index; ++previous) {
546 if (!graph.AreMutuallyExclusive(index, previous) && SignalsOverlap(signal, frame.signals[previous]))
552 signalLines[frameIndex][error.index], error.what());
void Handle(const std::string &line, DbcParseContext &context) const override
Process a trimmed statement using state belonging to this parse.
void Handle(const std::string &line, DbcParseContext &context) const override
Process a trimmed statement using state belonging to this parse.
void Handle(const std::string &line, DbcParseContext &context) const override
Process a trimmed statement using state belonging to this parse.
void Handle(const std::string &line, DbcParseContext &context) const override
Process a trimmed statement using state belonging to this parse.
DbcStatementDispatcher()
Register supported statement handlers through TypeFactory.
bool Dispatch(const std::string &line, DbcParseContext &context) const
void Handle(const std::string &line, DbcParseContext &context) const override
Process a trimmed statement using state belonging to this parse.
ByteOrder
Signal byte order used for runtime decoding.
Parsed DBC content stored in a simple internal form.
std::vector< FrameInfo > frames
std::vector< PendingComment > pendingComments
void ValidateMultiplexing(const std::string &filePath) const
Validate selectors, branch ranges, and signal overlap.
void ResolveValueDescriptions(const std::string &filePath)
Resolve deferred raw descriptions against unique targets.
std::vector< PendingValueDescriptions > pendingValues
void ResolveComments(const std::string &filePath)
Resolve deferred comments after all definitions are known.
std::vector< std::vector< std::size_t > > signalLines
Describes one CAN frame from a DBC file.
Inclusive raw selector range, without expanding individual values.
Basic markers and optional explicit extended multiplexing condition.
std::vector< MultiplexRange > ranges
Deferred extended multiplexing condition and source location.
Deferred raw value descriptions and their target.
ValueDescriptions descriptions
Describes one signal inside a DBC frame.
std::vector< std::string > receivers
ValueDescriptions valueDescriptions
Multiplexing multiplexing