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