/*
|
* =====================================================================================
|
*
|
* Filename: center.cpp
|
*
|
* Description:
|
*
|
* Version: 1.0
|
* Created: 2021年03月30日 16时19分37秒
|
* Revision: none
|
* Compiler: gcc
|
*
|
* Author: Li Chao (),
|
* Organization:
|
*
|
* =====================================================================================
|
*/
|
#include "center.h"
|
#include "defs.h"
|
#include "pubsub_center.h"
|
#include "reqrep_center.h"
|
#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()
|
{
|
static SharedMemory shm("bhome_default_shm_v0", 1024 * 1024 * 64);
|
return shm;
|
}
|
|
BHCenter::CenterRecords &BHCenter::Centers()
|
{
|
static CenterRecords rec;
|
return rec;
|
}
|
bool BHCenter::Install(const std::string &name, MsgHandler handler, const std::string &mqid, const int mq_len)
|
{
|
CenterRecords()[name] = CenterInfo{name, handler, mqid, mq_len};
|
}
|
|
BHCenter::BHCenter(Socket::Shm &shm)
|
{
|
sockets_["center"] = std::make_shared<ShmSocket>(shm, &BHTopicCenterAddress(), 1000);
|
sockets_["bus"] = std::make_shared<ShmSocket>(shm, &BHTopicBusAddress(), 1000);
|
for (auto &kv : Centers()) {
|
sockets_[kv.first] = std::make_shared<ShmSocket>(shm, kv.second.mqid_.data(), kv.second.mq_len_);
|
}
|
}
|
|
BHCenter::BHCenter() :
|
BHCenter(BHomeShm()) {}
|
|
bool BHCenter::Start()
|
{
|
auto onCenter = MakeReqRepCenter();
|
auto onBus = MakeBusCenter();
|
sockets_["center"]->Start(onCenter);
|
sockets_["bus"]->Start(onBus);
|
|
for (auto &kv : Centers()) {
|
sockets_[kv.first]->Start(kv.second.handler_);
|
}
|
return true;
|
// socket_.Start(Join(onCenter, onBus));
|
}
|
|
bool BHCenter::Stop()
|
{
|
for (auto &kv : sockets_) {
|
kv.second->Stop();
|
}
|
return true;
|
}
|
