X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FUpdates.h;h=2b3c35df0c891cbefac4ce9eff9a96a7b896b115;hb=8dbd52c7606588ab7fc7ffd3a54641b7cadc4431;hp=98e9e5a55397e59e27b0cb2b76a6ee30c3aee0b4;hpb=b55e7b53eb4af373764969ab9cfd5a4ef4bc9b8d;p=ghc-hetmet.git diff --git a/rts/Updates.h b/rts/Updates.h index 98e9e5a..2b3c35d 100644 --- a/rts/Updates.h +++ b/rts/Updates.h @@ -9,119 +9,12 @@ #ifndef UPDATES_H #define UPDATES_H -/* ----------------------------------------------------------------------------- - Updates - - We have two layers of update macros. The top layer, UPD_IND() and - friends perform all the work of an update. In detail: - - - if the closure being updated is a blocking queue, then all the - threads waiting on the blocking queue are updated. - - - then the lower level updateWithIndirection() macro is invoked - to actually replace the closure with an indirection (see below). - - -------------------------------------------------------------------------- */ - -# define SEMI ; -# define UPD_IND(updclosure, heapptr) \ - UPD_REAL_IND(updclosure,INFO_PTR(stg_IND_info),heapptr,SEMI) -# define UPD_SPEC_IND(updclosure, ind_info, heapptr, and_then) \ - UPD_REAL_IND(updclosure,ind_info,heapptr,and_then) - -/* These macros have to work in both C and C--, so here's the - * impedance matching: - */ -#ifdef CMINUSMINUS -#define BLOCK_BEGIN -#define BLOCK_END -#define INFO_PTR(info) info -#else -#define BLOCK_BEGIN { -#define BLOCK_END } -#define INFO_PTR(info) &info -#define StgBlockingQueue_blocking_queue(closure) \ - (((StgBlockingQueue *)closure)->blocking_queue) +#ifndef CMINUSMINUS +BEGIN_RTS_PRIVATE #endif -/* krc: there used to be an UPD_REAL_IND and an - UPD_PERM_IND, the latter of which was used for - ticky and cost-centre profiling. - for now, we just have UPD_REAL_IND. */ -#define UPD_REAL_IND(updclosure, ind_info, heapptr, and_then) \ - BLOCK_BEGIN \ - updateWithIndirection(ind_info, \ - updclosure, \ - heapptr, \ - and_then); \ - BLOCK_END - /* ----------------------------------------------------------------------------- - Awaken any threads waiting on a blocking queue (BLACKHOLE_BQ). - -------------------------------------------------------------------------- */ - -#if defined(PAR) - -/* - In a parallel setup several types of closures might have a blocking queue: - BLACKHOLE_BQ ... same as in the default concurrent setup; it will be - reawakened via calling UPD_IND on that closure after - having finished the computation of the graph - FETCH_ME_BQ ... a global indirection (FETCH_ME) may be entered by a - local TSO, turning it into a FETCH_ME_BQ; it will be - reawakened via calling processResume - RBH ... a revertible black hole may be entered by another - local TSO, putting it onto its blocking queue; since - RBHs only exist while the corresponding closure is in - transit, they will be reawakened via calling - convertToFetchMe (upon processing an ACK message) - - In a parallel setup a blocking queue may contain 3 types of closures: - TSO ... as in the default concurrent setup - BLOCKED_FETCH ... indicating that a TSO on another PE is waiting for - the result of the current computation - CONSTR ... an RBHSave closure (which contains data ripped out of - the closure to make room for a blocking queue; since - it only contains data we use the exisiting type of - a CONSTR closure); this closure is the end of a - blocking queue for an RBH closure; it only exists in - this kind of blocking queue and must be at the end - of the queue -*/ -extern void awakenBlockedQueue(StgBlockingQueueElement *q, StgClosure *node); -#define DO_AWAKEN_BQ(bqe, node) STGCALL2(awakenBlockedQueue, bqe, node); - -#define AWAKEN_BQ(info,closure) \ - if (info == &stg_BLACKHOLE_BQ_info || \ - info == &stg_FETCH_ME_BQ_info || \ - get_itbl(closure)->type == RBH) { \ - DO_AWAKEN_BQ(((StgBlockingQueue *)closure)->blocking_queue, closure); \ - } - -#elif defined(GRAN) - -extern void awakenBlockedQueue(StgBlockingQueueElement *q, StgClosure *node); -#define DO_AWAKEN_BQ(bq, node) STGCALL2(awakenBlockedQueue, bq, node); - -/* In GranSim we don't have FETCH_ME or FETCH_ME_BQ closures, so they are - not checked. The rest of the code is the same as for GUM. -*/ -#define AWAKEN_BQ(info,closure) \ - if (info == &stg_BLACKHOLE_BQ_info || \ - get_itbl(closure)->type == RBH) { \ - DO_AWAKEN_BQ(((StgBlockingQueue *)closure)->blocking_queue, closure); \ - } - -#endif /* GRAN || PAR */ - - -/* ----------------------------------------------------------------------------- - Updates: lower-level macros which update a closure with an - indirection to another closure. - - There are several variants of this code. - - PROFILING: + Updates -------------------------------------------------------------------------- */ /* LDV profiling: @@ -233,7 +126,7 @@ no_slop: * invert the optimisation. Grrrr --SDM). */ #ifdef CMINUSMINUS -#define generation(n) (W_[generations] + n*SIZEOF_generation) + #define updateWithIndirection(ind_info, p1, p2, and_then) \ W_ bd; \ \ @@ -242,7 +135,7 @@ no_slop: StgInd_indirectee(p1) = p2; \ prim %write_barrier() []; \ bd = Bdescr(p1); \ - if (bdescr_gen_no(bd) != 0 :: CInt) { \ + if (bdescr_gen_no(bd) != 0 :: bits16) { \ recordMutableCap(p1, TO_W_(bdescr_gen_no(bd)), R1); \ SET_INFO(p1, stg_IND_OLDGEN_info); \ LDV_RECORD_CREATE(p1); \ @@ -254,30 +147,44 @@ no_slop: TICK_UPD_NEW_IND(); \ and_then; \ } -#else -#define updateWithIndirection(ind_info, p1, p2, and_then) \ - { \ - bdescr *bd; \ - \ - ASSERT( (P_)p1 != (P_)p2 ); \ - /* not necessarily true: ASSERT( !closure_IND(p1) ); */ \ - /* occurs in RaiseAsync.c:raiseAsync() */ \ - DEBUG_FILL_SLOP(p1); \ - LDV_RECORD_DEAD_FILL_SLOP_DYNAMIC(p1); \ - ((StgInd *)p1)->indirectee = p2; \ - write_barrier(); \ - bd = Bdescr((P_)p1); \ - if (bd->gen_no != 0) { \ - recordMutableGenLock(p1, &generations[bd->gen_no]); \ - SET_INFO(p1, &stg_IND_OLDGEN_info); \ - TICK_UPD_OLD_IND(); \ - and_then; \ - } else { \ - SET_INFO(p1, ind_info); \ - LDV_RECORD_CREATE(p1); \ - TICK_UPD_NEW_IND(); \ - and_then; \ - } \ - } + +#else /* !CMINUSMINUS */ + +INLINE_HEADER void updateWithIndirection (Capability *cap, + const StgInfoTable *ind_info, + StgClosure *p1, + StgClosure *p2) +{ + bdescr *bd; + + ASSERT( (P_)p1 != (P_)p2 ); + /* not necessarily true: ASSERT( !closure_IND(p1) ); */ + /* occurs in RaiseAsync.c:raiseAsync() */ + DEBUG_FILL_SLOP(p1); + LDV_RECORD_DEAD_FILL_SLOP_DYNAMIC(p1); + ((StgInd *)p1)->indirectee = p2; + write_barrier(); + bd = Bdescr((StgPtr)p1); + if (bd->gen_no != 0) { + recordMutableCap(p1, cap, bd->gen_no); + SET_INFO(p1, &stg_IND_OLDGEN_info); + TICK_UPD_OLD_IND(); + } else { + SET_INFO(p1, ind_info); + LDV_RECORD_CREATE(p1); + TICK_UPD_NEW_IND(); + } +} + #endif /* CMINUSMINUS */ + +#define UPD_IND(cap, updclosure, heapptr) \ + updateWithIndirection(cap, &stg_IND_info, \ + updclosure, \ + heapptr) + +#ifndef CMINUSMINUS +END_RTS_PRIVATE +#endif + #endif /* UPDATES_H */