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/center.cpp | 15 +++++++++++++--
1 files changed, 13 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
--
Gitblit v1.8.0