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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
| #ifndef BH_API_WRAPPER_O81WKNXI
| #define BH_API_WRAPPER_O81WKNXI
|
| #ifdef __cplusplus
| extern "C" {
| #endif
|
| typedef int (*FBHApiIn1Out1)(const void *proc_info,
| const int proc_info_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHApiIn1Out1Proxy(FBHApiIn1Out1 func,
| const void *request,
| const int request_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHRegister(const void *proc_info,
| const int proc_info_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHUnregister(const void *proc_info,
| const int proc_info_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHRegisterTopics(const void *topics,
| const int topics_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHQueryTopicAddress(const void *remote,
| const int remote_len,
| const void *topics,
| const int topics_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHQueryProcs(const void *remote,
| const int remote_len,
| const void *query,
| const int query_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHSubscribeTopics(const void *topics,
| const int topics_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
| int BHSubscribeNetTopics(const void *topics,
| const int topics_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| typedef void (*FSubDataCallback)(const void *proc_id,
| int proc_id_len,
| const void *data,
| int data_len);
|
| typedef void (*FServerCallback)(const void *proc_id,
| int proc_id_len,
| const void *data,
| int data_len,
| void *src);
|
| typedef void (*FClientCallback)(const void *proc_id,
| int proc_id_len,
| const void *msg_id,
| int msg_id_len,
| const void *data,
| int data_len);
|
| void BHStartWorker(FServerCallback server_cb, FSubDataCallback sub_cb, FClientCallback client_cb);
|
| int BHHeartbeatEasy(const int timeout_ms);
| int BHHeartbeat(const void *proc_info,
| const int proc_info_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHPublish(const void *msgpub,
| const int msgpub_len,
| const int timeout_ms);
|
| int BHReadSub(void **proc_id,
| int *proc_id_len,
| void **msgpub,
| int *msgpub_len,
| const int timeout_ms);
|
| int BHAsyncRequest(const void *remote,
| const int remote_len,
| const void *request,
| const int request_len,
| void **msg_id,
| int *msg_id_len);
|
| int BHRequest(const void *remote,
| const int remote_len,
| const void *request,
| const int request_len,
| void **proc_id,
| int *proc_id_len,
| void **reply,
| int *reply_len,
| const int timeout_ms);
|
| int BHReadRequest(void **proc_id,
| int *proc_id_len,
| void **request,
| int *request_len,
| void **src,
| const int timeout_ms);
|
| int BHSendReply(void *src,
| const void *reply,
| const int reply_len);
|
| int BHCleanup();
|
| void BHFree(void *buf, int size);
|
| int BHGetLastError(void **msg, int *msg_len);
|
| #ifdef __cplusplus
| }
| #endif
| #endif /* end of include guard: BH_API_WRAPPER_O81WKNXI */
|
|
