From 8b4ddf10e71e1c8fabd33c72b282f7da65ff682f Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期二, 14 七月 2020 15:59:44 +0800
Subject: [PATCH] commit
---
test2/server.c | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/test2/server.c b/test2/server.c
index 2cf97a1..f3fa3b5 100644
--- a/test2/server.c
+++ b/test2/server.c
@@ -9,7 +9,8 @@
} msg_t;
void server() {
- msg_t msg;
+ void * msg;
+ int msg_size;
msg_t send_msg;
int key = 1;
size_t qsize = 16;
@@ -17,11 +18,11 @@
struct timespec timeout = {1, 0};
- while(shmqueue_pop(local_queue, (void *)&msg) ) {
- void * remote_queue = shmqueue_attach(msg.key);
- printf("received: %s\n", msg.buf);
+ while(shmqueue_pop(local_queue, &msg, &msg_size) ) {
+ void * remote_queue = shmqueue_attach(((msg_t *)msg)->key);
+ printf("received: %s\n", ((msg_t *)msg)->buf);
// send_msg.key = 1;
- sprintf(send_msg.buf, "hello, I have received: %s!", msg.buf);
+ sprintf(send_msg.buf, "hello, I have received: %s!", ((msg_t *)msg)->buf);
shmqueue_push(remote_queue, (void *)&send_msg, sizeof(send_msg));
shmqueue_drop(remote_queue);
// cout << item.pic << endl;
--
Gitblit v1.8.0