enum entities |
enum entities |
void calculateNodeSizeAndRank | ( | char ** | ) |
Referenced by CmiInitPxshm(), CmiInitXpmem(), CmiSendMessagePxshm(), and CmiSendMessageXpmem().
void setupSharedBuffers | ( | void | ) |
Referenced by CmiInitPxshm(), CmiInitXpmem(), CmiSendMessagePxshm(), and CmiSendMessageXpmem().
void initAllSendQs | ( | void | ) |
Referenced by CmiInitPxshm(), CmiInitXpmem(), CmiSendMessagePxshm(), and CmiSendMessageXpmem().
void CmiExitPxshm | ( | void | ) |
Definition at line 286 of file machine-pxshm.C.
References _Cmi_mynode, CmiPrintf(), PxshmContext::commServerTime, free(), PxshmContext::lockRecvCount, PxshmContext::noderank, PxshmContext::nodesize, pxshm_freed, PxshmContext::recvBufNames, PxshmContext::recvBufs, PxshmContext::sendBufNames, PxshmContext::sendBufs, PxshmContext::sendCount, PxshmContext::sendTime, tearDownSharedBuffers(), PxshmContext::validCheckCount, and PxshmContext::validCheckTime.
Referenced by cleanupOnAllSigs(), CmiAbortHelper(), and ConverseExit().
static void cleanupOnAllSigs | ( | int | signo | ) | [static] |
Definition at line 177 of file machine-pxshm.C.
References CmiExitPxshm().
Referenced by CmiInitPxshm(), and CmiInitXpmem().
void CmiInitPxshm | ( | char ** | argv | ) |
Definition at line 183 of file machine-pxshm.C.
References _Cmi_mynode, calculateNodeSizeAndRank(), calloc(), cleanupOnAllSigs(), CmiAbort(), CmiDeprecateArgInt(), CmiReadSize(), PxshmContext::commServerTime, initAllSendQs(), PxshmContext::lockRecvCount, name, PxshmContext::nodesize, PxshmContext::prefixStr, PxshmContext::sendCount, SENDQSTARTSIZE, PxshmContext::sendTime, setupSharedBuffers(), SHMBUFLEN, SHMMAXSIZE, snprintf(), PxshmContext::validCheckCount, and PxshmContext::validCheckTime.
Referenced by _initCharm(), and ConverseInit().
void tearDownSharedBuffers | ( | void | ) |
Referenced by CmiExitPxshm(), CmiSendMessagePxshm(), and CmiSendMessageXpmem().
void freeSharedBuffers | ( | void | ) |
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
Definition at line 325 of file machine-pxshm.C.
References PxshmContext::nodestart, SHMMAXSIZE, and PxshmContext::validCheckCount.
Referenced by CmiInterSendNetworkFunc().
Definition at line 343 of file machine-pxshm.C.
References PxshmContext::nodestart.
Referenced by CmiSendMessagePxshm().
void pushSendQ | ( | PxshmSendQ * | q, | |
char * | msg, | |||
int | size, | |||
int * | refcount | |||
) | [inline] |
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
int sendMessage | ( | char * | msg, | |
int | size, | |||
int * | refcount, | |||
sharedBufData * | dstBuf, | |||
PxshmSendQ * | dstSendQ | |||
) | [inline] |
Referenced by CmiSendMessagePxshm(), CmiSendMessageXpmem(), and sendMessageRec().
int flushSendQ | ( | PxshmSendQ * | q | ) |
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
int sendMessageRec | ( | OutgoingMsgRec * | omg, | |
sharedBufData * | dstBuf, | |||
PxshmSendQ * | dstSendQ | |||
) |
Definition at line 350 of file machine-pxshm.C.
References OutgoingMsgRec::data, OutgoingMsgRec::refcount, sendMessage(), and OutgoingMsgRec::size.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
failed to get the lock insert into q and retain the message
copy this message to sharedBuf
Definition at line 364 of file machine-pxshm.C.
References _Cmi_mynode, _Cmi_myphysnode_numprocesses, _Cmi_numnodes, argv, PxshmSendQ::begin, sharedBufHeader::bytes, calculateNodeSizeAndRank(), calloc(), Ck::IO::close(), CmiAlloc(), CmiFree(), CmiMemoryCheck(), CmiNotifyStillIdle(), CmiNumPesOnPhysicalNode(), CmiPhysicalNodeID(), CmiPrintf(), CmiWallTimer(), PxshmContext::commServerTime, CommunicationServerPxshm(), count, sharedBufHeader::count, OutgoingMsgRec::data, PxshmSendQ::data, sharedBufData::data, PxshmSendQ::end, fd, sharedBufHeader::flagReceiver, sharedBufHeader::flagSender, flushSendQ(), free(), freeSharedBuffers(), ftruncate(), handleOneRecvedMsg(), sharedBufData::header, initAllSendQs(), sharedBufHeader::lock, PxshmContext::lockRecvCount, LrtsBarrier(), LrtsPrepareEnvelope(), malloc(), sharedBufData::mutex, name, PxshmSendQ::next, PxshmContext::nodeend, PxshmContext::noderank, PxshmContext::nodesize, PxshmContext::nodestart, PxshmSendQ::numEntries, PxshmContext::prefixStr, pushSendQ(), PxshmRank(), PxshmSendQ::rank, rank, RECEIVER, PxshmContext::recvBufNames, PxshmContext::recvBufs, OutgoingMsgRec::refcount, PUP::s, PxshmContext::sendBufNames, PxshmContext::sendBufs, PxshmContext::sendCount, SENDER, sendMessage(), sendMessageRec(), sendQ_head_index, PxshmContext::sendQs, SENDQSTARTSIZE, PxshmContext::sendTime, setupSharedBuffers(), SHMBUFLEN, PxshmSendQ::size, OutgoingMsgRec::size, snprintf(), tearDownSharedBuffers(), and sharedBufHeader::turn.
Referenced by CmiInterSendNetworkFunc().
void CmiExitXpmem | ( | void | ) |
Definition at line 273 of file machine-xpmem.C.
References _Cmi_mynode, CmiPrintf(), XpmemContext::commServerTime, free(), XpmemContext::lockRecvCount, XpmemContext::noderank, XpmemContext::nodesize, XpmemContext::recvBufNames, XpmemContext::recvBufs, XpmemContext::sendBufNames, XpmemContext::sendBufs, XpmemContext::sendCount, XpmemContext::sendTime, XpmemContext::validCheckCount, and XpmemContext::validCheckTime.
Referenced by CmiAbortHelper(), CommunicationServer(), and ConverseExit().
void CmiInitXpmem | ( | char ** | argv | ) |
Definition at line 198 of file machine-xpmem.C.
References _Cmi_mynode, calculateNodeSizeAndRank(), calloc(), cleanupOnAllSigs(), CmiAbort(), CmiPrintf(), CmiReadSize(), initAllSendQs(), XpmemContext::nodesize, Ck::IO::open(), XpmemContext::prefixStr, SENDQSTARTSIZE, setupSharedBuffers(), snprintf(), xpmem_fd, and XPMEMBUFLEN.
Referenced by ConverseInit().
Definition at line 309 of file machine-xpmem.C.
References XpmemContext::nodestart, and XpmemContext::validCheckCount.
Referenced by CmiInterSendNetworkFunc().
Definition at line 319 of file machine-xpmem.C.
References XpmemContext::nodestart.
Referenced by CmiSendMessageXpmem().
void pushSendQ | ( | XpmemSendQ * | q, | |
char * | msg, | |||
int | size, | |||
int * | refcount | |||
) | [inline] |
int sendMessage | ( | char * | msg, | |
int | size, | |||
int * | refcount, | |||
sharedBufData * | dstBuf, | |||
XpmemSendQ * | dstSendQ | |||
) | [inline] |
int flushSendQ | ( | XpmemSendQ * | sendQ | ) | [inline] |
int sendMessageRec | ( | OutgoingMsgRec * | omg, | |
sharedBufData * | dstBuf, | |||
XpmemSendQ * | dstSendQ | |||
) | [inline] |
Definition at line 327 of file machine-xpmem.C.
References OutgoingMsgRec::data, OutgoingMsgRec::refcount, sendMessage(), and OutgoingMsgRec::size.
failed to get the lock insert into q and retain the message
copy this message to sharedBuf
Definition at line 339 of file machine-xpmem.C.
References _Cmi_mynode, _Cmi_numnodes, argv, XpmemSendQ::begin, sharedBufHeader::bytes, calculateNodeSizeAndRank(), calloc(), Ck::IO::close(), CmiAbort(), CmiAlloc(), CmiBarrier(), CmiFree(), CmiGetArgIntDesc(), CmiMemcpy(), CmiMemoryCheck(), CmiNotifyStillIdle(), CmiPrintf(), CmiPushPE(), CmiWallTimer(), XpmemContext::commServerTime, count, sharedBufHeader::count, OutgoingMsgRec::data, XpmemSendQ::data, sharedBufData::data, XpmemSendQ::end, fd, sharedBufHeader::flagReceiver, sharedBufHeader::flagSender, flushSendQ(), xi::fname, free(), freeSharedBuffers(), getpagesize(), handleOneRecvedMsg(), sharedBufData::header, initAllSendQs(), sharedBufHeader::lock, XpmemContext::lockRecvCount, LrtsPrepareEnvelope(), malloc(), sharedBufData::mutex, XpmemSendQ::next, XpmemContext::nodeend, XpmemContext::noderank, XpmemContext::nodesize, XpmemContext::nodestart, XpmemSendQ::numEntries, Ck::IO::open(), XpmemContext::prefixStr, pushSendQ(), XpmemSendQ::rank, rank, RECEIVER, XpmemContext::recvBufNames, XpmemContext::recvBufs, OutgoingMsgRec::refcount, PUP::s, XpmemContext::sendBufNames, XpmemContext::sendBufs, XpmemContext::sendCount, SENDER, sendMessage(), sendMessageRec(), sendQ_head_index, XpmemContext::sendQs, SENDQSTARTSIZE, SendSpanningChildren(), XpmemContext::sendTime, setupSharedBuffers(), XpmemSendQ::size, OutgoingMsgRec::size, snprintf(), tearDownSharedBuffers(), sharedBufHeader::turn, Ck::IO::write(), xpmem_fd, XPMEMBUFLEN, and XpmemRank().
Referenced by CmiInterSendNetworkFunc().
Definition at line 89 of file machine-pxshm.C.
Referenced by CmiInitPxshm(), and CmiSendMessagePxshm().
int SHMMAXSIZE = (1024 * 1024) [static] |
int SENDQSTARTSIZE = 256 [static] |
Definition at line 92 of file machine-pxshm.C.
Referenced by CmiInitPxshm(), CmiInitXpmem(), CmiSendMessagePxshm(), and CmiSendMessageXpmem().
int sharedBufHeader::bytes [inherited] |
Definition at line 98 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
OSSpinLock sharedBufHeader::lock [inherited] |
Definition at line 101 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
volatile int sharedBufHeader::flagSender [inherited] |
Definition at line 105 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
char sharedBufHeader::pad1 [inherited] |
Definition at line 106 of file machine-pxshm.C.
volatile int sharedBufHeader::flagReceiver [inherited] |
Definition at line 107 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
char sharedBufHeader::pad2 [inherited] |
Definition at line 108 of file machine-pxshm.C.
volatile int sharedBufHeader::turn [inherited] |
Definition at line 109 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
sharedBufHeader* sharedBufData::header [inherited] |
Definition at line 118 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
char* sharedBufData::data [inherited] |
Definition at line 119 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
int* OutgoingMsgRec::refcount [inherited] |
Definition at line 124 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), CmiSendMessageXpmem(), and sendMessageRec().
int OutgoingMsgRec::size [inherited] |
Definition at line 125 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), CmiSendMessageXpmem(), and sendMessageRec().
int PxshmSendQ::begin [inherited] |
int PxshmSendQ::end [inherited] |
int PxshmSendQ::numEntries [inherited] |
int PxshmSendQ::rank [inherited] |
int PxshmSendQ::next [inherited] |
OutgoingMsgRec* PxshmSendQ::data [inherited] |
int PxshmContext::noderank [inherited] |
Definition at line 143 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), and CmiSendMessagePxshm().
int PxshmContext::nodestart [inherited] |
Definition at line 144 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), CmiValidPxshm(), and PxshmRank().
int PxshmContext::nodeend [inherited] |
char PxshmContext::prefixStr[PREFIXSTRLEN] [inherited] |
Definition at line 145 of file machine-pxshm.C.
Referenced by CmiInitPxshm(), and CmiSendMessagePxshm().
char** PxshmContext::recvBufNames [inherited] |
Definition at line 146 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), and CmiSendMessagePxshm().
char** PxshmContext::sendBufNames [inherited] |
Definition at line 147 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), and CmiSendMessagePxshm().
sharedBufData* PxshmContext::recvBufs [inherited] |
Definition at line 149 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), and CmiSendMessagePxshm().
sharedBufData* PxshmContext::sendBufs [inherited] |
Definition at line 150 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), and CmiSendMessagePxshm().
PxshmSendQ** PxshmContext::sendQs [inherited] |
int PxshmContext::sendCount [inherited] |
Definition at line 155 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), CmiInitPxshm(), and CmiSendMessagePxshm().
int PxshmContext::validCheckCount [inherited] |
Definition at line 156 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), CmiInitPxshm(), and CmiValidPxshm().
int PxshmContext::lockRecvCount [inherited] |
Definition at line 157 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), CmiInitPxshm(), and CmiSendMessagePxshm().
double PxshmContext::validCheckTime [inherited] |
double PxshmContext::sendTime [inherited] |
Definition at line 159 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), CmiInitPxshm(), and CmiSendMessagePxshm().
double PxshmContext::commServerTime [inherited] |
Definition at line 160 of file machine-pxshm.C.
Referenced by CmiExitPxshm(), CmiInitPxshm(), and CmiSendMessagePxshm().
int sendQ_head_index = -1 [static] |
Definition at line 166 of file machine-pxshm.C.
Referenced by CmiSendMessagePxshm(), and CmiSendMessageXpmem().
PxshmContext* pxshmContext = NULL |
Definition at line 169 of file machine-pxshm.C.
int pxshm_freed = 0 [static] |
int XPMEMBUFLEN = (1024*1024*4) [static] |
Definition at line 92 of file machine-xpmem.C.
Referenced by CmiInitXpmem(), and CmiSendMessageXpmem().
int SENDQSTARTSIZE = 256 [static] |
Definition at line 96 of file machine-xpmem.C.
sharedBufHeader* sharedBufData::header [inherited] |
Definition at line 123 of file machine-xpmem.C.
char* sharedBufData::data [inherited] |
Definition at line 124 of file machine-xpmem.C.
__s64 sharedBufData::segid [inherited] |
Definition at line 125 of file machine-xpmem.C.
int* OutgoingMsgRec::refcount [inherited] |
Definition at line 131 of file machine-xpmem.C.
int XpmemSendQ::begin [inherited] |
int XpmemSendQ::end [inherited] |
int XpmemSendQ::numEntries [inherited] |
int XpmemSendQ::rank [inherited] |
int XpmemSendQ::next [inherited] |
OutgoingMsgRec* XpmemSendQ::data [inherited] |
int XpmemContext::noderank [inherited] |
Definition at line 151 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
int XpmemContext::nodestart [inherited] |
Definition at line 152 of file machine-xpmem.C.
Referenced by CmiSendMessageXpmem(), CmiValidXpmem(), and XpmemRank().
int XpmemContext::nodeend [inherited] |
char XpmemContext::prefixStr[PREFIXSTRLEN] [inherited] |
Definition at line 153 of file machine-xpmem.C.
Referenced by CmiInitXpmem(), and CmiSendMessageXpmem().
char** XpmemContext::recvBufNames [inherited] |
Definition at line 154 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
char** XpmemContext::sendBufNames [inherited] |
Definition at line 155 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
sharedBufData* XpmemContext::recvBufs [inherited] |
Definition at line 157 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
sharedBufData* XpmemContext::sendBufs [inherited] |
Definition at line 158 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
XpmemSendQ** XpmemContext::sendQs [inherited] |
int XpmemContext::sendCount [inherited] |
Definition at line 163 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
int XpmemContext::validCheckCount [inherited] |
int XpmemContext::lockRecvCount [inherited] |
Definition at line 165 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
double XpmemContext::validCheckTime [inherited] |
double XpmemContext::sendTime [inherited] |
Definition at line 167 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
double XpmemContext::commServerTime [inherited] |
Definition at line 168 of file machine-xpmem.C.
Referenced by CmiExitXpmem(), and CmiSendMessageXpmem().
int sendQ_head_index = -1 [static] |
Definition at line 175 of file machine-xpmem.C.
XpmemContext* xpmemContext = NULL |
Definition at line 178 of file machine-xpmem.C.
Definition at line 192 of file machine-xpmem.C.
Referenced by CmiInitXpmem(), and CmiSendMessageXpmem().
int pxshm_freed = 0 [static] |
Definition at line 269 of file machine-xpmem.C.