net engine: termination fixes

Signed-off-by: Jens Axboe <jens.axboe@oracle.com>

diff --git a/engines/net.c b/engines/net.c
index afb3265c6ada813179fa12853ec121d6632ab378..700f1626be8640c43f373375af0c54942b63e1e0 100644 (file)
--- a/engines/net.c
+++ b/engines/net.c
@@ -43,7 +43,7 @@ static int poll_wait(struct thread_data *td, int fd, short events)
                ret = poll(&pfd, 1, -1);
                if (ret < 0) {
                        if (errno == EINTR)
-                               continue;
+                               break;
 
                        td_verror(td, errno, "poll");
                        return -1;
@@ -55,8 +55,6 @@ static int poll_wait(struct thread_data *td, int fd, short events)
 
        if (pfd.revents & events)
                return 1;
-       else if (td->terminate)
-               return 1;
 
        return -1;
 }