lichao
2021-05-21 1c92e4cbc85f9501660444cb76ebb06770da9376
box/center_topic_node.cpp
@@ -79,7 +79,7 @@
   ProcInfo info;
   info.set_proc_id("#center.node");
   info.set_name("center node");
   if (!pnode_->Register(info, reply, timeout)) {
   if (!pnode_->UniRegister(true, info, reply, timeout)) {
      throw std::runtime_error("center node register failed.");
   }
@@ -92,7 +92,14 @@
   auto onRequest = [this](void *src_info, std::string &client_proc_id, MsgRequestTopic &request) {
      auto reply = MakeReply<MsgRequestTopicReply>(eSuccess);
      if (request.topic() == kTopicQueryProc) {
         auto data = (*pscenter_)->QueryProc(request.data());
         std::string id;
         if (!request.data().empty()) {
            Json json;
            if (json.parse(request.data())) {
               id = json.get("proc_id", "");
            }
         }
         auto data = (*pscenter_)->QueryProc(id);
         *reply.mutable_errmsg() = data.errmsg();
         reply.set_data(ToJson(data));
      } else {