Add the heartbeat logic feature.

Fu Juntang

2021-09-17 5c912c70e9333298ff48f7ea15424f72ca977b99

 src/socket/bus_server_socket_wrapper.h

@@ -1,3 +1,12 @@
/**
 * @file
 * 
 * @brief 总线服务。
 *
 * @details 发布订阅服务的路由，负责记录订阅者的消息并把发布者发布的消息转发给感兴趣的订阅者
 */


#ifndef _BUS_SERVER_SOCKET_WRAPPER_H_
#define _BUS_SERVER_SOCKET_WRAPPER_H_

@@ -7,24 +16,36 @@
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
}