X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FSparks.c;h=2167de0dcf7c07de20649243209a6ecee4d8ef28;hb=34cc75e1a62638f2833815746ebce0a9114dc26b;hp=aed75e52abf1b4288eb3f6b00313adfbed5322a4;hpb=e8d7985d56595f6b8004546bedc41627ca70c528;p=ghc-hetmet.git diff --git a/rts/Sparks.c b/rts/Sparks.c index aed75e5..2167de0 100644 --- a/rts/Sparks.c +++ b/rts/Sparks.c @@ -58,6 +58,8 @@ createSparkThread (Capability *cap) tso = createIOThread (cap, RtsFlags.GcFlags.initialStkSize, &base_GHCziConc_runSparks_closure); + postEvent(cap, EVENT_CREATE_SPARK_THREAD, 0, tso->id); + appendToRunQueue(cap,tso); } @@ -84,7 +86,7 @@ newSpark (StgRegTable *reg, StgClosure *p) cap->sparks_created++; - postEvent(cap, EVENT_CREATE_SPARK, reg->rCurrentTSO->id, 0); + postEvent(cap, EVENT_CREATE_SPARK, cap->r.rCurrentTSO->id, 0); return 1; }