From b861de29176891657cc96631ddbfb4ea9e114a42 Mon Sep 17 00:00:00 2001 From: Fu Juntang <StrongTiger_001@163.com> Date: 星期一, 30 八月 2021 17:52:23 +0800 Subject: [PATCH] re-structure the communication work flow. --- src/bh_api.h | 28 ++++++++++++++++++++++------ 1 files changed, 22 insertions(+), 6 deletions(-) diff --git a/src/bh_api.h b/src/bh_api.h index 75a9c17..40d9ffa 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,12 @@ void BHFree(void *buf, int size); +int BHGetLastError(void **msg, int *msg_len); + #ifdef __cplusplus } #endif -#endif +#endif /* end of include guard: BH_API_WRAPPER_O81WKNXI */ + + + -- Gitblit v1.8.0