X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=ghc%2Frts%2FRtsAPI.c;h=4f7e783595700daf2c87408f6f3ea260c68935eb;hb=85b74fd854bdeb89f71d7dcee571a39960cbccdd;hp=2722bf447decf319c7236b0312256388ae4f6f6a;hpb=af13609607da81e7837a7c7c598de82452363ab5;p=ghc-hetmet.git diff --git a/ghc/rts/RtsAPI.c b/ghc/rts/RtsAPI.c index 2722bf4..4f7e783 100644 --- a/ghc/rts/RtsAPI.c +++ b/ghc/rts/RtsAPI.c @@ -1,5 +1,5 @@ /* ---------------------------------------------------------------------------- - * $Id: RtsAPI.c,v 1.39 2003/01/25 15:54:49 wolfgang Exp $ + * $Id: RtsAPI.c,v 1.44 2003/05/23 08:28:48 simonmar Exp $ * * (c) The GHC Team, 1998-2001 * @@ -170,7 +170,15 @@ rts_mkPtr (HsPtr a) return p; } -#ifdef COMPILER /* GHC has em, Hugs doesn't */ +HaskellObj +rts_mkFunPtr (HsFunPtr a) +{ + StgClosure *p = (StgClosure *)allocate(sizeofW(StgHeader)+1); + SET_HDR(p, FunPtr_con_info, CCS_SYSTEM); + p->payload[0] = (StgClosure *)a; + return p; +} + HaskellObj rts_mkBool (HsBool b) { @@ -186,7 +194,6 @@ rts_mkString (char *s) { return rts_apply((StgClosure *)unpackCString_closure, rts_mkPtr(s)); } -#endif /* COMPILER */ HaskellObj rts_apply (HaskellObj f, HaskellObj arg) @@ -348,7 +355,15 @@ rts_getPtr (HaskellObj p) return (void *)(p->payload[0]); } -#ifdef COMPILER /* GHC has em, Hugs doesn't */ +HsFunPtr +rts_getFunPtr (HaskellObj p) +{ + // See comment above: + // ASSERT(p->header.info == FunPtr_con_info || + // p->header.info == FunPtr_static_info); + return (void *)(p->payload[0]); +} + HsBool rts_getBool (HaskellObj p) { @@ -360,7 +375,6 @@ rts_getBool (HaskellObj p) barf("rts_getBool: not a Bool"); } } -#endif /* COMPILER */ /* ---------------------------------------------------------------------------- Evaluating Haskell expressions @@ -397,16 +411,16 @@ rts_evalIO (HaskellObj p, /*out*/HaskellObj *ret) } /* - * Identical to rts_evalIO(), but won't create a new task/OS thread + * Identical to rts_evalLazyIO(), but won't create a new task/OS thread * to evaluate the Haskell thread. Used by main() only. Hack. */ SchedulerStatus -rts_mainEvalIO(HaskellObj p, /*out*/HaskellObj *ret) +rts_mainLazyIO(HaskellObj p, /*out*/HaskellObj *ret) { StgTSO* tso; - tso = createStrictIOThread(RtsFlags.GcFlags.initialStkSize, p); + tso = createIOThread(RtsFlags.GcFlags.initialStkSize, p); scheduleThread(tso); return waitThread(tso, ret); } @@ -468,10 +482,10 @@ rts_checkSchedStatus ( char* site, SchedulerStatus rc ) } } -#ifdef RTS_SUPPORTS_THREADS void rts_lock() { +#ifdef RTS_SUPPORTS_THREADS Capability *cap; ACQUIRE_LOCK(&sched_mutex); @@ -490,11 +504,13 @@ rts_lock() // If there is already a task available (waiting for the work capability), // this will do nothing. startSchedulerTask(); +#endif } void rts_unlock() { +#ifdef RTS_SUPPORTS_THREADS RELEASE_LOCK(&sched_mutex); -} #endif +}