From 6c07fe29a5185835f28059f627a1d30e462da28b Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 29 六月 2021 14:01:19 +0800
Subject: [PATCH] add notify node change.
---
src/topic_node.h | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/topic_node.h b/src/topic_node.h
index 3d6767b..1425844 100644
--- a/src/topic_node.h
+++ b/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_;
--
Gitblit v1.8.0