/**
|
* @file
|
*
|
* @brief 总线服务。
|
*
|
* @details 发布订阅服务的路由，负责记录订阅者的消息并把发布者发布的消息转发给感兴趣的订阅者
|
*/
|
|
|
#ifndef _BUS_SERVER_SOCKET_WRAPPER_H_
|
#define _BUS_SERVER_SOCKET_WRAPPER_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);
|
|
/**
|
* @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
|
}
|
#endif
|
|
#endif
|
