|
Data Structures |
| struct | PendingSentMsgStruct |
| struct | CmiIdleState |
Typedefs |
| typedef PendingSentMsgStruct * | PendingSentMsg |
Functions |
| static void | processMessage (char *msg, int len) |
| static const char * | getErrorMsg (mx_return_t rc) |
| static void | processStatusCode (mx_status_t status) |
| static void | PumpMsgs (int getone) |
| static void | ReleaseSentMsgs (void) |
| static void | PumpEvents (int getone) |
| static CmiIdleState * | CmiNotifyGetState (void) |
| static void | CmiNotifyStillIdle (CmiIdleState *s) |
| void | CmiNotifyIdle (void) |
| static void | CmiNotifyBeginIdle (CmiIdleState *s) |
| int | CheckSocketsReady (int withDelayMs) |
| static void | ServiceCharmrun_nolock () |
| void | recv_callback (void *context, uint64_t match_info, int length) |
| static void | CommunicationServer_nolock (int withDelayMs) |
| static void | CommunicationServer (int sleepTime, int where) |
| void | processFutureMessages (OtherNode node) |
| void | EnqueueOutgoingDgram (OutgoingMsg ogm, char *ptr, int dlen, OtherNode node, int rank, int broot, int copy) |
| void | DeliverViaNetwork (OutgoingMsg ogm, OtherNode node, int rank, unsigned int broot, int copy) |
| static void | sendBarrierMessage (int pe) |
| static void | recvBarrierMessage () |
| int | CmiBarrier () |
| int | CmiBarrierZero () |
| void | CmiMachineInit (char **argv) |
| void | CmiCommunicationInit (char **argv) |
| void | CmiMachineExit () |
| void | CmiMXMakeConnection () |
Variables |
| static PendingSentMsg | pmpool [MAXPMS] |
| static int | pmNums = 0 |
| static PendingSentMsg | sent_handles = NULL |
| static PendingSentMsg | sent_handles_end = NULL |
| CmiUInt8 | MATCH_FILTER = 0x11111111FFFFFFFFL |
| CmiUInt8 | MATCH_MASK = 0xffffffffffffffffL |
| static int | maxsize |
ChangeLog: 2/3/2006: Gengbin Zheng implemented packetization, and fix a bug related to buffer reuse/change in pending send 2/7/2006: Gengbin Zheng implement active message mode using callback short message pingpong time improved by 0.5us 2/8/2006: Gengbin Zheng implement buffering of future messages (I haven't seen out-of-order messages so far, but it may happen) Using POOL relies on charmrun set MX_MONOTHREAD=1.