提交 6abf9c0a authored 作者: blu's avatar blu

big refacting of communitation architect

上级 c67db2c4
......@@ -572,6 +572,20 @@ public:
spdlog::error("evcloudsvc failed setup router: {}", addr);
exit(1);
}
// setup edge msg processor
thMsgProcessor = thread([this](){
while(true){
auto v = zmqhelper::z_recv_multiple(this->pRouter);
if(v.size() == 0) {
spdlog::error("evdaemon {} failed to receive msg {}", this->devSn, zmq_strerror(zmq_errno()));
}else{
handleMsg(v);
}
}
});
thMsgProcessor.detach();
spdlog::info("evdaemon {} edge message processor had setup {}", devSn, addr);
};
~EvCloudSvc() {};
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论