X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FSchedule.h;h=549f555a1178667f4b01add9ce5943b0eb9d49c6;hb=b2bd63f99d643f6b3eb30bb72bb9ae26d4183252;hp=1e786ce690103c6f9b06b990869902fd98860dc7;hpb=2726a2f10256710cc6ed80b1098cb32e121e1be7;p=ghc-hetmet.git diff --git a/rts/Schedule.h b/rts/Schedule.h index 1e786ce..549f555 100644 --- a/rts/Schedule.h +++ b/rts/Schedule.h @@ -14,7 +14,7 @@ #include "Capability.h" #include "Trace.h" -BEGIN_RTS_PRIVATE +#include "BeginPrivate.h" /* initScheduler(), exitScheduler() * Called from STG : no @@ -23,6 +23,7 @@ BEGIN_RTS_PRIVATE void initScheduler (void); void exitScheduler (rtsBool wait_foreign); void freeScheduler (void); +void markScheduler (evac_fn evac, void *user); // Place a new thread on the run queue of the current Capability void scheduleThread (Capability *cap, StgTSO *tso); @@ -44,7 +45,7 @@ void wakeUpRts(void); StgWord raiseExceptionHelper (StgRegTable *reg, StgTSO *tso, StgClosure *exception); /* findRetryFrameHelper */ -StgWord findRetryFrameHelper (StgTSO *tso); +StgWord findRetryFrameHelper (Capability *cap, StgTSO *tso); /* Entry point for a new worker */ void scheduleWorker (Capability *cap, Task *task); @@ -155,7 +156,9 @@ popRunQueue (Capability *cap) StgTSO *t = cap->run_queue_hd; ASSERT(t != END_TSO_QUEUE); cap->run_queue_hd = t->_link; - cap->run_queue_hd->block_info.prev = END_TSO_QUEUE; + if (t->_link != END_TSO_QUEUE) { + t->_link->block_info.prev = END_TSO_QUEUE; + } t->_link = END_TSO_QUEUE; // no write barrier req'd if (cap->run_queue_hd == END_TSO_QUEUE) { cap->run_queue_tl = END_TSO_QUEUE; @@ -212,7 +215,7 @@ emptyThreadQueues(Capability *cap) #endif /* !IN_STG_CODE */ -END_RTS_PRIVATE +#include "EndPrivate.h" #endif /* SCHEDULE_H */