update

wangzhengquan

2021-02-04 83956b12d863924936a98c9dfbece37feb0cce9c

 src/net/net_mod_socket_wrapper.cpp

@@ -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_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_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_fn callback, void * user_data) {
  NetModSocket *sockt = (NetModSocket *)_socket;
  return sockt->recvandsend(  callback, NULL, BUS_NOWAIT_FLAG, user_data);
}


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