| | |
|---|
| | | { |
|---|
| | | return SendImpl(remote, cmd, std::forward<decltype(t)>(t)...); |
|---|
| | | } |
|---|
| | | bool SyncRecv(int64_t &cmd, const int timeout_ms); |
|---|
| | | bool SyncRecv(MsgI &msg, bhome_msg::BHMsgHead &head, const int timeout_ms); |
|---|
| | | |
|---|
| | | template <class Body> |
|---|
| | | bool SendAndRecv(const MQInfo &remote, BHMsgHead &head, Body &body, MsgI &reply, BHMsgHead &reply_head, const int timeout_ms) |
|---|
| | |
|---|
| | | |
|---|
| | | Synced<CallbackRecords<std::string, RecvCB>> per_msg_cbs_; |
|---|
| | | Synced<CallbackRecords<int, RawRecvCB>> alloc_cbs_; |
|---|
| | | |
|---|
| | | SendQ send_buffer_; |
|---|
| | | |
|---|
| | | // node request center alloc memory. |
|---|
| | | int node_proc_index_ = -1; |
|---|
| | | int socket_index_ = -1; |
|---|
