fujuntang
2021-11-10 c479ef57baaaa28964fc3ec8d80ff99dffa7d49f
src/socket/bus_server_socket_wrapper.h
@@ -1,30 +1,51 @@
/**
 * @file
 *
 * @brief 总线服务。
 *
 * @details 发布订阅服务的路由,负责记录订阅者的消息并把发布者发布的消息转发给感兴趣的订阅者
 */
#ifndef _BUS_SERVER_SOCKET_WRAPPER_H_
#define _BUS_SERVER_SOCKET_WRAPPER_H_
#include "net_mod_socket.h"
#include "bus_server_socket.h"
#ifdef __cplusplus
extern "C" {
#endif
/**
 * 创建
 * @brief 创建 bus_server_socket
 * @return bus_server_socket 句柄
 */
void * bus_server_socket_wrapper_open();
/**
 * 关闭
 * @brief 销毁 bus_server_socket
 */
void bus_server_socket_wrapper_close(void *_sockt);
/**
 * 启动bus
 * @brief 停止 bus_server_socket
 */
int bus_server_socket_wrapper_stop(void *_socket);
/**
 * @brief 启动bus
 * 
 * @return 0 成功, 其他值 失败的错误码
*/
int  bus_server_socket_wrapper_start_bus(void * _socket);
int  bus_server_socket_wrapper_data_get(void * _socket, int val);
int  bus_server_socket_wrapper_proc_check(void * _socket, int val, char *buf, int len, void **buf_ret, int *len_ret, \
                          const struct timespec *timeout, const int flag);
void bus_server_socket_wrapper_proc_release(void * _socket, int val);
#ifdef __cplusplus
}