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