about summary refs log tree commit diff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/nix-worker/main.cc12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/nix-worker/main.cc b/src/nix-worker/main.cc
index 4fa43f643cc9..2f87ce2bf766 100644
--- a/src/nix-worker/main.cc
+++ b/src/nix-worker/main.cc
@@ -60,7 +60,7 @@ static void tunnelStderr(const unsigned char * buf, size_t count)
    si_code in siginfo_t.  That would make most of the SIGPOLL
    complexity unnecessary, i.e., we could just enable SIGPOLL all the
    time and wouldn't have to worry about races. */
-static void sigioHandler(int sigNo)
+static void sigPollHandler(int sigNo)
 {
     if (!blockInt) {
         _isInterrupted = 1;
@@ -71,10 +71,10 @@ static void sigioHandler(int sigNo)
 }
 
 
-static void setSigPollAction(bool ignore)
+static void setSigPollAction(bool enable)
 {
     struct sigaction act, oact;
-    act.sa_handler = ignore ? SIG_IGN : sigioHandler;
+    act.sa_handler = enable ? sigPollHandler : SIG_IGN;
     sigfillset(&act.sa_mask);
     act.sa_flags = 0;
     if (sigaction(SIGPOLL, &act, &oact))
@@ -89,7 +89,7 @@ static void startWork()
     canSendStderr = true;
 
     /* Handle client death asynchronously. */
-    setSigPollAction(false);
+    setSigPollAction(true);
 
     /* Of course, there is a race condition here: the socket could
        have closed between when we last read from / wrote to it, and
@@ -126,7 +126,7 @@ static void stopWork(bool success = true, const string & msg = "")
     /* Stop handling async client death; we're going to a state where
        we're either sending or receiving from the client, so we'll be
        notified of client death anyway. */
-    setSigPollAction(true);
+    setSigPollAction(false);
     
     canSendStderr = false;
 
@@ -315,7 +315,7 @@ static void processConnection()
     writeToStderr = tunnelStderr;
 
     /* Allow us to receive SIGPOLL for events on the client socket. */
-    setSigPollAction(true);
+    setSigPollAction(false);
     if (fcntl(from.fd, F_SETOWN, getpid()) == -1)
         throw SysError("F_SETOWN");
     if (fcntl(from.fd, F_SETFL, fcntl(from.fd, F_GETFL, 0) | FASYNC) == -1)