wangzhengquan
2020-12-04 aa2f3b2a9968bb4928463bdae05fb026d16b60bb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
#include "bus_server_socket_wrapper.h"
#include "key_def.h"
static Logger *logger = LoggerFactory::getLogger();
 
 
/**
 * 创建
 */
void * bus_server_socket_wrapper_open() {
    
    NetModSocket *sockt = new NetModSocket;
    return (void *)sockt;
}
 
/**
 * 关闭
 */
void bus_server_socket_wrapper_close(void *_socket) {
    NetModSocket *sockt = (NetModSocket *)_socket;
    delete sockt;
}
 
/**
 * 启动bus
 * 
 * @return 0 成功, 其他值 失败的错误码
*/
int  bus_server_socket_wrapper_start_bus(void * _socket) {
    int ret;
    NetModSocket *sockt = (NetModSocket *)_socket;
 
    if( (ret = sockt->bind(BUS_KEY)) == 0) {
        sockt->start_bus();
        return 0;
    } else {
        logger->error("start bus failed");
        return -1;
    }
    
}