uuid msg

wangzhengquan

2021-02-03 758438289fc45829a8f6cef1b42afed0a1a8cb60

 src/net/net_mod_socket.cpp

@@ -141,6 +141,8 @@
}




int NetModSocket::_sendandrecv_(net_node_t *node_arr, int arrlen, void *send_buf, int send_size, 
  net_mod_recv_msg_t ** recv_arr, int *recv_arr_size, int  msec ) {

@@ -495,6 +497,24 @@
  return shmModSocket.recvfrom(buf, size, key, NULL, BUS_NOWAIT_FLAG);
}



int NetModSocket::recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) {
  return shmModSocket.recvandsend( recvbuf, recvsize, key, callback);

}

int NetModSocket::recvandsend_timeout(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback,
                              const struct timespec *timeout ) {
  return shmModSocket.recvandsend( recvbuf, recvsize, key, callback, timeout, BUS_TIMEOUT_FLAG);

}

int NetModSocket::recvandsend_nowait(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) {
  return shmModSocket.recvandsend( recvbuf, recvsize, key, callback, NULL,  BUS_NOWAIT_FLAG);

}

/**
 * 发送请求信息并等待接收应答
 * @key 发送给谁