src/shm_msg_queue.cpp
@@ -37,10 +37,7 @@ { } ShmMsgQueue::ShmMsgQueue(const int64_t abs_addr, ShmType &segment, const MQId id) : id_(id), queue_(abs_addr, segment, MsgQIdToName(id_)) { //TODO check some tag. } id_(id), queue_(abs_addr, segment, MsgQIdToName(id_)) {} ShmMsgQueue::~ShmMsgQueue() {} @@ -68,7 +65,6 @@ bool ShmMsgQueue::TrySend(SharedMemory &shm, const MQInfo &remote, const RawData val) { try { //TODO find from center, or use offset. ShmMsgQueue dest(remote.offset_, shm, remote.id_); return dest.queue().TryWrite(val); } catch (...) {