From 5f246a2c098b663fa44d87bc5c9ac5c8f74bbcc1 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期五, 26 二月 2021 14:04:39 +0800 Subject: [PATCH] update --- 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