From 4deeafbd502dc3c57dab8ad6ca601a38a9e7f074 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 06 四月 2021 19:10:49 +0800
Subject: [PATCH] add uni center.
---
src/defs.h | 2 ++
src/center.cpp | 15 +++++++++++++--
2 files changed, 15 insertions(+), 2 deletions(-)
diff --git a/src/center.cpp b/src/center.cpp
index d6570aa..9a2fc8f 100644
--- a/src/center.cpp
+++ b/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));
}
\ No newline at end of file
diff --git a/src/defs.h b/src/defs.h
index dfb00ee..8d5f468 100644
--- a/src/defs.h
+++ b/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
--
Gitblit v1.8.0