提交 f4e113c1 authored 作者: blu's avatar blu

restart meter

上级 51bba4ab
...@@ -501,6 +501,8 @@ private: ...@@ -501,6 +501,8 @@ private:
// update status // update status
spdlog::info("evdaemon {}, ping msg from {}", devSn, selfId); spdlog::info("evdaemon {}, ping msg from {}", devSn, selfId);
if(meta=="ping") { if(meta=="ping") {
//get pid
//this->peerData["pids"][selfId] = stoi(body2str(body[3]));
if(cachedMsg.find(selfId) != cachedMsg.end()) { if(cachedMsg.find(selfId) != cachedMsg.end()) {
while(!cachedMsg[selfId].empty()) { while(!cachedMsg[selfId].empty()) {
lock_guard<mutex> lock(cacheLock); lock_guard<mutex> lock(cacheLock);
...@@ -511,7 +513,7 @@ private: ...@@ -511,7 +513,7 @@ private:
spdlog::error("evdaemon {} failed to send multiple: {}", devSn, zmq_strerror(zmq_errno())); spdlog::error("evdaemon {} failed to send multiple: {}", devSn, zmq_strerror(zmq_errno()));
} }
else { else {
spdlog::info("evdaemon {} cached msg sent from {} to {} of type: {}, content: {}", body2str(v[1]), body2str(v[0]), body2str(v[2]), body2str(v[3])); spdlog::info("evdaemon {} failed to send cached msg from {} to {} of type: {}, content: {}",devSn, body2str(v[1]), body2str(v[0]), body2str(v[2]), body2str(v[3]));
} }
} }
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论