From 68d23225a38a35f1325eb39fa4ed5a005d5de473 Mon Sep 17 00:00:00 2001 From: fujuntang <fujuntang@aiot.com> Date: 星期三, 11 八月 2021 09:50:20 +0800 Subject: [PATCH] fix from 3.1 first commit --- src/socket/shm_socket.h | 10 +++++----- 1 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/socket/shm_socket.h b/src/socket/shm_socket.h index 516a343..97d9f2c 100644 --- a/src/socket/shm_socket.h +++ b/src/socket/shm_socket.h @@ -38,8 +38,8 @@ LockFreeQueue<shm_packet_t> *queue; //self queue LockFreeQueue<shm_packet_t> *remoteQueue; // peer queue - std::map<std::string, shm_packet_t> recvbuf; - + std::map<std::string, shm_packet_t> recvbuf; // for uuid + std::map<int, shm_packet_t> recvbuf2; //for thread local } shm_socket_t; @@ -48,12 +48,12 @@ size_t shm_socket_remove_keys(int keys[], size_t length); size_t shm_socket_remove_keys_exclude(int keys[], size_t length); -shm_socket_t *shm_open_socket(shm_socket_type_t socket_type); +shm_socket_t *shm_socket_open(shm_socket_type_t socket_type); -int shm_close_socket(shm_socket_t * socket) ; +int shm_socket_close(shm_socket_t * sockt) ; -int shm_socket_stop(shm_socket_t *sockt); +int shm_socket_stop(shm_socket_t * sockt); int shm_socket_bind(shm_socket_t * socket, int key) ; -- Gitblit v1.8.0