src/topic_node.h
@@ -39,7 +39,7 @@ const MQInfo &BusAddr() const { return BHTopicBusAddress(shm()); } public: TopicNode(SharedMemory &shm); TopicNode(SharedMemory &shm, MQId ssn_id = 0); ~TopicNode(); // topic node @@ -163,8 +163,8 @@ bool Init(); bool Valid() const { return state() != eStateUninited; } std::mutex mutex_; MQId ssn_id_ = 0; std::atomic<State> state_; MQId ssn_id_ = 0; int proc_index_ = -1; TopicQueryCache topic_query_cache_;