| | |
| | | } // 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(); } |
| | | |
| | |
| | | *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); |
| | | }; |