zhangmeng
2024-04-09 2561a007b8d8999a4750046d0cfb3b1ad5af50ac
src/net/net_mod_socket_wrapper.cpp
@@ -103,11 +103,6 @@
   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);
@@ -128,6 +123,21 @@
  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 等待时间,单位是千分之一秒