| | |
| | | #ifndef DEFS_KP8LKGD0 |
| | | #define DEFS_KP8LKGD0 |
| | | |
| | | #include "robust.h" |
| | | #include <atomic> |
| | | #include <string> |
| | | |
| | |
| | | struct CenterInfo { |
| | | MQInfo mq_center_; |
| | | MQInfo mq_bus_; |
| | | MQInfo mq_init_; |
| | | MQInfo mq_sender_; |
| | | robust::AtomicReqRep init_rr_; |
| | | std::atomic<MQId> mqid_; |
| | | CenterInfo() : |
| | | mqid_(100000) {} |
| | |
| | | const MQInfo &BHGlobalSenderAddress(); |
| | | const MQInfo &BHTopicCenterAddress(); |
| | | const MQInfo &BHTopicBusAddress(); |
| | | const MQInfo &BHCenterReplyAddress(); |
| | | bool BHNodeInit(const int64_t request, int64_t &reply); |
| | | void BHCenterHandleInit(std::function<int64_t(const int64_t)> const &onReq); |
| | | |
| | | #endif // end of include guard: DEFS_KP8LKGD0 |