summaryrefslogtreecommitdiffstats
path: root/src/os.c
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2021-03-12 21:08:13 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2021-03-12 21:08:13 +0000
commit8cf1b43148f689d41e29b4ba281b603acd9dd6c6 (patch)
tree4562b8f672b12e680383e0f27cda40a392c4386d /src/os.c
parentAdding upstream version 2.4.2+debian. (diff)
downloaddnsperf-55595e28d317d0ead4f39773ecde6a358e4cda2b.tar.xz
dnsperf-55595e28d317d0ead4f39773ecde6a358e4cda2b.zip
Adding upstream version 2.5.0+debian.upstream/2.5.0+debian
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/os.c')
-rw-r--r--src/os.c13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/os.c b/src/os.c
index addcdac..d149cea 100644
--- a/src/os.c
+++ b/src/os.c
@@ -61,11 +61,12 @@ void perf_os_handlesignal(int sig, void (*handler)(int))
perf_result_t
perf_os_waituntilreadable(struct perf_net_socket* sock, int pipe_fd, int64_t timeout)
{
- return perf_os_waituntilanyreadable(sock, 1, pipe_fd, timeout);
+ struct perf_net_socket* socks[] = { sock };
+ return perf_os_waituntilanyreadable(socks, 1, pipe_fd, timeout);
}
perf_result_t
-perf_os_waituntilanyreadable(struct perf_net_socket* socks, unsigned int nfds, int pipe_fd,
+perf_os_waituntilanyreadable(struct perf_net_socket** socks, unsigned int nfds, int pipe_fd,
int64_t timeout)
{
struct pollfd fds[nfds + 1];
@@ -73,10 +74,10 @@ perf_os_waituntilanyreadable(struct perf_net_socket* socks, unsigned int nfds, i
int to, n;
for (i = 0; i < nfds; i++) {
- if (socks[i].have_more)
+ if (perf_net_have_more(socks[i]))
return (PERF_R_SUCCESS);
- fds[i].fd = socks[i].fd;
+ fds[i].fd = socks[i]->fd;
fds[i].events = POLLIN;
}
@@ -109,7 +110,7 @@ perf_os_waituntilanyreadable(struct perf_net_socket* socks, unsigned int nfds, i
}
perf_result_t
-perf_os_waituntilanywritable(struct perf_net_socket* socks, unsigned int nfds, int pipe_fd,
+perf_os_waituntilanywritable(struct perf_net_socket** socks, unsigned int nfds, int pipe_fd,
int64_t timeout)
{
struct pollfd fds[nfds + 1];
@@ -117,7 +118,7 @@ perf_os_waituntilanywritable(struct perf_net_socket* socks, unsigned int nfds, i
int to, n;
for (i = 0; i < nfds; i++) {
- fds[i].fd = socks[i].fd;
+ fds[i].fd = socks[i]->fd;
fds[i].events = POLLOUT;
}