固定bus key

wangzhengquan

2020-12-04 aa2f3b2a9968bb4928463bdae05fb026d16b60bb

 test_net_socket/test_net_mod_socket.c

@@ -1,5 +1,7 @@
#include "net_mod_server_socket_wrapper.h"
#include "net_mod_socket_wrapper.h"
#include "bus_server_socket_wrapper.h"

#include "shm_mm_wraper.h"
#include "usg_common.h"
#include <getopt.h>
@@ -52,6 +54,36 @@
  
}


void start_bus_server() {
  printf("Start bus server\n");
  void * server_socket = bus_server_socket_wrapper_open();
  if(bus_server_socket_wrapper_start_bus(server_socket) != 0) {
    printf("start bus failed\n");
    exit(1);
  }
}

 

void start_reply(int key) {
  printf("start reply\n");
  void *client = net_mod_socket_open();
  net_mod_socket_bind(client, key);
  int size;
  void *recvbuf;
  char sendbuf[512];
  int rv;
  int remote_port;
  while ( (rv = net_mod_socket_recvfrom(client, &recvbuf, &size, &remote_port) ) == 0) {
   // printf( "server: RECEIVED REQUEST FROM PORT %d NAME %s\n", remote_port, recvbuf);
    sprintf(sendbuf, "RECEIVED  PORT %d NAME %s", remote_port, recvbuf);
    net_mod_socket_sendto(client, sendbuf, strlen(sendbuf) + 1, remote_port);
    free(recvbuf);
  }
}


void start_net_client(char *sendlist, char*publist ){
   client = net_mod_socket_open();
   char content[MAXLINE];
@@ -93,9 +125,8 @@
       
        if (fgets(content, MAXLINE, stdin) != NULL) {
           // 收到消息的节点即使没有对应的信息， 也要回复一个表示无的消息,否则会一直等待
          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);
          n = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, content, strlen(content), &recv_arr, &recv_arr_size);
          printf(" %d nodes reply\n", n);
          for(i=0; i<recv_arr_size; i++) {
             printf("host:%s, port: %d, key:%d, content: %s\n", 
                recv_arr[i].host,
@@ -110,10 +141,10 @@
        }
    }
    else if(strcmp(action, "desub") == 0) {
      printf("Please input buskey and topic!\n");
      printf("Please input topic!\n");
       
      scanf("%d %s", &buskey, topic);
      if (net_mod_socket_desub(client, topic, strlen(topic),  buskey) == 0) {
      scanf("%s", topic);
      if (net_mod_socket_desub(client, topic, strlen(topic)) == 0) {
         printf("%d Desub success!\n", net_mod_socket_get_key(client));
      } else {
        printf("Desub failture!\n");
@@ -122,11 +153,10 @@
     
    } 
    else if(strcmp(action, "sub") == 0) {
      printf("Please input buskey and topic!\n");
      scanf("%d %s",&buskey, topic);
      printf("Please input topic!\n");
      scanf("%s",topic);

      printf("===%d %s\n",buskey, topic);
      if (net_mod_socket_sub(client, topic, strlen(topic),  buskey) == 0) {
      if (net_mod_socket_sub(client, topic, strlen(topic)) == 0) {
         printf("%d Sub success!\n", net_mod_socket_get_key(client));
      } else {
        printf("Sub failture!\n");
@@ -147,34 +177,6 @@
  
}


void start_bus_server(int key) {
  printf("Start bus server\n");
  void * server_socket = net_mod_socket_open();
  
  net_mod_socket_bind(server_socket, key);
   
  net_mod_socket_start_bus(server_socket);
}

 

void start_reply(int key) {
  printf("start reply\n");
  void *socket = net_mod_socket_open();
  net_mod_socket_bind(socket, key);
  int size;
  void *recvbuf;
  char sendbuf[512];
  int rv;
  int remote_port;
  while ( (rv = net_mod_socket_recvfrom(socket, &recvbuf, &size, &remote_port) ) == 0) {
   // printf( "server: RECEIVED REQUEST FROM PORT %d NAME %s\n", remote_port, recvbuf);
    sprintf(sendbuf, "RECEIVED  PORT %d NAME %s", remote_port, recvbuf);
    net_mod_socket_sendto(socket, sendbuf, strlen(sendbuf) + 1, remote_port);
    free(recvbuf);
  }
}

 

@@ -360,7 +362,7 @@
      usage(argv[0]);
      exit(1);
    }
    start_bus_server(opt.key);
    start_bus_server();
  }
  else if (strcmp("start_reply", opt.fun) == 0) {
    if(opt.key == 0) {
@@ -556,10 +558,15 @@
  for(i = 0; i < entry_arr_len; i++) {
    property_arr_len = str_split(entry_arr[i], ":", &property_arr);
  // printf("%s, %s, %s\n", property_arr[0], property_arr[1], property_arr[2]);
    node_arr[i] = {trim(property_arr[0], 0), atoi(property_arr[1]), atoi(property_arr[2])};
    free(entry_arr[i]);
    node_arr[i] = {trim(property_arr[0], 0), atoi(property_arr[1]), 0};
   
    free(property_arr[1]);
    free(property_arr[2]);
    if(property_arr_len == 3) {
      node_arr[i].key = atoi(property_arr[2]);
      free(property_arr[2]);
    }
    free(entry_arr[i]);
   
  }
  *node_arr_addr = node_arr;