lichao
2021-04-06 4deeafbd502dc3c57dab8ad6ca601a38a9e7f074
add uni center.
2个文件已修改
17 ■■■■ 已修改文件
src/center.cpp 15 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/defs.h 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/center.cpp
@@ -22,6 +22,14 @@
#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()
{
@@ -30,12 +38,15 @@
}
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));
}
src/defs.h
@@ -27,6 +27,8 @@
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