diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-09-04 09:25:26 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-09-04 09:25:26 +0000 |
commit | 65cf0ef6387b1916d771c832447ccddfc028f66e (patch) | |
tree | d608fd551b336ab3718a75fb97fc73b67069dd15 /src/net_tcp.c | |
parent | Adding upstream version 2.13.0. (diff) | |
download | dnsperf-65cf0ef6387b1916d771c832447ccddfc028f66e.tar.xz dnsperf-65cf0ef6387b1916d771c832447ccddfc028f66e.zip |
Adding upstream version 2.13.1.upstream/2.13.1
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/net_tcp.c')
-rw-r--r-- | src/net_tcp.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/net_tcp.c b/src/net_tcp.c index 026dcce..fe3317b 100644 --- a/src/net_tcp.c +++ b/src/net_tcp.c @@ -297,6 +297,9 @@ static int perf__tcp_sockready(struct perf_net_socket* sock, int pipe_fd, int64_ dnslen = ntohs(dnslen); n = sendto(sock->fd, self->sendbuf + self->sending, dnslen + 2 - self->sending, 0, 0, 0); if (n < 0) { + if (errno == EAGAIN) { + return 0; + } int fd = perf__tcp_connect(sock), oldfd = ck_pr_load_int(&sock->fd); ck_pr_store_int(&sock->fd, fd); close(oldfd); @@ -364,7 +367,9 @@ conn_cont: dnslen = ntohs(dnslen); n = sendto(sock->fd, self->sendbuf + self->sending, dnslen + 2 - self->sending, 0, 0, 0); if (n < 0) { - self->need_reconnect = true; + if (errno != EAGAIN) { + self->need_reconnect = true; + } return 0; } self->sending += n; |