update

wangzhengquan

2021-02-04 770ad3081077e3eb89885bc4d1b3b7d2f470a075

 src/net/net_mod_socket_wrapper.cpp

@@ -35,8 +35,8 @@
*/
int net_mod_socket_force_bind(void * _socket, int key) {
   NetModSocket *sockt = (NetModSocket *)_socket;
   // return sockt->force_bind(key);
   return sockt->bind(key);
   return sockt->force_bind(key);
   // return sockt->bind(key);
}

/**
@@ -113,7 +113,25 @@
   return sockt->sendandrecv_nowait(node_arr,  arrlen, send_buf,  send_size, recv_arr, recv_arr_size);
}

 

int net_mod_socket_recvandsend(void *_socket, recvandsend_callback_wrapper_fn callback, void * user_data) {
  NetModSocket *sockt = (NetModSocket *)_socket;
  return sockt->recvandsend(  callback, NULL, 0, user_data);

}

int net_mod_socket_recvandsend_timeout(void *_socket, recvandsend_callback_wrapper_fn callback,
                                       int sec, int nsec, void * user_data) {
  NetModSocket *sockt = (NetModSocket *)_socket;
  struct timespec timeout = {sec, nsec};
  return sockt->recvandsend(  callback, &timeout, BUS_TIMEOUT_FLAG, user_data);
}

int net_mod_socket_recvandsend_nowait(void *_socket,  recvandsend_callback_wrapper_fn callback, void * user_data) {
  NetModSocket *sockt = (NetModSocket *)_socket;
  return sockt->recvandsend(  callback, NULL, BUS_NOWAIT_FLAG, user_data);
}


 /**
 * 向node_arr 中的所有网络节点发布消息