| | |
|---|
| | | MQInfo mq_bus_; |
|---|
| | | MQInfo mq_sender_; |
|---|
| | | robust::AtomicReqRep init_rr_; |
|---|
| | | std::atomic<MQId> mqid_; |
|---|
| | | CenterInfo() : |
|---|
| | | mqid_(100000) {} |
|---|
| | | }; |
|---|
| | | |
|---|
| | | const int kBHCenterPort = 24287; |
|---|
| | |
|---|
| | | 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); |
|---|
| | |
|---|
| | | // node mq is avail with in timeout; after that may get killed. |
|---|
| | | int NodeTimeoutSec(); |
|---|
| | | |
|---|
| | | std::string BHLogDir(); |
|---|
| | | |
|---|
| | | #endif // end of include guard: DEFS_KP8LKGD0 |
|---|
