From f85c9b875b060681b51f57b15074ba1c7c9f5636 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期一, 20 七月 2020 11:10:02 +0800 Subject: [PATCH] update --- queue/include/shm_socket.h | 27 +++++++++------------------ 1 files changed, 9 insertions(+), 18 deletions(-) diff --git a/queue/include/shm_socket.h b/queue/include/shm_socket.h index f14dbc6..8b14f06 100644 --- a/queue/include/shm_socket.h +++ b/queue/include/shm_socket.h @@ -23,6 +23,12 @@ }; +enum shm_connection_status_t { + SHM_CONN_CLOSED=1, + SHM_CONN_LISTEN=2, + SHM_CONN_ESTABLISHED=3 +}; + typedef struct shm_msg_t { int port; shm_msg_type_t type; @@ -35,6 +41,7 @@ typedef struct shm_socket_t { // 鏈湴port int port; + shm_connection_status_t status; SHMQueue<shm_msg_t> *queue; SHMQueue<shm_msg_t> *remoteQueue; LockFreeQueue<shm_msg_t, DM_Allocator> *messageQueue; @@ -45,23 +52,7 @@ } shm_socket_t; -/** - * 鍒濆鍖栧叡浜唴瀛� - * @size 鍏变韩鍐呭瓨澶у皬, 鍗曚綅M - * - */ -void shm_init(int size); -/** - * 閿�姣佸叡浜唴瀛� - * 鏁翠釜杩涚▼閫�鍑烘椂闇�瑕佹墽琛岃繖涓柟娉曪紝璇ユ柟娉曢鍏堜細妫�鏌ユ槸鍚﹁繕鏈夊叾浠栬繘绋嬪湪浣跨敤璇ュ叡浜唴瀛橈紝濡傛灉杩樻湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ氨鍙槸detach,濡傛灉娌℃湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ垯閿�姣佹暣鍧楀唴瀛樸�� - */ -void shm_destroy(); - -/** - * 閲婃斁recv鏂规硶鍒嗛厤鐨刡uf - */ -void shm_free(void *buf); shm_socket_t *shm_open_socket(); @@ -69,7 +60,7 @@ int shm_close_socket(shm_socket_t * socket) ; -int shm_bind(shm_socket_t * socket, int port) ; +int shm_socket_bind(shm_socket_t * socket, int port) ; int shm_listen(shm_socket_t * socket) ; @@ -77,7 +68,7 @@ int shm_connect(shm_socket_t * socket, int port); -int shm_send(shm_socket_t * socket, void *buf, int size) ; +int shm_send(shm_socket_t * socket, const void *buf, const int size) ; int shm_recv(shm_socket_t * socket, void **buf, int *size) ; -- Gitblit v1.8.0