| | |
| | | remote, remote_len, topic, topic_len, reply, reply_len, timeout_ms); |
| | | } |
| | | |
| | | 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) |
| | | { |
| | | return BHApi_In2_Out1<BHAddress, MsgQueryProc, MsgQueryProcReply>( |
| | | &TopicNode::QueryProcs, |
| | | remote, remote_len, query, query_len, reply, reply_len, timeout_ms); |
| | | } |
| | | |
| | | int BHSubscribeTopics(const void *topics, const int topics_len, void **reply, int *reply_len, const int timeout_ms) |
| | | { |
| | | return BHApi_In1_Out1<MsgTopicList>(&TopicNode::Subscribe, topics, topics_len, reply, reply_len, timeout_ms); |