sendandrecv改为线程安全的

wangzhengquan

2020-11-30 900c0972923ac0eeac54425f128d38dffefd381b

 src/socket/net_mod_socket_wrapper.h

@@ -12,6 +12,8 @@
   NetModSocket *sockt;
};



/**
 * 创建
 */
@@ -101,8 +103,8 @@
 * @return 成功发布的节点的个数
 */
int net_mod_socket_pub(void *_sockt, net_node_t *node_arr, int node_arr_len, char *topic, int topic_size, void *content, int content_size);


int net_mod_socket_pub_timeout(void *_sockt, net_node_t *node_arr, int node_arr_len, char *topic, int topic_size, void *content, int content_size, int timeout);
int net_mod_socket_pub_nowait(void *_sockt, net_node_t *node_arr, int node_arr_len, char *topic, int topic_size, void *content, int content_size);

/**
 * 订阅指定主题
@@ -147,6 +149,17 @@
 */
void net_mod_socket_free(void *buf) ;


/**
 * 删除key对应的共享队列，并在bus里删除该key的订阅
 */
int shm_mod_socket_remove_key(int key);

/**
 * 批量删除key对应的共享队列，并在bus里删除该key的订阅
 */
int shm_mod_socket_remove_keys(int keys[], int length);

#ifdef __cplusplus
}
#endif