diff options
Diffstat (limited to 'rts/Sparks.c')
| -rw-r--r-- | rts/Sparks.c | 18 |
1 files changed, 2 insertions, 16 deletions
diff --git a/rts/Sparks.c b/rts/Sparks.c index ecd3c38a17..bd5e120863 100644 --- a/rts/Sparks.c +++ b/rts/Sparks.c @@ -14,6 +14,7 @@ #include "Trace.h" #include "Prelude.h" #include "Sparks.h" +#include "ThreadLabels.h" #include "sm/HeapAlloc.h" #if defined(THREADED_RTS) @@ -43,7 +44,7 @@ createSparkThread (Capability *cap) tso = createIOThread (cap, RtsFlags.GcFlags.initialStkSize, (StgClosure *)runSparks_closure); - + labelThread(cap, tso, "spark evaluator"); traceEventCreateSparkThread(cap, tso->id); appendToRunQueue(cap,tso); @@ -283,21 +284,6 @@ traverseSparkQueue (evac_fn evac, void *user, Capability *cap) sparkPoolSize(pool), pool->bottom, pool->top); } -/* ---------------------------------------------------------------------------- - * balanceSparkPoolsCaps: takes an array of capabilities (usually: all - * capabilities) and its size. Accesses all spark pools and equally - * distributes the sparks among them. - * - * Could be called after GC, before Cap. release, from scheduler. - * -------------------------------------------------------------------------- */ -void balanceSparkPoolsCaps(uint32_t n_caps, Capability caps[]) - GNUC3_ATTRIBUTE(__noreturn__); - -void balanceSparkPoolsCaps(uint32_t n_caps STG_UNUSED, - Capability caps[] STG_UNUSED) { - barf("not implemented"); -} - #else StgInt |