| | |
| | | #include "msg.h" |
| | | #include "bh_util.h" |
| | | #include "defs.h" |
| | | #include "socket.h" |
| | | #include "shm_socket.h" |
| | | |
| | | namespace bhome_msg |
| | | { |
| | |
| | | } |
| | | 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."); |