src/msg.cpp
@@ -37,8 +37,12 @@ } auto n = meta()->count_.Dec(); if (n == 0) { int64_t free_cmd = (id() << 4) | EncodeCmd(eCmdFree); Sender().Send(BHTopicCenterAddress(), free_cmd); if (meta()->managed_) { int64_t free_cmd = (id() << 4) | EncodeCmd(eCmdFree); Sender().Send(BHTopicCenterAddress(), free_cmd); } else { Free(); } } else if (n < 0) { LOG_FATAL() << "error double release data."; throw std::runtime_error("double release msg.");