| | |
| | | */ |
| | | void * net_mod_socket_open(); |
| | | |
| | | |
| | | /** |
| | | * @brief 关闭 net_mod_socket |
| | | */ |
| | | void net_mod_socket_close(void *_sockt); |
| | | |
| | | |
| | | /** |
| | | * @brief 停止 net_mod_socket |
| | | */ |
| | | int net_mod_socket_stop(void *_sockt); |
| | | |
| | | /** |
| | | * @brief 绑定端口到socket, 如果不绑定则系统自动分配一个 |
| | |
| | | * |
| | | * @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(void *_sockt, net_node_t *node_arr, int node_arr_len, const char *topic, int topic_size, const void *content, int content_size); |
| | | |
| | | |
| | | /** |
| | |
| | | * |
| | | * @return 成功发布的节点的个数 |
| | | */ |
| | | 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 msec); |
| | | int net_mod_socket_pub_timeout(void *_sockt, net_node_t *node_arr, int node_arr_len, const char *topic, int topic_size, const void *content, int content_size, int msec); |
| | | |
| | | |
| | | /** |
| | |
| | | * |
| | | * @return 成功发布的节点的个数 |
| | | */ |
| | | 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); |
| | | int net_mod_socket_pub_nowait(void *_sockt, net_node_t *node_arr, int node_arr_len, const char *topic, int topic_size, const void *content, int content_size); |
| | | |
| | | /** |
| | | * @brief 订阅感兴趣主题的消息 |