From 83085f2ce99cca05d40a19482151873a55e6393a Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 02 四月 2021 19:32:21 +0800
Subject: [PATCH] refactor center; add async request no cb.
---
src/pubsub_center.h | 15 +++++----------
1 files changed, 5 insertions(+), 10 deletions(-)
diff --git a/src/pubsub_center.h b/src/pubsub_center.h
index af3a2f4..e79dd96 100644
--- a/src/pubsub_center.h
+++ b/src/pubsub_center.h
@@ -18,28 +18,23 @@
#ifndef PUBSUB_CENTER_MFSUZJU7
#define PUBSUB_CENTER_MFSUZJU7
+#include "center.h"
#include "defs.h"
#include "socket.h"
#include <mutex>
#include <set>
#include <unordered_map>
+BHCenter::MsgHandler MakeBusCenter();
+
// publish/subcribe manager.
class PubSubCenter
{
- class SocketBus : public ShmSocket
- {
- public:
- SocketBus(ShmSocket::Shm &shm) :
- ShmSocket(shm, &kBHTopicBus, 1000) {}
- using ShmSocket::shm;
- };
- SocketBus socket_;
- ShmSocket::Shm &shm() { return socket_.shm(); }
+ ShmSocket socket_;
public:
PubSubCenter(ShmSocket::Shm &shm) :
- socket_(shm) {}
+ socket_(shm, &kBHTopicBus, 1000) {}
PubSubCenter() :
PubSubCenter(BHomeShm()) {}
~PubSubCenter() { Stop(); }
--
Gitblit v1.8.0