Merge branch 'master' into dev

wangzhengquan

2021-02-20 8bfe9f711612efde96a0d7b7aa3ba7178ab51640

 test_net_socket/test_net_mod_socket.cpp

@@ -75,6 +75,11 @@
   }
}

void start_resycle() {
  shm_mm_wrapper_start_resycle();
}


// 打印接受到的订阅消息
void *print_sub_msg(void *sockt) {
  pthread_detach(pthread_self());
@@ -370,7 +375,8 @@
  double difftime = end.tv_sec * 1000000 + end.tv_usec - (start.tv_sec * 1000000 + start.tv_usec);
  long diffsec = (long) (difftime/1000000);
  long diffusec = difftime - diffsec*1000000;
  fprintf(stderr,"发送数目: %ld, 用时: (%ld sec %ld usec), 平均: %f\n", total, diffsec, diffusec, difftime/total );
  fprintf(stderr,"发送数目:%ld, 成功数目: %ld, 用时: (%ld sec %ld usec), 平均: %f\n", 
    SCALE*node_arr_size, total, diffsec, diffusec, difftime/total );
  // fflush(stdout);
 
}
@@ -601,6 +607,9 @@
     
    test_net_pub(opt.publist);
  }
  else if (strcmp("start_resycle", opt.fun) == 0) {
    start_resycle();
  }
  
  else {
    usage(argv[0]);
@@ -609,7 +618,7 @@
  }

  printf("==========end========\n");
  shm_mm_wrapper_destroy();
  // shm_mm_wrapper_destroy();

}