X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FSparks.c;h=2167de0dcf7c07de20649243209a6ecee4d8ef28;hb=ed4beb8bc5e49d84e38b047c2dfc14eb22c74607;hp=75464d925b95f0d9d811be9e2e7d1ef3a963dd05;hpb=6f045438008234fe58c7629ce1b33e3524fc9006;p=ghc-hetmet.git

diff --git a/rts/Sparks.c b/rts/Sparks.c
index 75464d9..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);
 }
@@ -91,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;
 }