*
* ---------------------------------------------------------------------------*/
-/* This is non-Posix-compliant.
- #include "PosixSource.h"
-*/
+#include "PosixSource.h"
#include "Rts.h"
-#include "SchedAPI.h"
+
#include "Schedule.h"
#include "RtsSignals.h"
-#include "posix/Signals.h"
+#include "Signals.h"
#include "RtsUtils.h"
-#include "RtsFlags.h"
#include "Prelude.h"
-#include "ThrIOManager.h"
+#include "Stable.h"
#ifdef alpha_HOST_ARCH
# if defined(linux_HOST_OS)
# include <errno.h>
#endif
+#ifdef HAVE_EVENTFD_H
+# include <sys/eventfd.h>
+#endif
+
#include <stdlib.h>
#include <string.h>
}
// Here's the pipe into which we will send our signals
-static int io_manager_pipe = -1;
+static int io_manager_wakeup_fd = -1;
+static int io_manager_control_fd = -1;
#define IO_MANAGER_WAKEUP 0xff
#define IO_MANAGER_DIE 0xfe
+#define IO_MANAGER_SYNC 0xfd
void
-setIOManagerPipe (int fd)
+setIOManagerWakeupFd (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;
- }
+ // compiled here because System.Event.Control depends on it.
+ io_manager_wakeup_fd = fd;
+}
+
+void
+setIOManagerControlFd (int fd)
+{
+ // only called when THREADED_RTS, but unconditionally
+ // compiled here because System.Event.Control depends on it.
+ io_manager_control_fd = fd;
}
-#if defined(THREADED_RTS)
void
ioManagerWakeup (void)
{
int r;
// Wake up the IO Manager thread by sending a byte down its pipe
- if (io_manager_pipe >= 0) {
+ if (io_manager_wakeup_fd >= 0) {
+#if defined(HAVE_EVENTFD)
+ StgWord64 n = (StgWord64)IO_MANAGER_WAKEUP;
+ r = write(io_manager_wakeup_fd, (char *) &n, 8);
+#else
StgWord8 byte = (StgWord8)IO_MANAGER_WAKEUP;
- r = write(io_manager_pipe, &byte, 1);
+ r = write(io_manager_wakeup_fd, &byte, 1);
+#endif
if (r == -1) { sysErrorBelch("ioManagerWakeup: write"); }
}
}
+#if defined(THREADED_RTS)
void
ioManagerDie (void)
{
int r;
// Ask the IO Manager thread to exit
- if (io_manager_pipe >= 0) {
+ if (io_manager_control_fd >= 0) {
StgWord8 byte = (StgWord8)IO_MANAGER_DIE;
- r = write(io_manager_pipe, &byte, 1);
+ r = write(io_manager_control_fd, &byte, 1);
if (r == -1) { sysErrorBelch("ioManagerDie: write"); }
- close(io_manager_pipe);
- io_manager_pipe = -1;
+ io_manager_control_fd = -1;
+ io_manager_wakeup_fd = -1;
}
}
+Capability *
+ioManagerStartCap (Capability *cap)
+{
+ return rts_evalIO(
+ cap,&base_GHCziConcziIO_ensureIOManagerIsRunning_closure,NULL);
+}
+
void
ioManagerStart (void)
{
// Make sure the IO manager thread is running
Capability *cap;
- if (io_manager_pipe < 0) {
+ if (io_manager_control_fd < 0 || io_manager_wakeup_fd < 0) {
cap = rts_lock();
- cap = rts_evalIO(cap,&base_GHCziConc_ensureIOManagerIsRunning_closure,NULL);
+ cap = ioManagerStartCap(cap);
rts_unlock(cap);
}
}
{
#if defined(THREADED_RTS)
- if (io_manager_pipe != -1)
+ if (io_manager_control_fd != -1)
{
StgWord8 buf[sizeof(siginfo_t) + 1];
int r;
buf[0] = sig;
- memcpy(buf+1, info, sizeof(siginfo_t));
- r = write(io_manager_pipe, buf, sizeof(siginfo_t)+1);
+
+ 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_control_fd, buf, sizeof(siginfo_t)+1);
if (r == -1 && errno == EAGAIN)
{
errorBelch("lost signal due to full pipe: %d\n", sig);
{
sigemptyset(&userSignals);
#ifndef THREADED_RTS
- getStablePtr((StgPtr)&base_GHCziConc_runHandlers_closure);
+ getStablePtr((StgPtr)&base_GHCziConcziSignal_runHandlers_closure);
// needed to keep runHandler alive
#endif
}
RtsFlags.GcFlags.initialStkSize,
rts_apply(cap,
rts_apply(cap,
- &base_GHCziConc_runHandlers_closure,
+ &base_GHCziConcziSignal_runHandlers_closure,
rts_mkPtr(cap, info)),
rts_mkInt(cap, info->si_signo))));
}