BThreadWork: make pipe read end non-blocking

1 files changed, 7 insertions, 0 deletions

diff --git a/threadwork/BThreadWork.c b/threadwork/BThreadWork.c
index 133ea9c..088df5c 100644
--- a/threadwork/BThreadWork.c
+++ b/threadwork/BThreadWork.c
@@ -25,6 +25,7 @@
 #ifdef BADVPN_THREADWORK_USE_PTHREAD
     #include <unistd.h>
     #include <errno.h>
+    #include <fcntl.h>
 #endif
 
 #include <misc/offset.h>
@@ -168,6 +169,12 @@ int BThreadWorkDispatcher_Init (BThreadWorkDispatcher *o, BReactor *reactor, int
             goto fail2;
         }
         
+        // set read end non-blocking
+        if (fcntl(o->pipe[0], F_SETFL, O_NONBLOCK) < 0) {
+            BLog(BLOG_ERROR, "pipe failed");
+            goto fail3;
+        }
+        
         // init BFileDescriptor
         BFileDescriptor_Init(&o->bfd, o->pipe[0], (BFileDescriptor_handler)pipe_fd_handler, o);
         if (!BReactor_AddFileDescriptor(o->reactor, &o->bfd)) {