1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
| /*
| * =====================================================================================
| *
| * 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
| {
|
| 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);
| DefaultSender(shm()).Send(BHTopicCenterAddress(shm()), 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
|
|
