From 8284df1d749fa7adb334fe4f43da77bfc9c05a71 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期四, 24 十二月 2020 11:35:02 +0800
Subject: [PATCH] add error message method
---
test_net_socket/heart_beat.c | 16 +++++++---------
1 files changed, 7 insertions(+), 9 deletions(-)
diff --git a/test_net_socket/heart_beat.c b/test_net_socket/heart_beat.c
index 562cb23..d7f5ed3 100644
--- a/test_net_socket/heart_beat.c
+++ b/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++;
}
--
Gitblit v1.8.0