commit

wangzhengquan

2020-07-14 8b4ddf10e71e1c8fabd33c72b282f7da65ff682f

 test2/client.c

@@ -17,15 +17,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);

     
   }