| | |
| | | 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); |
| | | } |
| | | |
| | |
| | | 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; |
| | |
| | | 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++; |
| | | } |