From f75a37444e7a97fb58439077eea4d1b3c576bfe3 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 20 七月 2020 11:17:33 +0800
Subject: [PATCH] update
---
test2/server.c | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/test2/server.c b/test2/server.c
index 2cf97a1..d969c83 100644
--- a/test2/server.c
+++ b/test2/server.c
@@ -1,5 +1,5 @@
#include "shm_queue_wrapper.h"
-#include "mm.h"
+
typedef struct msg_t
{
@@ -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