| | |
| | | #include "shm.h" |
| | | |
| | | using namespace bhome_shm; |
| | | typedef BHCenter::MsgHandler Handler; |
| | | |
| | | Handler Join(Handler h1, Handler h2) |
| | | { |
| | | return [h1, h2](ShmSocket &socket, bhome_msg::MsgI &imsg, bhome::msg::BHMsg &msg) { |
| | | return h1(socket, imsg, msg) || h2(socket, imsg, msg); |
| | | }; |
| | | } |
| | | |
| | | SharedMemory &BHomeShm() |
| | | { |
| | |
| | | } |
| | | |
| | | BHCenter::BHCenter(Socket::Shm &shm) : |
| | | socket_(shm) {} |
| | | socket_(shm, &kBHUniCenter, 1000) {} |
| | | |
| | | BHCenter::BHCenter() : |
| | | BHCenter(BHomeShm()) {} |
| | | |
| | | bool BHCenter::Start() |
| | | { |
| | | return false; |
| | | auto onCenter = MakeReqRepCenter(); |
| | | auto onBus = MakeBusCenter(); |
| | | |
| | | socket_.Start(Join(onCenter, onBus)); |
| | | } |
| | |
| | | |
| | | const MQId kBHTopicBus = boost::uuids::string_generator()("01234567-89ab-cdef-8349-1234567890ff"); |
| | | const MQId kBHTopicReqRepCenter = boost::uuids::string_generator()("12345670-89ab-cdef-8349-1234567890ff"); |
| | | const MQId kBHUniCenter = boost::uuids::string_generator()("87654321-89ab-cdef-8349-1234567890ff"); |
| | | |
| | | const int kBHCenterPort = 24287; |
| | | const char kTopicSep = '.'; |
| | | namespace bhome_shm |