update

wangzhengquan

2020-07-20 f75a37444e7a97fb58439077eea4d1b3c576bfe3

 test2/client.c

@@ -1,6 +1,5 @@
#include "shm_queue_wrapper.h"
#include "mm.h"
 

typedef struct msg_t
{
   int key;
@@ -17,15 +16,17 @@
   msg_t msg;
   msg.key = key;

   msg_t rec_msg;
   void * rec_msg;
   int rec_msg_size;
   //入队
   while(true) {
     printf("=====>say some thing:\n");
     scanf("%s", msg.buf);
     shmqueue_push(remote_queue, (void *)&msg, sizeof(msg));
     //printf("send: %s\n",  msg.buf);
     shmqueue_pop(local_queue, (void *)&rec_msg );
     printf("=====>peer : %s\n",  rec_msg.buf);
     shmqueue_pop(local_queue, &rec_msg, &rec_msg_size);
     printf("=====>peer : %s\n",  ((msg_t*)rec_msg)->buf);
     free(rec_msg);

     
   }