From 5c912c70e9333298ff48f7ea15424f72ca977b99 Mon Sep 17 00:00:00 2001 From: Fu Juntang <StrongTiger_001@163.com> Date: 星期五, 17 九月 2021 09:43:55 +0800 Subject: [PATCH] Add the heartbeat logic feature. --- src/socket/bus_server_socket_wrapper.cpp | 40 ++++++++++++++++++++++++++++++++++++---- 1 files changed, 36 insertions(+), 4 deletions(-) diff --git a/src/socket/bus_server_socket_wrapper.cpp b/src/socket/bus_server_socket_wrapper.cpp index d2f5a8e..db8bfe5 100644 --- a/src/socket/bus_server_socket_wrapper.cpp +++ b/src/socket/bus_server_socket_wrapper.cpp @@ -7,7 +7,6 @@ * 鍒涘缓 */ void * bus_server_socket_wrapper_open() { - logger->debug("===bus_server_socket_wrapper_open\n"); BusServerSocket *sockt = new BusServerSocket; return (void *)sockt; } @@ -19,7 +18,6 @@ BusServerSocket *sockt = (BusServerSocket *)_socket; delete sockt; - logger->debug("===bus_server_socket_wrapper_close\n"); } int bus_server_socket_wrapper_stop(void *_socket) { @@ -35,11 +33,45 @@ int ret; BusServerSocket *sockt = (BusServerSocket *)_socket; - if( (ret = sockt->force_bind(SHM_BUS_KEY)) == 0) { + if( (ret = sockt->bind(SHM_BUS_KEY)) == 0) { return sockt->start(); } else { logger->error("start bus failed"); return -1; } -} \ No newline at end of file +} + +int bus_server_socket_wrapper_data_get(void * _socket, int val) { + int ret; + BusServerSocket *sockt = (BusServerSocket *)_socket; + + ret = sockt->get_data(val); + + return ret; + +} + +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) { + int ret; + BusServerSocket *sockt = (BusServerSocket *)_socket; + + ret = sockt->check_proc(val, buf, len, buf_ret, len_ret, timeout, flag); + + return ret; + +} + +void bus_server_socket_wrapper_proc_release(void * _socket, int val) { + + BusServerSocket *sockt = (BusServerSocket *)_socket; + + sockt->remove_proc(val); + +} + + + + + -- Gitblit v1.8.0