From 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6 Mon Sep 17 00:00:00 2001 From: liuxiaolong <liuxiaolong@aiotlink.com> Date: 星期三, 05 一月 2022 14:11:39 +0800 Subject: [PATCH] pb.go MsgQueryProcReply add subLocalTopics and subNetTopics --- src/bh_api.h | 39 ++++++++++++++++++++++++++++++++++++--- 1 files changed, 36 insertions(+), 3 deletions(-) diff --git a/src/bh_api.h b/src/bh_api.h index 3ef07cc..2a9e39a 100644 --- a/src/bh_api.h +++ b/src/bh_api.h @@ -1,9 +1,11 @@ -#ifndef BH_API -#define BH_API +#ifndef _BH_API_WRAPPER_ +#define _BH_API_WRAPPER_ #ifdef __cplusplus extern "C" { #endif + +#define PRO_DE_SERIALIZE 1 int BHRegister(const void *proc_info, const int proc_info_len, @@ -17,11 +19,20 @@ 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, @@ -31,6 +42,18 @@ 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); + int BHHeartbeatEasy(const int timeout_ms); int BHHeartbeat(const void *proc_info, const int proc_info_len, @@ -38,9 +61,13 @@ int *reply_len, const int timeout_ms); +#if defined(PRO_DE_SERIALIZE) int BHPublish(const void *msgpub, const int msgpub_len, const int timeout_ms); +#else +int BHPublish(const char *topic, const char *content, const int timeout_ms); +#endif int BHReadSub(void **proc_id, int *proc_id_len, @@ -82,7 +109,13 @@ int BHGetLastError(void **msg, int *msg_len); +int inter_key_get(void); +void inter_key_set(int key); +void *socket_data_get(void); #ifdef __cplusplus } #endif -#endif +#endif /* end of include guard: BH_API_WRAPPER_O81WKNXI */ + + + -- Gitblit v1.8.0