X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2Fposix%2FSignals.c;h=4bb1255dac8d9d8d2e3bf3461e7c7a0b84c99d05;hb=888b4e89a4a4e3f39a3ba567c796b3a79b63bf61;hp=aa7877452ba0d18df665453b03e04593431c21dc;hpb=3501ac6af749ada0afcaf84f112ab2e4bf9120b9;p=ghc-hetmet.git diff --git a/rts/posix/Signals.c b/rts/posix/Signals.c index aa78774..4bb1255 100644 --- a/rts/posix/Signals.c +++ b/rts/posix/Signals.c @@ -86,18 +86,16 @@ static int io_manager_pipe = -1; #define IO_MANAGER_WAKEUP 0xff #define IO_MANAGER_DIE 0xfe +#define IO_MANAGER_SYNC 0xfd void setIOManagerPipe (int fd) { // only called when THREADED_RTS, but unconditionally // compiled here because GHC.Conc depends on it. - if (io_manager_pipe < 0) { - io_manager_pipe = fd; - } + io_manager_pipe = fd; } -#if defined(THREADED_RTS) void ioManagerWakeup (void) { @@ -111,6 +109,19 @@ ioManagerWakeup (void) } void +ioManagerSync (void) +{ + int r; + // Wake up the IO Manager thread by sending a byte down its pipe + if (io_manager_pipe >= 0) { + StgWord8 byte = (StgWord8)IO_MANAGER_SYNC; + r = write(io_manager_pipe, &byte, 1); + if (r == -1) { sysErrorBelch("ioManagerSync: write"); } + } +} + +#if defined(THREADED_RTS) +void ioManagerDie (void) { int r; @@ -172,7 +183,14 @@ generic_handler(int sig USED_IF_THREADS, int r; buf[0] = sig; - memcpy(buf+1, info, sizeof(siginfo_t)); + + if (info == NULL) { + // info may be NULL on Solaris (see #3790) + memset(buf+1, 0, sizeof(siginfo_t)); + } else { + memcpy(buf+1, info, sizeof(siginfo_t)); + } + r = write(io_manager_pipe, buf, sizeof(siginfo_t)+1); if (r == -1 && errno == EAGAIN) {