taskCount = 0;
workerCount = 0;
tasksRunning = 0;
+#if defined(THREADED_RTS)
+ maxWorkers = DEFAULT_MAX_WORKERS * RtsFlags.ParFlags.nNodes;
+#else
maxWorkers = DEFAULT_MAX_WORKERS;
+#endif
initialized = 1;
#if defined(THREADED_RTS)
newThreadLocalKey(¤tTaskKey);
{
ASSERT_LOCK_HELD(&sched_mutex);
if (!task->stopped) {
- debugTrace(DEBUG_sched, "discarding task %p", TASK_ID(task));
+ debugTrace(DEBUG_sched, "discarding task %ld", TASK_ID(task));
task->cap = NULL;
task->tso = NULL;
task->stopped = rtsTrue;
void
resetTaskManagerAfterFork (void)
{
-#warning TODO!
+ // TODO!
taskCount = 0;
}