nils/ebusd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BusLoop::analyseCycData: check of input data for validity implemented.

Browse Source
This commit is contained in:
Roland Jax
2014-11-29 11:22:22 +01:00
parent 10839f770f
commit 0eaccd08ea
1 changed files with 47 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ebusd/busloop.cpp
+47 -29
View File
@@ -307,38 +307,56 @@ void BusLoop::collectCycData(const int numRecv)
void BusLoop::analyseCycData() void BusLoop::analyseCycData()
{ {
//TODO check the input data for validity int lenMaster = m_sstr[4];
SymbolString master;
static bool skipfirst = false; for (int i = 0; i < 5+lenMaster; i++)
master.push_back(m_sstr[i], true , true);
if (skipfirst == true) { if (m_sstr[5+lenMaster] != master.getCRC()) {
L.log(cyc, trace, "%s", m_sstr.getDataStr().c_str()); L.log(cyc, trace, "ERR_CYC_CRC_M %s - %02x %02x", master.getDataStr().c_str(), m_sstr[5+lenMaster], master.getCRC());
return;
int index = m_commands->storeCycData(m_sstr.getDataStr());
if (index == -1) {
L.log(cyc, debug, " command not found");
}
else if (index == -2) {
L.log(cyc, debug, " no commands defined");
}
else if (index == -3) {
L.log(cyc, debug, " search skipped - string too short");
}
else {
string tmp;
tmp += (*m_commands)[index][1];
tmp += " ";
tmp += (*m_commands)[index][2];
L.log(cyc, event, " cycle [%4d] %s", index, tmp.c_str());
}
// collect Slave address
if (index != -3)
collectSlave();
} }
else
skipfirst = true; if (m_sstr[1] != BROADCAST || isMaster(m_sstr[1]) == false) {
int lenSlave = m_sstr[5+lenMaster+2];
SymbolString slave;
for (int i = 5+lenMaster+2; i < 5+lenMaster+3+lenSlave; i++)
slave.push_back(m_sstr[i], true , true);
if (m_sstr[5+lenMaster+3+lenSlave] != slave.getCRC()) {
L.log(cyc, trace, "ERR_CYC_CRC_S %s - %02x %02x", slave.getDataStr().c_str(), m_sstr[5+lenMaster+3+lenSlave], slave.getCRC());
return;
}
}
L.log(cyc, trace, "%s", m_sstr.getDataStr().c_str());
int index = m_commands->storeCycData(m_sstr.getDataStr());
if (index == -1) {
L.log(cyc, debug, " command not found");
}
else if (index == -2) {
L.log(cyc, debug, " no commands defined");
}
else if (index == -3) {
L.log(cyc, debug, " search skipped - string too short");
}
else {
string tmp;
tmp += (*m_commands)[index][1];
tmp += " ";
tmp += (*m_commands)[index][2];
L.log(cyc, event, " cycle [%4d] %s", index, tmp.c_str());
}
// collect Slave address
if (index != -3)
collectSlave();
} }
void BusLoop::collectSlave() void BusLoop::collectSlave()