wangzhengquan
2020-12-24 8284df1d749fa7adb334fe4f43da77bfc9c05a71
test_net_socket/heart_beat.c
@@ -28,14 +28,12 @@
  char sendbuf[512];
  int rv;
  int remote_port;
  while (true) {
    if ((rv =  net_mod_socket_recvfrom(serv, &recvbuf, &size, &remote_port) ) == 0) {
      printf( "RECEIVED HREARTBEAT FROM %d: %s\n", remote_port, recvbuf);
      net_mod_socket_sendto(serv, "suc", strlen("suc")+1, remote_port);
      free(recvbuf);
    }
  while (net_mod_socket_recvfrom(serv, &recvbuf, &size, &remote_port) == 0) {
    printf( "RECEIVED HREARTBEAT FROM %d: %s\n", remote_port, recvbuf);
    net_mod_socket_sendto(serv, "suc", strlen("suc")+1, remote_port);
    free(recvbuf);
  }
  // sleep(1000);
  net_mod_socket_close(serv);
}
@@ -45,7 +43,7 @@
  int size;
  char sendbuf[512];
  long i = 0;
  net_node_t node_arr[] = {"", 0, 100};
  net_node_t node_arr[] = {"", 0, port};
  int node_arr_size = 1;
  int recv_arr_size;
@@ -53,7 +51,7 @@
  while (true) {
    sprintf(sendbuf, "%d", i);
    printf("SEND HEART:%s\n", sendbuf);
    rv = net_mod_socket_sendandrecv(client, node_arr, node_arr_size, sendbuf, strlen(sendbuf)+1, NULL, NULL);
    rv = net_mod_socket_sendandrecv_timeout(client, node_arr, node_arr_size, sendbuf, strlen(sendbuf)+1, NULL, NULL, 1000);
   // sleep(1);
    i++;
  }