X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=ghc%2Frts%2FCapability.h;h=50e0b9400d4531506656889cfc0c51867a269ca8;hb=3034a6c8cfb50e2b5af4ef57c419986039b53a94;hp=f9ae89472153cc694a38a1a026528510d3fe8c20;hpb=677c63455e46b5536800a2dc2db70b64cc802266;p=ghc-hetmet.git diff --git a/ghc/rts/Capability.h b/ghc/rts/Capability.h index f9ae894..50e0b94 100644 --- a/ghc/rts/Capability.h +++ b/ghc/rts/Capability.h @@ -1,19 +1,19 @@ /* --------------------------------------------------------------------------- * - * (c) The GHC Team, 2001-2003 + * (c) The GHC Team, 2001-2006 * * Capabilities * * The notion of a capability is used when operating in multi-threaded - * environments (which the SMP and Threads builds of the RTS do), to + * environments (which the THREADED_RTS build of the RTS does), to * hold all the state an OS thread/task needs to run Haskell code: * its STG registers, a pointer to its TSO, a nursery etc. During * STG execution, a pointer to the capabilitity is kept in a * register (BaseReg). * - * Only in an SMP build will there be multiple capabilities, the threaded - * RTS and other non-threaded builds, there is one global capability, - * namely MainRegTable. + * Only in an THREADED_RTS build will there be multiple capabilities, + * in the non-threaded builds there is one global capability, namely + * MainCapability. * * This header file contains the functions for working with capabilities. * (the main, and only, consumer of this interface is the scheduler). @@ -81,6 +81,12 @@ struct Capability_ { Task *returning_tasks_hd; // Singly-linked, with head/tail Task *returning_tasks_tl; #endif + + // Per-capability STM-related data + StgTVarWaitQueue *free_tvar_wait_queues; + StgTRecChunk *free_trec_chunks; + StgTRecHeader *free_trec_headers; + nat transaction_tokens; }; // typedef Capability, defined in RtsAPI.h @@ -91,12 +97,20 @@ struct Capability_ { #endif // These properties should be true when a Task is holding a Capability -#define ASSERT_CAPABILITY_INVARIANTS(cap,task) \ +#define ASSERT_FULL_CAPABILITY_INVARIANTS(cap,task) \ ASSERT(cap->running_task != NULL && cap->running_task == task); \ ASSERT(task->cap == cap); \ - ASSERT(cap->run_queue_hd == END_TSO_QUEUE ? \ - cap->run_queue_tl == END_TSO_QUEUE : 1); \ - ASSERT(myTask() == task); \ + ASSERT_PARTIAL_CAPABILITY_INVARIANTS(cap,task) + +// Sometimes a Task holds a Capability, but the Task is not associated +// with that Capability (ie. task->cap != cap). This happens when +// (a) a Task holds multiple Capabilities, and (b) when the current +// Task is bound, its thread has just blocked, and it may have been +// moved to another Capability. +#define ASSERT_PARTIAL_CAPABILITY_INVARIANTS(cap,task) \ + ASSERT(cap->run_queue_hd == END_TSO_QUEUE ? \ + cap->run_queue_tl == END_TSO_QUEUE : 1); \ + ASSERT(myTask() == task); \ ASSERT_TASK_ID(task); // Converts a *StgRegTable into a *Capability. @@ -126,8 +140,8 @@ INLINE_HEADER void releaseCapability (Capability* cap STG_UNUSED) {}; INLINE_HEADER void releaseCapability_ (Capability* cap STG_UNUSED) {}; #endif -#if !IN_STG_CODE && !defined(SMP) -// for non-SMP, we have one global capability +#if !IN_STG_CODE +// one global capability extern Capability MainCapability; #endif