update

wangzhengquan

2020-07-20 f75a37444e7a97fb58439077eea4d1b3c576bfe3

 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;