X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=ghc%2Fincludes%2FSchedAPI.h;h=524b1da9f58f47b561b17837bb06ab740fee5ec9;hb=18340925716fb6e68672c69bd263ad9041f81822;hp=18c48f5f9cf6c5c8155593d12cdacbfcf00947a1;hpb=1b28d4e1f43185ad8c8e7407c66413e1b358402b;p=ghc-hetmet.git diff --git a/ghc/includes/SchedAPI.h b/ghc/includes/SchedAPI.h index 18c48f5..524b1da 100644 --- a/ghc/includes/SchedAPI.h +++ b/ghc/includes/SchedAPI.h @@ -1,7 +1,7 @@ /* ----------------------------------------------------------------------------- - * $Id: SchedAPI.h,v 1.9 2000/01/13 14:34:01 hwloidl Exp $ + * $Id: SchedAPI.h,v 1.17 2002/12/27 12:33:21 panne Exp $ * - * (c) The GHC Team 1998 + * (c) The GHC Team 1998-2002 * * External API for the scheduler. For most uses, the functions in * RtsAPI.h should be enough. @@ -16,33 +16,27 @@ #define NO_PRI 0 #endif -/* - * schedule() plus the thread creation functions are not part - * part of the external RTS API, so leave them out if we're - * not compiling rts/ bits. -- sof 7/99 - * - */ -SchedulerStatus waitThread(StgTSO *main_thread, /*out*/StgClosure **ret); +extern SchedulerStatus waitThread(StgTSO *main_thread, /*out*/StgClosure **ret); /* * Creating threads */ #if defined(GRAN) -StgTSO *createThread(nat stack_size, StgInt pri); +extern StgTSO *createThread(nat stack_size, StgInt pri); #else -StgTSO *createThread(nat stack_size); +extern StgTSO *createThread(nat stack_size); #endif -void scheduleThread(StgTSO *tso); +#if defined(PAR) || defined(SMP) +extern void taskStart(void); +#endif +extern void scheduleThread(StgTSO *tso); +extern SchedulerStatus scheduleWaitThread(StgTSO *tso, /*out*/HaskellObj* ret); -static inline void pushClosure (StgTSO *tso, StgClosure *c) { +static inline void pushClosure (StgTSO *tso, StgWord c) { tso->sp--; tso->sp[0] = (W_) c; } -static inline void pushRealWorld (StgTSO *tso) { - tso->sp--; - tso->sp[0] = (W_) REALWORLD_TAG; -} static inline StgTSO * createGenThread(nat stack_size, StgClosure *closure) { StgTSO *t; @@ -51,7 +45,8 @@ createGenThread(nat stack_size, StgClosure *closure) { #else t = createThread(stack_size); #endif - pushClosure(t,closure); + pushClosure(t, (W_)closure); + pushClosure(t, (W_)&stg_enter_info); return t; } @@ -63,8 +58,10 @@ createIOThread(nat stack_size, StgClosure *closure) { #else t = createThread(stack_size); #endif - pushRealWorld(t); - pushClosure(t,closure); + pushClosure(t, (W_)&stg_noforceIO_info); + pushClosure(t, (W_)&stg_ap_v_info); + pushClosure(t, (W_)closure); + pushClosure(t, (W_)&stg_enter_info); return t; } @@ -81,8 +78,10 @@ createStrictIOThread(nat stack_size, StgClosure *closure) { #else t = createThread(stack_size); #endif - pushClosure(t,closure); - pushClosure(t,(StgClosure*)&forceIO_closure); + pushClosure(t, (W_)&stg_forceIO_info); + pushClosure(t, (W_)&stg_ap_v_info); + pushClosure(t, (W_)closure); + pushClosure(t, (W_)&stg_enter_info); return t; } @@ -90,14 +89,12 @@ createStrictIOThread(nat stack_size, StgClosure *closure) { /* * Killing threads */ - -void deleteThread(StgTSO *tso); -void deleteAllThreads ( void ); - +extern void deleteThread(StgTSO *tso); +extern void deleteAllThreads ( void ); +extern int howManyThreadsAvail ( void ); /* - * Reverting CAFs + * Run until there are no more threads. */ - -void RevertCAFs(void); +extern void finishAllThreads ( void ); #endif