src/shm_msg_queue.cpp
@@ -31,12 +31,6 @@ } // namespace ShmMsgQueue::MQId ShmMsgQueue::NewId() { static auto &id = GetData("Must init shared memory before use! Please make sure center is running."); return (++id) * 10; } ShmMsgQueue::ShmMsgQueue(ShmType &segment, const MQId id, const int len) : id_(id), queue_(segment, MsgQIdToName(id_), len, segment.get_segment_manager()) @@ -84,7 +78,7 @@ if (IsCmd(val)) { LOG_DEBUG() << "clsing queue " << id << ", has a cmd" << DecodeCmd(val); } else { MsgI(val).Release(); MsgI(val, shm).Release(); } } }