From f5886fef7eb0c44ec854d00a70acc0dfc4975efa Mon Sep 17 00:00:00 2001 From: Cigy Cyriac Date: Tue, 10 Aug 2010 19:49:43 -0400 Subject: [PATCH] Not all platforms have MSG_DONTWAIT Signed-off-by: Jens Axboe --- engines/net.c | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/engines/net.c b/engines/net.c index c0a793e8..9e6e789e 100644 --- a/engines/net.c +++ b/engines/net.c @@ -223,7 +223,10 @@ static int fio_netio_splice_out(struct thread_data *td, struct io_u *io_u) static int fio_netio_send(struct thread_data *td, struct io_u *io_u) { struct netio_data *nd = td->io_ops->data; - int ret, flags = MSG_DONTWAIT; + int ret, flags = 0; +#ifdef MSG_DONTWAIT + flags = MSG_DONTWAIT; +#endif do { if (nd->net_protocol == IPPROTO_UDP) { @@ -251,7 +254,9 @@ static int fio_netio_send(struct thread_data *td, struct io_u *io_u) if (ret <= 0) break; +#ifdef MSG_DONTWAIT flags &= ~MSG_DONTWAIT; +#endif } while (1); return ret; @@ -276,7 +281,10 @@ static int is_udp_close(struct io_u *io_u, int len) static int fio_netio_recv(struct thread_data *td, struct io_u *io_u) { struct netio_data *nd = td->io_ops->data; - int ret, flags = MSG_DONTWAIT; + int ret, flags = 0; +#ifdef MSG_DONTWAIT + flags = MSG_DONTWAIT; +#endif do { if (nd->net_protocol == IPPROTO_UDP) { @@ -299,7 +307,9 @@ static int fio_netio_recv(struct thread_data *td, struct io_u *io_u) ret = poll_wait(td, io_u->file->fd, POLLIN); if (ret <= 0) break; +#ifdef MSG_DONTWAIT flags &= ~MSG_DONTWAIT; +#endif flags |= MSG_WAITALL; } while (1); -- 2.25.1