arcuru/lix
0
0
Fork 0
forked from lix-project/lix
Code Pull requests Activity

* Some renaming.

Browse source
This commit is contained in:
Eelco Dolstra 2006-12-05 14:15:51 +00:00
parent fc1c20d11b
commit fd4a9db91f
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/nix-worker/main.cc
View file

@ -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 si_code in siginfo_t. That would make most of the SIGPOLL
complexity unnecessary, i.e., we could just enable SIGPOLL all the complexity unnecessary, i.e., we could just enable SIGPOLL all the
time and wouldn't have to worry about races. */ time and wouldn't have to worry about races. */
static void sigioHandler(int sigNo) static void sigPollHandler(int sigNo)
{ {
if (!blockInt) { if (!blockInt) {
_isInterrupted = 1; _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; struct sigaction act, oact;
act.sa_handler = ignore ? SIG_IGN : sigioHandler; act.sa_handler = enable ? sigPollHandler : SIG_IGN;
sigfillset(&act.sa_mask); sigfillset(&act.sa_mask);
act.sa_flags = 0; act.sa_flags = 0;
if (sigaction(SIGPOLL, &act, &oact)) if (sigaction(SIGPOLL, &act, &oact))
@ -89,7 +89,7 @@ static void startWork()
canSendStderr = true; canSendStderr = true;
/* Handle client death asynchronously. */ /* Handle client death asynchronously. */
setSigPollAction(false); setSigPollAction(true);
/* Of course, there is a race condition here: the socket could /* Of course, there is a race condition here: the socket could
have closed between when we last read from / wrote to it, and 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 /* 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 we're either sending or receiving from the client, so we'll be
notified of client death anyway. */ notified of client death anyway. */
setSigPollAction(true); setSigPollAction(false);
canSendStderr = false; canSendStderr = false;
@ -315,7 +315,7 @@ static void processConnection()
writeToStderr = tunnelStderr; writeToStderr = tunnelStderr;
/* Allow us to receive SIGPOLL for events on the client socket. */ /* Allow us to receive SIGPOLL for events on the client socket. */
setSigPollAction(true); setSigPollAction(false);
if (fcntl(from.fd, F_SETOWN, getpid()) == -1) if (fcntl(from.fd, F_SETOWN, getpid()) == -1)
throw SysError("F_SETOWN"); throw SysError("F_SETOWN");
if (fcntl(from.fd, F_SETFL, fcntl(from.fd, F_GETFL, 0) | FASYNC) == -1) if (fcntl(from.fd, F_SETFL, fcntl(from.fd, F_GETFL, 0) | FASYNC) == -1)