From 330f78f3334bcdcdb4cc2ab2dbf66604e0224d71 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 21 五月 2021 16:21:45 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/valib/bhshmq
---
src/bh_api.h | 160 ++++++++++++++++++++++++++++++++++++-----------------
1 files changed, 108 insertions(+), 52 deletions(-)
diff --git a/src/bh_api.h b/src/bh_api.h
index 1b351ca..3b77da5 100644
--- a/src/bh_api.h
+++ b/src/bh_api.h
@@ -5,73 +5,129 @@
extern "C" {
#endif
-struct BHSrcInfo;
-struct BHServerCallbackTag;
+typedef int (*FBHApiIn1Out1)(const void *proc_info,
+ const int proc_info_len,
+ void **reply,
+ int *reply_len,
+ const int timeout_ms);
-bool BHRegister(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);
-typedef void (*FSubDataCallback)(const void *proc_id,
- const int proc_id_len,
- const void *data,
- const int data_len);
+int BHRegister(const void *proc_info,
+ const int proc_info_len,
+ void **reply,
+ int *reply_len,
+ const int timeout_ms);
-typedef void (*FServerCallback)(const void *proc_id,
- const int proc_id_len,
- const void *data,
- const int data_len,
- BHServerCallbackTag *tag);
-
-void BHStartWorker(FServerCallback server_cb, FSubDataCallback sub_cb);
-bool BHServerCallbackReply(const BHServerCallbackTag *tag,
- const void *data,
- const int data_len);
-
-bool BHHeartBeatEasy(const int timeout_ms);
-bool BHHeartBeat(const void *proc_info,
+int BHUnregister(const void *proc_info,
const int proc_info_len,
void **reply,
int *reply_len,
const int timeout_ms);
-bool BHPublish(const void *msgpub,
- const int msgpub_len,
- const int timeout_ms);
+int BHRegisterTopics(const void *topics,
+ const int topics_len,
+ void **reply,
+ int *reply_len,
+ const int timeout_ms);
-bool BHReadSub(const void *proc_id,
- const int proc_id_len,
- void **msgpub,
- int *msgpub_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);
-bool BHRequest(const void *request,
- const int request_len,
- void **proc_id,
- int *proc_id_len,
- void **reply,
- int *reply_len,
- const int timeout_ms);
-
-bool BHReadRequest(void **proc_id,
- int *proc_id_len,
- void **request,
- int *request_len,
- BHSrcInfo **src,
- const int timeout_ms);
-
-bool BHSendReply(BHSrcInfo *src,
- const void *reply,
- const int reply_len,
+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 BHCleanUp();
+int BHSubscribeTopics(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);
+int BHGetLastError(void **msg, int *msg_len);
#ifdef __cplusplus
}
--
Gitblit v1.8.0