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

evslicer: more logs

上级 0936796c
...@@ -540,8 +540,8 @@ debug:record ...@@ -540,8 +540,8 @@ debug:record
"metaValue":"debug:record", "metaValue":"debug:record",
"data":{ "data":{
"type":"event", "type":"event",
"start":1571723088, "start":1584177090,
"end":1571723098 "end":1584177190
} }
} }
``` ```
......
...@@ -130,7 +130,8 @@ private: ...@@ -130,7 +130,8 @@ private:
if(eventQueue.size() > MAX_EVENT_QUEUE_SIZE) { if(eventQueue.size() > MAX_EVENT_QUEUE_SIZE) {
eventQueue.pop(); eventQueue.pop();
} }
cvEvent.notify_one(); cvEvent.notify_all();
spdlog::info("{} notified event", selfId);
} }
else { else {
spdlog::error("{} msg not supported from {}: {}", selfId, peerId, msg); spdlog::error("{} msg not supported from {}: {}", selfId, peerId, msg);
...@@ -191,7 +192,7 @@ private: ...@@ -191,7 +192,7 @@ private:
{ {
lock_guard<mutex> lock(this->mutEvent); lock_guard<mutex> lock(this->mutEvent);
eventQueue.push(evt.dump()); eventQueue.push(evt.dump());
cvEvent.notify_one(); cvEvent.notify_all();
} }
bProcessed = true; bProcessed = true;
} }
...@@ -1043,7 +1044,10 @@ public: ...@@ -1043,7 +1044,10 @@ public:
} }
} }
spdlog::info("{} processing event: {}", selfId, evt);
if(evt.empty()) { if(evt.empty()) {
spdlog::error("{} can't process empty event");
continue; continue;
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论