shm的c++通讯库
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
liuxiaolong
2022-01-05 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6 
 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 */