From 658e74cc759db6fb6d51d5287749cff1cfd2a0a2 Mon Sep 17 00:00:00 2001 From: Fu Juntang <StrongTiger_001@163.com> Date: 星期六, 04 九月 2021 10:48:31 +0800 Subject: [PATCH] Add strict parameters checks to avoid the invalid inputs. --- src/bh_api.h | 36 +++++++++++++++++++++++++++++++++--- 1 files changed, 33 insertions(+), 3 deletions(-) diff --git a/src/bh_api.h b/src/bh_api.h index 3ef07cc..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,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, @@ -85,4 +112,7 @@ #ifdef __cplusplus } #endif -#endif +#endif /* end of include guard: BH_API_WRAPPER_O81WKNXI */ + + + -- Gitblit v1.8.0