X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2Fposix%2FSignals.c;h=fcfa1f121453b08fa864b383ffac92b8a6590618;hb=33b42ef9c0d3b05ad889959bb1d143ae9ffe1665;hp=ded85f5d3959adb978ec4047c140a13b8c0c4728;hpb=ab0e778ccfde61aed4c22679b24d175fc6cc9bf3;p=ghc-hetmet.git diff --git a/rts/posix/Signals.c b/rts/posix/Signals.c index ded85f5..fcfa1f1 100644 --- a/rts/posix/Signals.c +++ b/rts/posix/Signals.c @@ -11,14 +11,13 @@ */ #include "Rts.h" #include "SchedAPI.h" -#include "Storage.h" #include "Schedule.h" #include "RtsSignals.h" #include "posix/Signals.h" #include "RtsUtils.h" #include "RtsFlags.h" #include "Prelude.h" -#include "Stable.h" +#include "ThrIOManager.h" #ifdef alpha_HOST_ARCH # if defined(linux_HOST_OS) @@ -42,7 +41,7 @@ * to POSIX.1 to control whether or not to include SA_NOCLDSTOP when * installing a SIGCHLD handler. */ -StgInt nocldstop = 0; +HsInt nocldstop = 0; /* ----------------------------------------------------------------------------- * The table of signal handlers @@ -165,22 +164,6 @@ StgPtr *next_pending_handler = pending_handler_buf; #endif /* THREADED_RTS */ /* ----------------------------------------------------------------------------- - * SIGCONT handler - * - * It seems that shells tend to put stdin back into blocking mode - * following a suspend/resume of the process. Here we arrange to put - * it back into non-blocking mode. We don't do anything to - * stdout/stderr because these handles don't get put into non-blocking - * mode at all - see the comments on stdout/stderr in PrelHandle.hsc. - * -------------------------------------------------------------------------- */ - -static void -cont_handler(int sig STG_UNUSED) -{ - setNonBlockingFd(0); -} - -/* ----------------------------------------------------------------------------- * Low-level signal handler * * Places the requested handler on a stack of pending handlers to be @@ -250,11 +233,6 @@ generic_handler(int sig) sigaddset(&signals, sig); sigprocmask(SIG_UNBLOCK, &signals, NULL); - // *always* do the SIGCONT handler, even if the user overrides it. - if (sig == SIGCONT) { - cont_handler(sig); - } - context_switch = 1; } @@ -414,19 +392,19 @@ startSignalHandlers(Capability *cap) #if !defined(THREADED_RTS) void -markSignalHandlers (evac_fn evac) +markSignalHandlers (evac_fn evac, void *user) { StgPtr *p; p = next_pending_handler; while (p != pending_handler_buf) { p--; - evac((StgClosure **)p); + evac(user, (StgClosure **)p); } } #else void -markSignalHandlers (evac_fn evac STG_UNUSED) +markSignalHandlers (evac_fn evac STG_UNUSED, void *user STG_UNUSED) { } #endif @@ -451,24 +429,9 @@ stg_sig_install(StgInt sig STG_UNUSED, * We like to shutdown nicely after receiving a SIGINT, write out the * stats, write profiling info, close open files and flush buffers etc. * -------------------------------------------------------------------------- */ -#ifdef SMP -pthread_t startup_guy; -#endif - static void shutdown_handler(int sig STG_UNUSED) { -#ifdef SMP - // if I'm a worker thread, send this signal to the guy who - // originally called startupHaskell(). Since we're handling - // the signal, it won't be a "send to all threads" type of signal - // (according to the POSIX threads spec). - if (pthread_self() != startup_guy) { - pthread_kill(startup_guy, sig); - return; - } -#endif - // If we're already trying to interrupt the RTS, terminate with // extreme prejudice. So the first ^C tries to exit the program // cleanly, and the second one just kills it. @@ -495,14 +458,10 @@ shutdown_handler(int sig STG_UNUSED) * doesn't seem to do so. * -------------------------------------------------------------------------- */ void -initDefaultHandlers() +initDefaultHandlers(void) { struct sigaction action,oact; -#ifdef SMP - startup_guy = pthread_self(); -#endif - // install the SIGINT handler action.sa_handler = shutdown_handler; sigemptyset(&action.sa_mask); @@ -515,14 +474,6 @@ initDefaultHandlers() siginterrupt(SIGINT, 1); // isn't this the default? --SDM #endif - // install the SIGCONT handler - action.sa_handler = cont_handler; - sigemptyset(&action.sa_mask); - action.sa_flags = 0; - if (sigaction(SIGCONT, &action, &oact) != 0) { - sysErrorBelch("warning: failed to install SIGCONT handler"); - } - // install the SIGFPE handler // In addition to handling SIGINT, also handle SIGFPE by ignoring it. @@ -547,4 +498,11 @@ initDefaultHandlers() #endif } +void +freeSignalHandlers(void) { + if (signal_handlers != NULL) { + stgFree(signal_handlers); + } +} + #endif /* RTS_USER_SIGNALS */