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