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 | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/test2/server.c b/test2/server.c
index 0f8b446..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;
@@ -34,10 +35,10 @@
int main () {
- mm_init(512);
+ shm_init(512);
server();
//鏁翠釜杩涚▼閫�鍑烘椂闇�瑕佹墽琛岃繖涓柟娉曪紝璇ユ柟娉曢鍏堜細妫�鏌ユ槸鍚﹁繕鏈夊叾浠栬繘绋嬪湪浣跨敤璇ュ叡浜唴瀛橈紝濡傛灉杩樻湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ氨鍙槸detach,濡傛灉娌℃湁鍏朵粬杩涚▼鍦ㄤ娇鐢ㄥ垯閿�姣佹暣鍧楀唴瀛樸��
- mm_destroy();
+ shm_destroy();
return 0;
}
\ No newline at end of file
--
Gitblit v1.8.0