| | |
| | | int *reply_len, |
| | | const int timeout_ms); |
| | | |
| | | bool BHRegisterTopics(const void *topics, |
| | | const int topics_len, |
| | | void **reply, |
| | | int *reply_len, |
| | | const int timeout_ms); |
| | | |
| | | bool BHSubscribeTopics(const void *topics, |
| | | const int topics_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, |
| | | BHServerCallbackTag *tag); |
| | | |
| | | void BHStartWorker(FServerCallback server_cb, FSubDataCallback sub_cb); |
| | | typedef void (*FClientCallback)(const void *proc_id, |
| | | const int proc_id_len, |
| | | const void *msg_id, |
| | | const int msg_id_len, |
| | | const void *data, |
| | | const int data_len); |
| | | |
| | | void BHStartWorker(FServerCallback server_cb, FSubDataCallback sub_cb, FClientCallback client_cb); |
| | | bool BHServerCallbackReply(const BHServerCallbackTag *tag, |
| | | const void *data, |
| | | const int data_len); |
| | |
| | | int *msgpub_len, |
| | | const int timeout_ms); |
| | | |
| | | bool BHAsyncRequest(const void *request, |
| | | const int request_len, |
| | | void **msg_id, |
| | | int *msg_id_len); |
| | | |
| | | bool BHRequest(const void *request, |
| | | const int request_len, |
| | | void **proc_id, |