/*
|
* =====================================================================================
|
*
|
* Filename: msg.cpp
|
*
|
* Description:
|
*
|
* Version: 1.0
|
* Created: 2021年03月24日 16时48分42秒
|
* Revision: none
|
* Compiler: gcc
|
*
|
* Author: Li Chao (),
|
* Organization:
|
*
|
* =====================================================================================
|
*/
|
#include "msg.h"
|
#include "bh_util.h"
|
#include "defs.h"
|
#include "shm_socket.h"
|
|
namespace bhome_msg
|
{
|
|
ShmSocket &ShmMsg::Sender()
|
{
|
static auto &mq = GetCenterInfo(shm())->mq_sender_;
|
static ShmSocket sender(mq.offset_, shm(), mq.id_);
|
return sender;
|
}
|
|
int ShmMsg::Release()
|
{
|
if (!valid()) {
|
return 0;
|
}
|
auto n = meta()->count_.Dec();
|
if (n == 0) {
|
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.");
|
}
|
return n;
|
}
|
|
void ShmMsg::Free()
|
{
|
assert(valid());
|
shm().Dealloc(meta());
|
offset_ = 0;
|
assert(!valid());
|
}
|
} // namespace bhome_msg
|
