lichao
2021-04-06 70fec55c71f707358e6dba1b551d7836e93a5c78
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
/*
 * =====================================================================================
 *
 *       Filename:  reqrep_center.h
 *
 *    Description:  
 *
 *        Version:  1.0
 *        Created:  2021年04月01日 14时09分13秒
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  Li Chao (), 
 *   Organization:  
 *
 * =====================================================================================
 */
#ifndef REQREP_CENTER_US3RBM60
#define REQREP_CENTER_US3RBM60
 
#include "center.h"
#include "defs.h"
#include "socket.h"
 
BHCenter::MsgHandler MakeReqRepCenter();
class ReqRepCenter
{
    ShmSocket socket_;
 
public:
    ReqRepCenter(ShmSocket::Shm &shm) :
        socket_(shm, &BHTopicReqRepCenter(), 1000) {}
    ReqRepCenter() :
        ReqRepCenter(BHomeShm()) {}
    ~ReqRepCenter() { Stop(); }
    bool Start(const int nworker = 2);
    bool Stop() { return socket_.Stop(); }
};
 
#endif // end of include guard: REQREP_CENTER_US3RBM60