From 58d904a328c0d849769b483e901a0be9426b8209 Mon Sep 17 00:00:00 2001 From: liuxiaolong <liuxiaolong@aiotlink.com> Date: 星期二, 20 七月 2021 20:20:44 +0800 Subject: [PATCH] 调整Request C.BHFree的位置 --- src/defs.h | 8 +++----- 1 files changed, 3 insertions(+), 5 deletions(-) diff --git a/src/defs.h b/src/defs.h index b117579..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); @@ -74,4 +70,6 @@ // node mq is avail with in timeout; after that may get killed. int NodeTimeoutSec(); +std::string BHLogDir(); + #endif // end of include guard: DEFS_KP8LKGD0 -- Gitblit v1.8.0