Merge branch 'master' into dev

wangzhengquan

2020-10-13 32be9184bcab815ed1795889612a2c2c84a17334

Merge branch 'master' into dev

 src/libshm_queue.a

Binary files differ

 src/socket/net_mod_server_socket.c

@@ -175,6 +175,7 @@
    {
      pool.nready--;
      if(process_client(connfd) != 0) {
        LoggerFactory::getLogger()->debug("===server close client %d\n", connfd);
        Close(connfd); //line:conc:echoservers:closeconnfd
        FD_CLR(connfd, &pool.read_set); 
        pool.clientfd[i] = -1;

 src/socket/net_mod_socket.c

@@ -15,6 +15,7 @@
  rio_t * rio;
  for (auto map_iter = connectionMap.begin(); map_iter != connectionMap.end(); map_iter++) {
    rio = map_iter->second;
    Close(rio->rio_fd);
    if(rio != NULL) {
      free(rio);
    }
@@ -91,7 +92,12 @@
    }

LABEL_ARR_PUSH:
    if(node->host != NULL) {
    strcpy( ret_arr[i].host, node->host);
    } else {
       strcpy( ret_arr[i].host, "local");
    }
   
    ret_arr[i].port = node->port;
    ret_arr[i].key = node->key;
    ret_arr[i].content = recv_buf;

 test_net_socket/firwall.sh

@@ -4,3 +4,7 @@
firewall-cmd --state
# 关闭防火墙
systemctl stop firewalld.service


ssh -p 100 basic@192.168.5.22:/data/disk2/test/build    
ssh basic@192.168.20.10:/data3/workspace/wzq/build

 test_net_socket/net_mod_socket.c

@@ -19,16 +19,16 @@
    int node_arr_size = 3;
    //192.168.20.104
    net_node_t node_arr[] = {
        {"192.168.20.104", port, 11},
        {"192.168.20.104", port, 12},
        {"192.168.20.104", port, 13}
        {"192.168.5.22", port, 11},
        {"192.168.20.10", port, 12},
        {"localhost", port, 13}
    };

    int pub_node_arr_size = 3;
    net_node_t pub_node_arr[] = {
        {"192.168.20.104", port, 8},
        {"192.168.20.104", port, 8},
        {"192.168.20.104", port, 8}
        {"192.168.5.22", port, 8},
        {"192.168.20.10", port, 8},
        {"localhost", port, 8}
    };
    
  while (true) {

 test_net_socket/net_mod_socket.sh

@@ -3,7 +3,7 @@
    ./dgram_mod_req_rep server 11 &
    ./dgram_mod_req_rep server 12 &
    ./dgram_mod_req_rep server 13 &
    ./dgram_mod_req_rep server 14 &
	

    ./dgram_mod_bus server 8 &