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/reqrep_center.h | 14 ++++----------
1 files changed, 4 insertions(+), 10 deletions(-)
diff --git a/src/reqrep_center.h b/src/reqrep_center.h
index 6473841..326ac7a 100644
--- a/src/reqrep_center.h
+++ b/src/reqrep_center.h
@@ -18,24 +18,18 @@
#ifndef REQREP_CENTER_US3RBM60
#define REQREP_CENTER_US3RBM60
+#include "center.h"
#include "defs.h"
#include "socket.h"
+BHCenter::MsgHandler MakeReqRepCenter();
class ReqRepCenter
{
- class Socket : public ShmSocket
- {
- public:
- Socket(ShmSocket::Shm &shm) :
- ShmSocket(shm, &kBHTopicReqRepCenter, 1000) {}
- using ShmSocket::shm;
- };
- Socket socket_;
- ShmSocket::Shm &shm() { return socket_.shm(); }
+ ShmSocket socket_;
public:
ReqRepCenter(ShmSocket::Shm &shm) :
- socket_(shm) {}
+ socket_(shm, &kBHTopicReqRepCenter, 1000) {}
ReqRepCenter() :
ReqRepCenter(BHomeShm()) {}
~ReqRepCenter() { Stop(); }
--
Gitblit v1.8.0