| | |
| | | ShmMsgQueue(const MQId &id, ShmType &segment, const int len); |
| | | ShmMsgQueue(ShmType &segment, const int len); |
| | | ~ShmMsgQueue(); |
| | | // bool Send(const MQId &remote_id, const void *data, const size_t size, const int timeout_ms); // request |
| | | bool Recv(BHMsg &msg, const int timeout_ms); |
| | | bool Send(const MQId &remote_id, const BHMsg &msg, const int timeout_ms); |
| | | const MQId &Id() const { return id_; } |
| | | |
| | | bool Recv(BHMsg &msg, const int timeout_ms); |
| | | bool Recv(MsgI &msg, const int timeout_ms) { return Read(msg, timeout_ms); } |
| | | bool Send(const MQId &remote_id, const BHMsg &msg, const int timeout_ms); |
| | | bool Send(const MQId &remote_id, const MsgI &msg, const int timeout_ms); |
| | | }; |
| | | |