X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FCapability.h;h=f13afe21174b13c82301de7f2b473801687f3700;hb=4753cf734c79ad196ef4411393a1516465302f71;hp=a2551d0cc5025b7427879aad57bf7ba069f2c212;hpb=0065d5ab628975892cea1ec7303f968c3338cbe1;p=ghc-hetmet.git diff --git a/rts/Capability.h b/rts/Capability.h index a2551d0..f13afe2 100644 --- a/rts/Capability.h +++ b/rts/Capability.h @@ -89,7 +89,8 @@ struct Capability_ { #endif // Per-capability STM-related data - StgTVarWaitQueue *free_tvar_wait_queues; + StgTVarWatchQueue *free_tvar_watch_queues; + StgInvariantCheckQueue *free_invariant_check_queues; StgTRecChunk *free_trec_chunks; StgTRecHeader *free_trec_headers; nat transaction_tokens; @@ -161,6 +162,9 @@ extern Capability *capabilities; // extern Capability *last_free_capability; +// GC indicator, in scope for the scheduler +extern volatile StgWord waiting_for_gc; + // Acquires a capability at a return point. If *cap is non-NULL, then // this is taken as a preference for the Capability we wish to // acquire. @@ -199,6 +203,10 @@ void waitForCapability (Task *task, Mutex *mutex, Capability **pCap); // from the one held by the current Task). // void wakeupThreadOnCapability (Capability *cap, StgTSO *tso); +void wakeupThreadOnCapability_lock (Capability *cap, StgTSO *tso); + +void migrateThreadToCapability (Capability *cap, StgTSO *tso); +void migrateThreadToCapability_lock (Capability *cap, StgTSO *tso); // Wakes up a worker thread on just one Capability, used when we // need to service some global event. @@ -212,7 +220,7 @@ void prodAllCapabilities (void); // Waits for a capability to drain of runnable threads and workers, // and then acquires it. Used at shutdown time. // -void shutdownCapability (Capability *cap, Task *task); +void shutdownCapability (Capability *cap, Task *task, rtsBool wait_foreign); // Attempt to gain control of a Capability if it is free. // @@ -227,6 +235,14 @@ extern void grabCapability (Capability **pCap); #endif /* !THREADED_RTS */ +// Free a capability on exit +void freeCapability (Capability *cap); + +// FOr the GC: +void markSomeCapabilities (evac_fn evac, void *user, nat i0, nat delta); +void markCapabilities (evac_fn evac, void *user); +void traverseSparkQueues (evac_fn evac, void *user); + /* ----------------------------------------------------------------------------- * INLINE functions... private below here * -------------------------------------------------------------------------- */