| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | ShmMsgQueue::ShmMsgQueue(ShmType &segment, const int len) : |
|---|
| | | ShmMsgQueue(NewId(), segment, len) |
|---|
| | | { |
|---|
| | | } |
|---|
| | | ShmMsgQueue(NewId(), segment, len) {} |
|---|
| | | |
|---|
| | | ShmMsgQueue::~ShmMsgQueue() |
|---|
| | | ShmMsgQueue::~ShmMsgQueue() {} |
|---|
| | | |
|---|
| | | bool ShmMsgQueue::Remove(SharedMemory &shm, const MQId &id) |
|---|
| | | { |
|---|
| | | // It's not safe to remove, others may still holder pointers and write to it. |
|---|
| | | // TODO use smart_ptr or garbage collection. |
|---|
| | | //Remove(); |
|---|
| | | return Super::Remove(shm, MsgQIdToName(id)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | bool ShmMsgQueue::Send(SharedMemory &shm, const MQId &remote_id, const MsgI &msg, const int timeout_ms, OnSend const &onsend) |
|---|
