X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FSparks.c;h=2167de0dcf7c07de20649243209a6ecee4d8ef28;hb=eb5ecfbe174cda6b40a22f44b2b0cdfd2ef2f149;hp=7e89d46c663a161441d6b23c6564a25479d5698a;hpb=9211ec0183bbe923ec6c5997fa695e5f5a3eefab;p=ghc-hetmet.git diff --git a/rts/Sparks.c b/rts/Sparks.c index 7e89d46..2167de0 100644 --- a/rts/Sparks.c +++ b/rts/Sparks.c @@ -58,12 +58,7 @@ createSparkThread (Capability *cap) tso = createIOThread (cap, RtsFlags.GcFlags.initialStkSize, &base_GHCziConc_runSparks_closure); - if (cap->r.rCurrentTSO != NULL) - // Capability in a bound thread? - postEvent(cap, EVENT_SPARK_TO_THREAD, cap->r.rCurrentTSO->id, tso->id); - else - // Capability in a worker thread? - postEvent(cap, EVENT_SPARK_TO_THREAD, 0, tso->id); + postEvent(cap, EVENT_CREATE_SPARK_THREAD, 0, tso->id); appendToRunQueue(cap,tso); }