| | |
| | | return sockt->sendandrecv(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size, err_arr, err_arr_size, -1); |
| | | } |
| | | |
| | | int net_mod_socket_bind_proc_id(void * _socket, char *proc_id, int len){ |
| | | NetModSocket *sockt = (NetModSocket *)_socket; |
| | | return sockt->bind_proc_id(proc_id, len); |
| | | } |
| | | |
| | | void net_mod_socket_int_set(void * _socket, int data) { |
| | | NetModSocket *sockt = (NetModSocket *)_socket; |
| | | sockt->int_set(data); |
| | |
| | | return sockt->svr_get(); |
| | | } |
| | | |
| | | void net_mod_socket_buf_data_set(void * _socket, std::string str, int val) { |
| | | NetModSocket *sockt = (NetModSocket *)_socket; |
| | | sockt->buf_data_set(str, val); |
| | | } |
| | | |
| | | int net_mod_socket_buf_data_get(void * _socket, std::string str) { |
| | | NetModSocket *sockt = (NetModSocket *)_socket; |
| | | return sockt->buf_data_get(str); |
| | | } |
| | | |
| | | void net_mod_socket_buf_data_del(void * _socket, std::string str) { |
| | | NetModSocket *sockt = (NetModSocket *)_socket; |
| | | sockt->buf_data_del(str); |
| | | } |
| | | |
| | | /** |
| | | * 如果建立连接的节点没有接受到消息等待timeout的时间后返回 |
| | | * @timeout 等待时间,单位是千分之一秒 |