| | |
| | | int sendandrecv_nowait( const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size) ; |
| | | |
| | | |
| | | int recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) ; |
| | | |
| | | |
| | | int recvandsend_timeout(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback, |
| | | const struct timespec *timeout ); |
| | | int recvandsend_nowait(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback); |
| | | int recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback, |
| | | const struct timespec *timeout = NULL , int flag = 0, void * user_data = NULL ); |
| | | |
| | | /** |
| | | * 向node_arr 中的所有网络节点发布消息 |