From 54951dfb930bea890aef14be02236f81b3a19f2e Mon Sep 17 00:00:00 2001
From: cheliequan <liequanche@126.com>
Date: 星期二, 27 十二月 2022 10:23:43 +0800
Subject: [PATCH] 更新消息通知库，使用basic_create_ipc_server函数创建消息监听服务器
---
src/ipc_msg.h | 21 ++++++++++++++++++---
1 files changed, 18 insertions(+), 3 deletions(-)
diff --git a/src/ipc_msg.h b/src/ipc_msg.h
index e7ad225..5b489c3 100644
--- a/src/ipc_msg.h
+++ b/src/ipc_msg.h
@@ -11,6 +11,8 @@
#define UNIX_DOMAIN "/tmp/UNIX.domain"
+#define errExit(msg) do { perror(msg); exit(EXIT_FAILURE); \
+} while (0)
#define MAX_LEN 4096
#define HELLO_MSG "hello_basic"
@@ -26,20 +28,33 @@
int len;
} memfd_data_st;
-int send_fd(int fd, memfd_data_st** ppmemfd_data);
+struct user_data
+{
+ int fd;
+ unsigned int n_size;
+ char line[MAX_LEN];
+};
+
+#define READ_THREAD_NUM 2
+#define WRITE_THREAD_NUM 2
+
+int proc_memfd(struct user_data* rdata);
+int basic_create_ipc_server(char * unix_domain_path);
+
+int send_fd_sendmsg(int fd, memfd_data_st** ppmemfd_data);
/**
* @brief 鍙戦�佺洰鏍囨枃浠舵弿杩扮
* @param fd 浼犻�掍俊鎭殑 UNIX 鍩� 鏂囦欢鎻忚堪绗�
* @param fd_to_send 寰呭彂閫佺殑鏂囦欢鎻忚堪绗�
*/
-int send_fd_args(int fd, int fd_to_send, pid_t pid, void **ppdata, int len);
+int send_fd_args_sendmsg(int fd, int fd_to_send, pid_t pid, void **ppdata, int len);
/**
* @brief 鎺ュ彈鏂囦欢鎻忚堪绗�
* @param fd 浼犻�掍俊鎭殑 UNIX 鍩� 鏂囦欢鎻忚堪绗�
*/
-int recv_fd(int fd, memfd_data_st** ppmemfd_data);
+int recv_fd_recvmsg(int fd, memfd_data_st** ppmemfd_data);
#ifdef __cplusplus
}
--
Gitblit v1.8.0