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

fixed cache invalidation

Browse Source
This commit is contained in:
john30
2015-12-12 17:57:43 +01:00
parent 5b7aea8564
commit 752475ef5f
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ebusd/bushandler.cpp
+6 -6
View File
@@ -762,6 +762,12 @@ void BusHandler::receiveCompleted()
logNotice(lf_update, "unknown MS cmd: %s / %s", m_command.getDataStr().c_str(), m_response.getDataStr().c_str()); logNotice(lf_update, "unknown MS cmd: %s / %s", m_command.getDataStr().c_str(), m_response.getDataStr().c_str());
} }
else { else {
messages.pop_front();
while (messages.size()>0) {
Message* invalidate = messages.front();
m_messages->invalidateCache(invalidate);
messages.pop_front();
}
string circuit = message->getCircuit(); string circuit = message->getCircuit();
string name = message->getName(); string name = message->getName();
ostringstream output; ostringstream output;
@@ -783,12 +789,6 @@ void BusHandler::receiveCompleted()
logNotice(lf_update, "update %s %s QQ=%2.2x: %s", circuit.c_str(), name.c_str(), srcAddress, data.c_str()); logNotice(lf_update, "update %s %s QQ=%2.2x: %s", circuit.c_str(), name.c_str(), srcAddress, data.c_str());
else else
logNotice(lf_update, "update %s %s: %s", circuit.c_str(), name.c_str(), data.c_str()); logNotice(lf_update, "update %s %s: %s", circuit.c_str(), name.c_str(), data.c_str());
messages.pop_front();
}
while (messages.size()>0) {
message = messages.front();
m_messages->invalidateCache(message);
messages.pop_front();
} }
} }
} }