update

wangzhengquan

2021-02-24 36e6a90a33983154633c99f7ac95d09dd68f7bcb

 src/net/net_mod_socket.h

@@ -55,6 +55,14 @@
  
};

struct net_mod_recv_err_t
{
  char host[NI_MAXHOST];
  int port;
  int key;
  int code;  
};

class NetModSocket {
 

@@ -83,14 +91,14 @@
  NetConnPool* _get_pool();

  //读取返回信息
  int read_response(int clientfd, net_mod_recv_msg_t *recv_msg);
  int read_response(int clientfd, net_mod_recv_msg_t *recv_msg, net_mod_recv_err_t *err_arr);
  // 发送请求信息
  int write_request(int clientfd, net_mod_request_head_t &request_head, void *send_buf, int send_size, void *topic_buf, int topic_size);
  int write_request(int clientfd, net_mod_request_head_t &request_head, const void *send_buf, int send_size, const void *topic_buf, int topic_size);

  int _sendandrecv_(net_node_t *node_arr, int node_arr_len, void *send_buf, int send_size, 
    net_mod_recv_msg_t ** recv_arr, int *recv_arr_size, int timeout);

  int _pub_(net_node_t *node_arr, int arrlen, char *topic, int topic_size, void *content, int content_size, int timeout) ;
  int _pub_(net_node_t *node_arr, int arrlen, const char *topic, int topic_size, const void *content, int content_size, int timeout) ;
  

public:
@@ -206,13 +214,13 @@
   * @content 内容，@content_size 内容长度
   * @return 成功发布的节点的个数
   */
  int pub(net_node_t *node_arr, int arrlen, char *topic, int topic_size, void *content, int content_size) ;
  int pub(net_node_t *node_arr, int arrlen, const char *topic, int topic_size, const void *content, int content_size) ;

  int pub_nowait(net_node_t *node_arr, int arrlen, char *topic, int topic_size, void *content, int content_size);
  int pub_nowait(net_node_t *node_arr, int arrlen, const char *topic, int topic_size, const void *content, int content_size);
  /**
   * @msec 毫秒 （千分之一秒）
   */
  int pub_timeout(net_node_t *node_arr, int arrlen, char *topic, int topic_size, void *content, int content_size, int  msec);
  int pub_timeout(net_node_t *node_arr, int arrlen, const char *topic, int topic_size, const void *content, int content_size, int  msec);
  /**
   * 订阅指定主题
   * @topic 主题
@@ -247,10 +255,6 @@
  int  pub_timeout( char *topic, int topic_size, void *content, int content_size, int key, int sec, int nsec);
  int  pub_nowait( char *topic, int topic_size, void *content, int content_size, int key);



  
   

  /**
   * 获取soket key