formatting
This commit is contained in:
@@ -152,7 +152,7 @@ std::string BaseLoop::decodeMessage(const std::string& data)
|
|||||||
BusMessage* message = new BusMessage(busCommand, false, false);
|
BusMessage* message = new BusMessage(busCommand, false, false);
|
||||||
L.log(bas, trace, " msg: %s", busCommand.c_str());
|
L.log(bas, trace, " msg: %s", busCommand.c_str());
|
||||||
// send message
|
// send message
|
||||||
m_busloop->addBusMessage(message);
|
m_busloop->addMessage(message);
|
||||||
message->waitSignal();
|
message->waitSignal();
|
||||||
|
|
||||||
if (!message->isErrorResult()) {
|
if (!message->isErrorResult()) {
|
||||||
@@ -205,7 +205,7 @@ std::string BaseLoop::decodeMessage(const std::string& data)
|
|||||||
BusMessage* message = new BusMessage(busCommand, false, false);
|
BusMessage* message = new BusMessage(busCommand, false, false);
|
||||||
L.log(bas, event, " msg: %s", busCommand.c_str());
|
L.log(bas, event, " msg: %s", busCommand.c_str());
|
||||||
// send message
|
// send message
|
||||||
m_busloop->addBusMessage(message);
|
m_busloop->addMessage(message);
|
||||||
message->waitSignal();
|
message->waitSignal();
|
||||||
|
|
||||||
if (!message->isErrorResult()) {
|
if (!message->isErrorResult()) {
|
||||||
@@ -274,7 +274,7 @@ std::string BaseLoop::decodeMessage(const std::string& data)
|
|||||||
BusMessage* message = new BusMessage(busCommand, false, false);
|
BusMessage* message = new BusMessage(busCommand, false, false);
|
||||||
L.log(bas, trace, " msg: %s", busCommand.c_str());
|
L.log(bas, trace, " msg: %s", busCommand.c_str());
|
||||||
// send message
|
// send message
|
||||||
m_busloop->addBusMessage(message);
|
m_busloop->addMessage(message);
|
||||||
message->waitSignal();
|
message->waitSignal();
|
||||||
|
|
||||||
if (message->isErrorResult()) {
|
if (message->isErrorResult()) {
|
||||||
|
|||||||
@@ -340,7 +340,7 @@ void BusLoop::addPollMessage()
|
|||||||
BusMessage* message = new BusMessage(busCommand, true, false);
|
BusMessage* message = new BusMessage(busCommand, true, false);
|
||||||
L.log(bus, trace, " msg: %s", busCommand.c_str());
|
L.log(bus, trace, " msg: %s", busCommand.c_str());
|
||||||
|
|
||||||
addBusMessage(message);
|
addMessage(message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -675,6 +675,6 @@ void BusLoop::addScanMessage()
|
|||||||
BusMessage* message = new BusMessage(busCommand, true, true);
|
BusMessage* message = new BusMessage(busCommand, true, true);
|
||||||
L.log(bus, trace, " msg: %s", busCommand.c_str());
|
L.log(bus, trace, " msg: %s", busCommand.c_str());
|
||||||
|
|
||||||
addBusMessage(message);
|
addMessage(message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
@@ -80,7 +80,7 @@ public:
|
|||||||
void* run();
|
void* run();
|
||||||
void stop() { m_stop = true; }
|
void stop() { m_stop = true; }
|
||||||
|
|
||||||
void addBusMessage(BusMessage* message) { m_busQueue.add(message); }
|
void addMessage(BusMessage* message) { m_busQueue.add(message); }
|
||||||
|
|
||||||
void dump() { m_dumpState == true ? m_dumpState = false : m_dumpState = true ; }
|
void dump() { m_dumpState == true ? m_dumpState = false : m_dumpState = true ; }
|
||||||
void raw() { m_logRawData == true ? m_logRawData = false : m_logRawData = true ; }
|
void raw() { m_logRawData == true ? m_logRawData = false : m_logRawData = true ; }
|
||||||
|
|||||||
Reference in New Issue
Block a user