lichao
2021-06-02 993c556000a414011626770540678948f16eaa9e
box/center_topic_node.cpp
@@ -56,7 +56,7 @@
} // namespace
CenterTopicNode::CenterTopicNode(CenterPtr center, SharedMemory &shm) :
    pscenter_(center), pnode_(new TopicNode(shm)), run_(false) {}
    pscenter_(center), pnode_(new TopicNode(shm, 200)), run_(false) {}
CenterTopicNode::~CenterTopicNode() { Stop(); }
@@ -106,7 +106,7 @@
         *reply.mutable_errmsg() = data.errmsg();
         reply.set_data(ToJson(data));
      } else {
         SetError(*reply.mutable_errmsg(), eInvalidInput, "not supported topic" + request.topic());
         SetError(*reply.mutable_errmsg(), eInvalidInput, "invalid topic: " + request.topic());
      }
      pnode_->ServerSendReply(src_info, reply);
   };