update

wangzhengquan

2020-12-01 e994d555ba64d68d874099ed7c1b9e22c0b592b0

 test_net_socket/test_net_mod_socket.c

@@ -1,6 +1,6 @@
#include "net_mod_server_socket_wrapper.h"
#include "net_mod_socket_wrapper.h"
#include "shm_mm.h"
#include "shm_mm_wraper.h"
#include "usg_common.h"
#include <getopt.h>

@@ -29,7 +29,7 @@
  printf("Start net proxy\n");
   void *serverSocket  = net_mod_server_socket_open(port);
   if(net_mod_server_socket_start(serverSocket) != 0) {
      err_msg(errno, "net_mod_server_socket_start");
      err_exit(errno, "net_mod_server_socket_start");
   }
}

@@ -87,8 +87,8 @@
       
        if (fgets(content, MAXLINE, stdin) != NULL) {
           // 收到消息的节点即使没有对应的信息， 也要回复一个表示无的消息,否则会一直等待
          n = net_mod_socket_sendandrecv_timeout(client, node_arr, node_arr_size, content, 
          strlen(content), &recv_arr, &recv_arr_size, 5000);
          n = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, content, 
          strlen(content), &recv_arr, &recv_arr_size);
          printf("send %d nodes\n", n);
          for(i=0; i<recv_arr_size; i++) {
             printf("host:%s, port: %d, key:%d, content: %s\n", 
@@ -257,7 +257,7 @@


int main(int argc, char *argv[]) {
   shm_init(512);
   shm_mm_wrapper_init(512);
 
  argument_t opt = parse_args(argc, argv);