From 903b27f875e5f2a872c1b309f354b18c0450f35a Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期五, 04 六月 2021 11:46:18 +0800 Subject: [PATCH] allow tcp request with no dest, auto query topic. --- src/defs.h | 6 +----- 1 files changed, 1 insertions(+), 5 deletions(-) diff --git a/src/defs.h b/src/defs.h index 5f6fc16..ec41371 100644 --- a/src/defs.h +++ b/src/defs.h @@ -39,9 +39,6 @@ MQInfo mq_bus_; MQInfo mq_sender_; robust::AtomicReqRep init_rr_; - std::atomic<MQId> mqid_; - CenterInfo() : - mqid_(100000) {} }; const int kBHCenterPort = 24287; @@ -59,12 +56,11 @@ ShmSocket &DefaultSender(SharedMemory &shm); MQId NewSession(); -bool CenterInit(SharedMemory &shm); +bool CenterInit(); bool GlobalInit(SharedMemory &shm); typedef std::string Topic; void SetLastError(const int ec, const std::string &msg); void GetLastError(int &ec, std::string &msg); -//TODO center can check shm for previous crash. const MQInfo &BHTopicCenterAddress(SharedMemory &shm); const MQInfo &BHTopicBusAddress(SharedMemory &shm); -- Gitblit v1.8.0