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 | 31 +++++++++++++++++++++++++------
1 files changed, 25 insertions(+), 6 deletions(-)
diff --git a/src/bh_api.h b/src/bh_api.h
index 75a9c17..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,15 +19,19 @@
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 *topic, const int topic_len,
- void **reply, int *reply_len,
+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,
@@ -41,6 +47,7 @@
void **reply,
int *reply_len,
const int timeout_ms);
+
int BHSubscribeNetTopics(const void *topics,
const int topics_len,
void **reply,
@@ -54,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,
@@ -96,7 +107,15 @@
void BHFree(void *buf, int size);
+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