X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=ghc%2Frts%2Fparallel%2FHLC.h;h=793ac840f930847f04d5160f136d63cafdac6cf5;hb=3c245de9199f522f75ace92219256badbd928bd6;hp=f2d98d4bdc23e4f56e6b4faa202fce199cb317a1;hpb=1b28d4e1f43185ad8c8e7407c66413e1b358402b;p=ghc-hetmet.git diff --git a/ghc/rts/parallel/HLC.h b/ghc/rts/parallel/HLC.h index f2d98d4..793ac84 100644 --- a/ghc/rts/parallel/HLC.h +++ b/ghc/rts/parallel/HLC.h @@ -1,6 +1,5 @@ /* -------------------------------------------------------------------------- - Time-stamp: - $Id: HLC.h,v 1.2 2000/01/13 14:34:07 hwloidl Exp $ + Time-stamp: High Level Communications Header (HLC.h) @@ -29,16 +28,17 @@ rtsBool initMoreBuffers(void); void sendFetch (globalAddr *ga, globalAddr *bqga, int load); -void sendResume(globalAddr *rga, int nelem, rtsPackBuffer *data); +void sendResume(globalAddr *rga, int nelem, rtsPackBuffer *packBuffer); void sendAck (GlobalTaskId task, int ngas, globalAddr *gagamap); void sendFish (GlobalTaskId destPE, GlobalTaskId origPE, int age, int history, int hunger); void sendFree (GlobalTaskId destPE, int nelem, P_ data); -void sendSchedule(GlobalTaskId origPE, int nelem, rtsPackBuffer *data); +void sendSchedule(GlobalTaskId origPE, int nelem, rtsPackBuffer *packBuffer); +void sendReval(GlobalTaskId origPE, int nelem, rtsPackBuffer *data); //@node Message-Processing Functions //@subsection Message-Processing Functions -void processMessages(void); +rtsBool processMessages(void); void processFetches(void); void processTheRealFetches(void); @@ -53,6 +53,10 @@ GlobalTaskId choosePE(void); StgClosure *createBlockedFetch (globalAddr ga, globalAddr rga); void waitForTermination(void); +/* Message bouncing (startup and shutdown, mainly) */ +void bounceFish(void); +void bounceReval(void); + void DebugPrintGAGAMap (globalAddr *gagamap, int nGAs); #endif /* PAR */