update

wangzhengquan

2021-02-04 803d392aeb11665a3e34f7be83f972a1fc7d39c0

 src/net/net_mod_socket.h

@@ -62,10 +62,8 @@
private:
   
  ShmModSocket shmModSocket;
  // pool req_resp_pool;
  NetConnPool *gpool;

  pthread_mutex_t sendMutex;
  // pthread_mutex_t sendMutex;

  // request header 编码为网络传输的字节
  static void * encode_request_head(net_mod_request_head_t & request);
@@ -193,11 +191,13 @@
  int sendandrecv_nowait( const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size) ;


  int recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) ;
  

  int recvandsend_timeout(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback,
                                        const struct timespec *timeout );
  int recvandsend_nowait(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback);
  /**
   * recvandsend
   */
  int recvandsend( recvandsend_callback_fn callback,
                                        const struct timespec *timeout = NULL , int flag = 0, void * user_data = NULL );

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