| | |
| | | #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(); } |