| | |
| | | using namespace bhome_shm; |
| | | |
| | | ShmSocket::ShmSocket(Shm &shm, const MQId id, const int len) : |
| | | run_(false), mq_(id, shm, len), alloc_id_(0) |
| | | { |
| | | Start(); |
| | | } |
| | | run_(false), mq_(shm, id, len), alloc_id_(0) { Start(); } |
| | | ShmSocket::ShmSocket(Shm &shm, const bool create_or_else_find, const MQId id, const int len) : |
| | | run_(false), mq_(id, create_or_else_find, shm, len), alloc_id_(0) |
| | | { |
| | | Start(); |
| | | } |
| | | ShmSocket::ShmSocket(bhome_shm::SharedMemory &shm, const int len) : |
| | | run_(false), mq_(shm, len), alloc_id_(0) |
| | | { |
| | | Start(); |
| | | } |
| | | run_(false), mq_(shm, create_or_else_find, id, len), alloc_id_(0) { Start(); } |
| | | ShmSocket::ShmSocket(int64_t abs_addr, Shm &shm, const MQId id) : |
| | | run_(false), mq_(abs_addr, shm, id), alloc_id_(0) { Start(); } |
| | | |
| | | ShmSocket::~ShmSocket() |
| | | { |
| | | Stop(); |
| | | } |
| | | ShmSocket::~ShmSocket() { Stop(); } |
| | | |
| | | bool ShmSocket::Start(int nworker, const RecvCB &onData, const RawRecvCB &onRaw, const IdleCB &onIdle) |
| | | { |