summaryrefslogtreecommitdiff
path: root/rts/Schedule.c
diff options
context:
space:
mode:
authorSimon Marlow <marlowsd@gmail.com>2017-07-17 17:32:44 +0100
committerSimon Marlow <marlowsd@gmail.com>2017-07-18 12:45:47 +0100
commit12ae1fa51b2f59e37d6100359b494bee2192ef0a (patch)
treed5c24f6ac1eac5f8252f4dd369a80706b7f86119 /rts/Schedule.c
parentf656fba19d0cefe05643ddea35d080ea332a6584 (diff)
downloadhaskell-12ae1fa51b2f59e37d6100359b494bee2192ef0a.tar.gz
Fix a missing getNewNursery(), and related cleanup
Summary: When we use nursery chunks with +RTS -n<size>, when the current nursery runs out we have to check whether there's another chunk available with getNewNursery(). There was one place we weren't doing this: the ad-hoc heap check in scheduleProcessInbox(). The impact of the bug was that we would GC too early when using nursery chunks, especially in programs that used messages (throwTo between capabilities could do this, also hs_try_putmvar()). Test Plan: validate, also local testing in our application Reviewers: bgamari, niteria, austin, erikd Subscribers: rwbarton, thomie Differential Revision: https://phabricator.haskell.org/D3749
Diffstat (limited to 'rts/Schedule.c')
-rw-r--r--rts/Schedule.c19
1 files changed, 3 insertions, 16 deletions
diff --git a/rts/Schedule.c b/rts/Schedule.c
index 7950785c4f..8002ac37dc 100644
--- a/rts/Schedule.c
+++ b/rts/Schedule.c
@@ -993,8 +993,8 @@ scheduleProcessInbox (Capability **pcap USED_IF_THREADS)
Capability *cap = *pcap;
while (!emptyInbox(cap)) {
- if (cap->r.rCurrentNursery->link == NULL ||
- g0->n_new_large_words >= large_alloc_lim) {
+ // Executing messages might use heap, so we should check for GC.
+ if (doYouWantToGC(cap)) {
scheduleDoGC(pcap, cap->running_task, false);
cap = *pcap;
}
@@ -1183,20 +1183,7 @@ scheduleHandleHeapOverflow( Capability *cap, StgTSO *t )
}
}
- // if we got here because we exceeded large_alloc_lim, then
- // proceed straight to GC.
- if (g0->n_new_large_words >= large_alloc_lim) {
- return true;
- }
-
- // Otherwise, we just ran out of space in the current nursery.
- // Grab another nursery if we can.
- if (getNewNursery(cap)) {
- debugTrace(DEBUG_sched, "thread %ld got a new nursery", t->id);
- return false;
- }
-
- return true;
+ return doYouWantToGC(cap);
/* actual GC is done at the end of the while loop in schedule() */
}