X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;ds=sidebyside;f=ghc%2Frts%2Fparallel%2FHLC.h;h=10d91faf1634fcddb49fa79e1a852c784aa9681d;hb=e1c4a20eb3545e0ac5c67099e487d1f26d4a655c;hp=f2d98d4bdc23e4f56e6b4faa202fce199cb317a1;hpb=1b28d4e1f43185ad8c8e7407c66413e1b358402b;p=ghc-hetmet.git diff --git a/ghc/rts/parallel/HLC.h b/ghc/rts/parallel/HLC.h index f2d98d4..10d91fa 100644 --- a/ghc/rts/parallel/HLC.h +++ b/ghc/rts/parallel/HLC.h @@ -1,6 +1,6 @@ /* -------------------------------------------------------------------------- - Time-stamp: - $Id: HLC.h,v 1.2 2000/01/13 14:34:07 hwloidl Exp $ + Time-stamp: + $Id: HLC.h,v 1.3 2001/03/22 03:51:11 hwloidl Exp $ High Level Communications Header (HLC.h) @@ -29,16 +29,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 +54,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 */