Data Structures | |
| struct | CkChareID |
| struct | _ckGroupID |
Typedefs | |
| typedef struct _ckGroupID | CkGroupID |
| typedef CkGroupID | CkNodeGroupID |
| typedef struct envelope | envelope |
Enumerations | |
| enum | CkEnvelopeType { NewChareMsg = 1, NewVChareMsg = 2, BocInitMsg = 3, ForChareMsg = 4, ForBocMsg = 5, ForVidMsg = 6, FillVidMsg = 7, RODataMsg = 8, ROMsgMsg = 9, ExitMsg = 10, ReqStatMsg = 11, StatMsg = 12, NodeBocInitMsg = 13, ForNodeBocMsg = 14, ArrayEltInitMsg = 15, ForArrayEltMsg = 16 } |
Functions | |
| void | CkCreateChare (int chareIdx, int constructorIdx, void *msg, CkChareID *vid, int destPE) |
| CkGroupID | CkCreateGroup (int chareIdx, int constructorIdx, void *msg) |
| CkGroupID | CkCreateNodeGroup (int chareIdx, int constructorIdx, void *msg) |
| void | CkCreateLocalGroup (CkGroupID groupID, int constructorIdx, envelope *env) |
| void | CkCreateLocalNodeGroup (CkGroupID groupID, int constructorIdx, envelope *env) |
| void | CkSendMsg (int entryIndex, void *msg, const CkChareID *chare, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgBranch (int eIdx, void *msg, int destPE, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgInline (int entryIndex, void *msg, const CkChareID *chare, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgBranchInline (int eIdx, void *msg, int destPE, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *pes, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgNodeBranch (int eIdx, void *msg, int destNode, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgNodeBranchInline (int eIdx, void *msg, int destNode, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| void | CkSendMsgNodeBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *nodes, int opts CK_MSGOPTIONAL) |
| void | CkBroadcastMsgBranch (int eIdx, void *msg, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| void | CkBroadcastMsgNodeBranch (int eIdx, void *msg, CkGroupID gID, int opts CK_MSGOPTIONAL) |
| int | CkChareMsgPrep (int eIdx, void *msg, const CkChareID *pCid) |
| void | CkGroupMsgPrep (int eIdx, void *msg, CkGroupID gID) |
| void | CkNodeGroupMsgPrep (int eIdx, void *msg, CkGroupID gID) |
| void | CkSetRefNum (void *msg, int ref) |
| int | CkGetRefNum (void *msg) |
| int | CkGetSrcPe (void *msg) |
| int | CkGetSrcNode (void *msg) |
| void | CkDeliverMessageFree (int epIdx, void *msg, void *object) |
| void | CkDeliverMessageReadonly (int epIdx, const void *msg, void *object) |
| void * | CkLocalBranch (CkGroupID gID) |
| void * | CkLocalNodeBranch (CkGroupID gID) |
| void * | CkLocalChare (const CkChareID *chare) |
| void | CkArrayManagerInsert (int onPe, void *msg, CkGroupID aID) |
| void | CkArrayManagerDeliver (int onPe, void *msg, int opts CK_MSGOPTIONAL) |
These routines implement a basic remote-method-invocation system consisting of chares and groups.
These routines are implemented in ck.C.
There is no migration. All the bindings are written to the C language, although most clients, including the rest of Charm++, are actually C++.
| typedef struct _ckGroupID CkGroupID |
| typedef CkGroupID CkNodeGroupID |
| enum CkEnvelopeType |
Definition at line 540 of file ck.C.
References _charmHandlerIdx, _entryTable, _infoIdx, Converse::CkMyPe(), CldEnqueue(), idx, NewChareMsg, NewVChareMsg, CkChareID::objPtr, CkChareID::onPE, envelope::setEpIdx(), envelope::setForAnyPE(), envelope::setMsgtype(), envelope::setSrcPe(), envelope::setVidPtr(), and UsrToEnv().
Referenced by CProxy_waitqd_QDChare::ckNew(), CProxy_TraceUtilizationInit::ckNew(), CProxy_TraceTauInit::ckNew(), CProxy_TraceSummaryInit::ckNew(), CProxy_TraceSimpleInit::ckNew(), CProxy_TraceProjectionsInit::ckNew(), CProxy_TraceControlPointsInit::ckNew(), CProxy_TempoChare::ckNew(), CProxy_pathHistoryMain::ckNew(), CProxy_PythonCCS::ckNew(), CProxy_CpdPython::ckNew(), CProxy_LBDBInit::ckNew(), CProxy_controlPointMain::ckNew(), CProxy_ComlibManagerMain::ckNew(), CProxy_CkMemCheckPTInit::ckNew(), CProxy_CkMapsInit::ckNew(), CProxy_FutureMain::ckNew(), CProxy_CkCheckpointInit::ckNew(), CProxy_ckcallback_main::ckNew(), CProxy_Main::ckNew(), CProxy_ckcallback_main::CProxy_ckcallback_main(), CProxy_CkCheckpointInit::CProxy_CkCheckpointInit(), CProxy_CkMapsInit::CProxy_CkMapsInit(), CProxy_CkMemCheckPTInit::CProxy_CkMemCheckPTInit(), CProxy_ComlibManagerMain::CProxy_ComlibManagerMain(), CProxy_controlPointMain::CProxy_controlPointMain(), CProxy_CpdPython::CProxy_CpdPython(), CProxy_FutureMain::CProxy_FutureMain(), CProxy_LBDBInit::CProxy_LBDBInit(), CProxy_Main::CProxy_Main(), CProxy_pathHistoryMain::CProxy_pathHistoryMain(), CProxy_PythonCCS::CProxy_PythonCCS(), CProxy_TraceControlPointsInit::CProxy_TraceControlPointsInit(), CProxy_TraceProjectionsInit::CProxy_TraceProjectionsInit(), CProxy_TraceSimpleInit::CProxy_TraceSimpleInit(), CProxy_TraceSummaryInit::CProxy_TraceSummaryInit(), CProxy_TraceTauInit::CProxy_TraceTauInit(), CProxy_TraceUtilizationInit::CProxy_TraceUtilizationInit(), and CProxy_waitqd_QDChare::CProxy_waitqd_QDChare().
Definition at line 746 of file ck.C.
References _entryTable, _groupCreate(), BocInitMsg, Converse::CkMyPe(), Converse::CkNumPes(), envelope::setEpIdx(), envelope::setMsgtype(), envelope::setSrcPe(), and UsrToEnv().
Definition at line 760 of file ck.C.
References _entryTable, _nodeGroupCreate(), Converse::CkMyPe(), BGConverse::CkNumNodes(), NodeBocInitMsg, envelope::setEpIdx(), envelope::setMsgtype(), envelope::setSrcPe(), and UsrToEnv().
Definition at line 576 of file ck.C.
Referenced by _createGroup(), _processBocInitMsg(), and CkPupGroupData().
Definition at line 605 of file ck.C.
Referenced by _createNodeGroup(), _processNodeBocInitMsg(), and CkPupNodeGroupData().
Definition at line 1385 of file ck.C.
References _infoIdx, _noCldEnqueue(), _prepareMsg(), CkSendMsgInline(), CldEnqueue(), CmiAbort(), and UsrToEnv().
Referenced by CkDelegateMgr::ChareSend(), CkRemoteCallAsync(), CkSendMsgInline(), CProxy_Main::Finish(), CProxy_PythonCCS::forwardInt(), CProxy_PythonCCS::forwardString(), CProxy_waitqd_QDChare::onQD(), CkCallback::send(), and CProxy_TempoChare::tempoGeneric().
Definition at line 1541 of file ck.C.
References _sendMsgBranch(), CkSendMsgBranchImmediate(), and CkSendMsgBranchInline().
Referenced by CProxyElement_CkReductionMgr::ArrayReductionHandler(), CProxyElement_TraceSummaryBOC::askSummary(), CProxyElement_ComlibManager::bracketedConfirmCount(), CProxyElement_ComlibManager::bracketedContributeDiscovery(), CProxyElement_ComlibManager::bracketedCountConfirmed(), CProxyElement_ComlibManager::bracketedDiscover(), CProxyElement_ComlibManager::bracketedErrorDetected(), CProxyElement_ComlibManager::bracketedReceiveCount(), CProxyElement_ComlibManager::bracketedReceiveNewCount(), CProxyElement_ComlibManager::bracketedReceiveNewPeList(), CProxyElement_ComlibManager::bracketedReleaseBufferedMessages(), CProxyElement_ComlibManager::bracketedReleaseCount(), CProxyElement_ComlibManager::bracketedStartErrorRecoveryProcess(), CProxyElement_pathHistoryManager::broadcastCriticalPathProjections(), CProxyElement_TraceProjectionsBOC::calculateWeights(), CProxyElement_ckcallback_group::call(), CProxyElement_TraceSummaryBOC::ccsRequestSummaryDouble(), CProxyElement_TraceSummaryBOC::ccsRequestSummaryUnsignedChar(), CkRemoteBranchCallAsync(), CkSendMsgBranchInline(), CProxyElement_TraceProjectionsBOC::closeTrace(), CProxyElement_HybridBaseLB::CollectInfo(), CProxyElement_CkCacheManager::collectStatistics(), CProxyElement_ComlibManager::collectStats(), CProxyElement_TraceUtilizationBOC::collectSumDetailData(), CProxyElement_TraceSummaryBOC::collectSummaryData(), CProxyElement_CkReductionMgr::contributeViaMessage(), CProxyElement_CkMemCheckPT::cpFinish(), CProxyElement_pathHistoryManager::criticalPathProjectionsDone(), CProxyElement_TraceProjectionsBOC::determineOutliers(), CProxyElement_CkMemCheckPT::doItNow(), CProxyElement_CkLocMgr::dummyAtSync(), CProxyElement_TraceProjectionsBOC::endTimeReduction(), CProxyElement_TraceProjectionsBOC::finalReduction(), CProxyElement_CkCacheManager::finishedChunk(), CProxyElement_CkMemCheckPT::finishUp(), CProxyElement_CkMulticastMgr::freeup(), CProxyElement_controlPointManager::gatherIdleTime(), CProxyElement_controlPointManager::gatherMemoryUsage(), CProxyElement_CpdPythonGroup::getCast(), CProxyElement_CpdPythonGroup::getMessage(), CProxyElement_CpdPythonGroup::getStatic(), CProxyElement_CpdPythonGroup::getValue(), CkDelegateMgr::GroupSend(), ComlibManager::GroupSend(), BroadcastStrategy::handleHypercube(), BroadcastStrategy::handleTree(), CProxyElement_CkLocMgr::immigrate(), CProxyElement_TraceSummaryBOC::initCCS(), CProxyElement_CkMemCheckPT::inmem_restore(), CProxyElement_CkReductionMgr::LateMigrantMsg(), CProxyElement_CentralLB::LoadBalance(), CProxyElement_HybridBaseLB::Loadbalancing(), CProxyElement_HbmLB::Loadbalancing(), CProxyElement_CkReductionMgr::MigrantDied(), CProxyElement_CentralLB::MissMigrate(), CProxyElement_HybridBaseLB::NotifyObjectMigrationDone(), CProxyElement_HbmLB::NotifyObjectMigrationDone(), CProxyElement_HybridBaseLB::ObjMigrated(), CProxyElement_HbmLB::ObjMigrated(), CProxyElement_TraceProjectionsBOC::outlierAverageReduction(), CProxyElement_HybridBaseLB::PropagateInfo(), CProxyElement_CpdPythonGroup::pyRequest(), CProxyElement_CkMemCheckPT::quiescence(), CProxyElement_CentralLB::ReceiveCounts(), CProxyElement_WSLB::ReceiveMigration(), CProxyElement_NborBaseLB::ReceiveMigration(), CProxyElement_HybridBaseLB::ReceiveMigration(), CProxyElement_CentralLB::ReceiveMigration(), CProxyElement_HbmLB::ReceiveMigrationCount(), CProxyElement_HbmLB::ReceiveMigrationDelta(), CProxyElement_HbmLB::ReceiveResumeClients(), CProxyElement_HybridBaseLB::ReceiveStats(), CProxyElement_HbmLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStatsViaTree(), CProxyElement_HybridBaseLB::ReceiveVectorMigration(), CProxyElement_CkLocMgr::reclaimRemote(), CProxyElement_CkMemCheckPT::recoverArrayElements(), CProxyElement_CkMemCheckPT::recoverBuddies(), CProxyElement_CkArray::recvBroadcast(), CProxyElement_CkMulticastMgr::recvCookie(), CProxyElement_CkMulticastMgr::recvCookieInfo(), CProxyElement_CkCacheManager::recvData(), CProxyElement_CkMemCheckPT::recvData(), CProxyElement_CkArray::recvExpeditedBroadcast(), CProxyElement_CkMulticastMgr::recvMsg(), CProxyElement_CkMulticastMgr::recvPacket(), CProxyElement_CkMemCheckPT::recvProcData(), CProxyElement_CkMulticastMgr::recvRedMsg(), CProxyElement_CkReductionMgr::ReductionStarting(), CProxyElement_CpdPythonGroup::registerPersistent(), CProxyElement_CkArray::remoteDoneInserting(), CProxyElement_CkMemCheckPT::removeArrayElements(), CProxyElement_CkMemCheckPT::report(), CProxyElement_HybridBaseLB::reportLBMem(), CProxyElement_HybridBaseLB::reportLBQulity(), CProxyElement_HbmLB::reportLBQulity(), CProxyElement_controlPointManager::requestIdleTime(), CProxyElement_CkMemCheckPT::resetReductionMgr(), CProxyElement_CkMemCheckPT::restart(), CProxyElement_WSLB::ResumeClients(), CProxyElement_NborBaseLB::ResumeClients(), CProxyElement_HybridBaseLB::ResumeClients(), CProxyElement_HbmLB::ResumeClients(), CProxyElement_CentralLB::ResumeClients(), CProxyElement_ComlibManager::resumeFromSetupBarrier(), CProxyElement_CkMulticastMgr::retire(), CProxyElement_CkMulticastMgr::retrieveCookie(), CProxyElement_pathHistoryManager::saveCriticalPathForPriorities(), CkCallback::send(), CProxyElement_CkArray::sendBroadcast(), CProxyElement_CkArray::sendExpeditedBroadcast(), CProxyElement_CkCheckpointMgr::SendRestartCB(), CProxyElement_CentralLB::SendStats(), CProxyElement_TraceSummaryBOC::sendSummaryBOC(), CProxyElement_TraceProjectionsBOC::setOutliers(), CProxyElement_FutureBOC::SetSema(), CProxyElement_TraceProjectionsBOC::shutdownAnalysis(), CProxyElement_HybridBaseLB::StartCollectInfo(), CProxyElement_TraceProjectionsBOC::startEndTimeAnalysis(), CProxyElement_TraceUtilizationBOC::sumDetailDataCollected(), CProxyElement_TraceSummaryBOC::summaryDataCollected(), CProxyElement_CkMemCheckPT::syncFiles(), CProxyElement_CkMulticastMgr::teardown(), CProxyElement_HybridBaseLB::TotalObjMigrated(), CProxyElement_CkLocMgr::updateLocation(), CProxyElement_CkMulticastMgr::updateRedNo(), and CProxyElement_CkCacheManager::writebackChunk().
| void CkSendMsgInline | ( | int | entryIndex, | |
| void * | msg, | |||
| const CkChareID * | chare, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1410 of file ck.C.
References _invokeEntryNoTrace(), _prepareMsg(), Converse::CkMyPe(), CkSendMsg(), CkUnpackMessage(), envelope::isPacked(), CkChareID::objPtr, CkChareID::onPE, and UsrToEnv().
Referenced by CkSendMsg(), and CkCallback::send().
| void CkSendMsgBranchInline | ( | int | eIdx, | |
| void * | msg, | |||
| int | destPE, | |||
| CkGroupID | gID, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1517 of file ck.C.
References _deliverForBocMsg(), _localBranch(), _prepareMsgBranch(), Converse::CkMyPe(), CkSendMsgBranch(), ForBocMsg, and UsrToEnv().
Referenced by CkSendMsgBranch(), CkSendMsgBranchImmediate(), PipeBroadcastStrategy::deliver(), EachToManyMulticastStrategy::deliver(), and CkCallback::send().
| void CkSendMsgBranchMulti | ( | int | eIdx, | |
| void * | msg, | |||
| CkGroupID | gID, | |||
| int | npes, | |||
| int * | pes, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1573 of file ck.C.
References _sendMsgBranchMulti(), and CkSendMsgBranchMultiImmediate().
Referenced by CkDelegateMgr::GroupSectionSend().
| void CkSendMsgNodeBranch | ( | int | eIdx, | |
| void * | msg, | |||
| int | destNode, | |||
| CkGroupID | gID, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1676 of file ck.C.
References _sendMsgNodeBranch(), CkSendMsgNodeBranchImmediate(), and CkSendMsgNodeBranchInline().
Referenced by CkRemoteNodeBranchCallAsync(), CkSendMsgNodeBranchInline(), CProxyElement_CkNodeReductionMgr::collectMaxRedNo(), CProxyElement_CkNodeReductionMgr::DeleteChild(), CProxyElement_CkNodeReductionMgr::DeleteNewChild(), CProxyElement_CkNodeReductionMgr::modifyTree(), CkDelegateMgr::NodeGroupSend(), CProxyElement_CkNodeReductionMgr::RecvMsg(), CProxyElement_CkNodeReductionMgr::restartLocalGroupReductions(), CkCallback::send(), and CProxyElement_CkNodeReductionMgr::unblockNode().
| void CkSendMsgNodeBranchInline | ( | int | eIdx, | |
| void * | msg, | |||
| int | destNode, | |||
| CkGroupID | gID, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1653 of file ck.C.
References _deliverForNodeBocMsg(), _prepareMsgBranch(), BGConverse::CkMyNode(), CkSendMsgNodeBranch(), ForNodeBocMsg, and UsrToEnv().
Referenced by CkSendMsgNodeBranch(), CkSendMsgNodeBranchImmediate(), and CkCallback::send().
| void CkSendMsgNodeBranchMulti | ( | int | eIdx, | |
| void * | msg, | |||
| CkGroupID | gID, | |||
| int | npes, | |||
| int * | nodes, | |||
| int opts | CK_MSGOPTIONAL | |||
| ) |
Definition at line 1706 of file ck.C.
References _sendMsgNodeBranchMulti(), and CkSendMsgNodeBranchMultiImmediate().
Referenced by CkDelegateMgr::NodeGroupSectionSend().
Definition at line 1586 of file ck.C.
References _sendMsgBranch(), and Converse::CkNumPes().
Referenced by CkDelegateMgr::GroupBroadcast(), and CkCallback::send().
Definition at line 1719 of file ck.C.
References _sendMsgNodeBranch(), and BGConverse::CkNumNodes().
Referenced by CkDelegateMgr::NodeGroupBroadcast(), and CkCallback::send().
Definition at line 1728 of file ck.C.
References _prepareMsg().
Referenced by CProxy_Main::Finish(), CProxy_PythonCCS::forwardInt(), CProxy_PythonCCS::forwardString(), CProxy_waitqd_QDChare::onQD(), and CProxy_TempoChare::tempoGeneric().
Definition at line 1731 of file ck.C.
References _prepareMsgBranch(), and ForBocMsg.
Referenced by CProxyElement_CkReductionMgr::ArrayReductionHandler(), CProxyElement_TraceSummaryBOC::askSummary(), CProxyElement_ComlibManager::bracketedConfirmCount(), CProxyElement_ComlibManager::bracketedContributeDiscovery(), CProxyElement_ComlibManager::bracketedCountConfirmed(), CProxyElement_ComlibManager::bracketedDiscover(), CProxyElement_ComlibManager::bracketedErrorDetected(), CProxyElement_ComlibManager::bracketedReceiveCount(), CProxyElement_ComlibManager::bracketedReceiveNewCount(), CProxyElement_ComlibManager::bracketedReceiveNewPeList(), CProxyElement_ComlibManager::bracketedReleaseBufferedMessages(), CProxyElement_ComlibManager::bracketedReleaseCount(), CProxyElement_ComlibManager::bracketedStartErrorRecoveryProcess(), CProxyElement_pathHistoryManager::broadcastCriticalPathProjections(), CProxyElement_TraceProjectionsBOC::calculateWeights(), CProxyElement_ckcallback_group::call(), CProxyElement_TraceSummaryBOC::ccsRequestSummaryDouble(), CProxyElement_TraceSummaryBOC::ccsRequestSummaryUnsignedChar(), CProxyElement_TraceProjectionsBOC::closeTrace(), CProxyElement_HybridBaseLB::CollectInfo(), CProxyElement_CkCacheManager::collectStatistics(), CProxyElement_ComlibManager::collectStats(), CProxyElement_TraceUtilizationBOC::collectSumDetailData(), CProxyElement_TraceSummaryBOC::collectSummaryData(), CProxyElement_CkReductionMgr::contributeViaMessage(), CProxyElement_CkMemCheckPT::cpFinish(), CProxyElement_pathHistoryManager::criticalPathProjectionsDone(), CProxyElement_TraceProjectionsBOC::determineOutliers(), CProxyElement_CkMemCheckPT::doItNow(), CProxyElement_CkLocMgr::dummyAtSync(), CProxyElement_TraceProjectionsBOC::endTimeReduction(), CProxyElement_TraceProjectionsBOC::finalReduction(), CProxyElement_CkCacheManager::finishedChunk(), CProxyElement_CkMemCheckPT::finishUp(), CProxyElement_CkMulticastMgr::freeup(), CProxyElement_controlPointManager::gatherIdleTime(), CProxyElement_controlPointManager::gatherMemoryUsage(), CProxyElement_CpdPythonGroup::getCast(), CProxyElement_CpdPythonGroup::getMessage(), CProxyElement_CpdPythonGroup::getStatic(), CProxyElement_CpdPythonGroup::getValue(), CProxyElement_CkLocMgr::immigrate(), CProxyElement_TraceSummaryBOC::initCCS(), CProxyElement_CkMemCheckPT::inmem_restore(), CProxyElement_CkReductionMgr::LateMigrantMsg(), CProxyElement_CentralLB::LoadBalance(), CProxyElement_HybridBaseLB::Loadbalancing(), CProxyElement_HbmLB::Loadbalancing(), CProxyElement_CkReductionMgr::MigrantDied(), CProxyElement_CentralLB::MissMigrate(), CProxyElement_HybridBaseLB::NotifyObjectMigrationDone(), CProxyElement_HbmLB::NotifyObjectMigrationDone(), CProxyElement_HybridBaseLB::ObjMigrated(), CProxyElement_HbmLB::ObjMigrated(), CProxyElement_TraceProjectionsBOC::outlierAverageReduction(), CProxyElement_HybridBaseLB::PropagateInfo(), CProxyElement_CpdPythonGroup::pyRequest(), CProxyElement_CkMemCheckPT::quiescence(), CProxyElement_CentralLB::ReceiveCounts(), CProxyElement_WSLB::ReceiveMigration(), CProxyElement_NborBaseLB::ReceiveMigration(), CProxyElement_HybridBaseLB::ReceiveMigration(), CProxyElement_CentralLB::ReceiveMigration(), CProxyElement_HbmLB::ReceiveMigrationCount(), CProxyElement_HbmLB::ReceiveMigrationDelta(), CProxyElement_HbmLB::ReceiveResumeClients(), CProxyElement_HybridBaseLB::ReceiveStats(), CProxyElement_HbmLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStatsViaTree(), CProxyElement_HybridBaseLB::ReceiveVectorMigration(), CProxyElement_CkLocMgr::reclaimRemote(), CProxyElement_CkMemCheckPT::recoverArrayElements(), CProxyElement_CkMemCheckPT::recoverBuddies(), CProxyElement_CkArray::recvBroadcast(), CProxyElement_CkMulticastMgr::recvCookie(), CProxyElement_CkMulticastMgr::recvCookieInfo(), CProxyElement_CkCacheManager::recvData(), CProxyElement_CkMemCheckPT::recvData(), CProxyElement_CkArray::recvExpeditedBroadcast(), CProxyElement_CkMulticastMgr::recvMsg(), CProxyElement_CkMulticastMgr::recvPacket(), CProxyElement_CkMemCheckPT::recvProcData(), CProxyElement_CkMulticastMgr::recvRedMsg(), CProxyElement_CkReductionMgr::ReductionStarting(), CProxyElement_CpdPythonGroup::registerPersistent(), CProxyElement_CkArray::remoteDoneInserting(), CProxyElement_CkMemCheckPT::removeArrayElements(), CProxyElement_CkMemCheckPT::report(), CProxyElement_HybridBaseLB::reportLBMem(), CProxyElement_HybridBaseLB::reportLBQulity(), CProxyElement_HbmLB::reportLBQulity(), CProxyElement_controlPointManager::requestIdleTime(), CProxyElement_CkMemCheckPT::resetReductionMgr(), CProxyElement_CkMemCheckPT::restart(), CProxyElement_WSLB::ResumeClients(), CProxyElement_NborBaseLB::ResumeClients(), CProxyElement_HybridBaseLB::ResumeClients(), CProxyElement_HbmLB::ResumeClients(), CProxyElement_CentralLB::ResumeClients(), CProxyElement_ComlibManager::resumeFromSetupBarrier(), CProxyElement_CkMulticastMgr::retire(), CProxyElement_CkMulticastMgr::retrieveCookie(), CProxyElement_pathHistoryManager::saveCriticalPathForPriorities(), CProxyElement_CkArray::sendBroadcast(), CProxyElement_CkArray::sendExpeditedBroadcast(), CProxyElement_CkCheckpointMgr::SendRestartCB(), CProxyElement_CentralLB::SendStats(), CProxyElement_TraceSummaryBOC::sendSummaryBOC(), CProxyElement_TraceProjectionsBOC::setOutliers(), CProxyElement_FutureBOC::SetSema(), CProxyElement_TraceProjectionsBOC::shutdownAnalysis(), CProxyElement_HybridBaseLB::StartCollectInfo(), CProxyElement_TraceProjectionsBOC::startEndTimeAnalysis(), CProxyElement_TraceUtilizationBOC::sumDetailDataCollected(), CProxyElement_TraceSummaryBOC::summaryDataCollected(), CProxyElement_CkMemCheckPT::syncFiles(), CProxyElement_CkMulticastMgr::teardown(), CProxyElement_HybridBaseLB::TotalObjMigrated(), CProxyElement_CkLocMgr::updateLocation(), CProxyElement_CkMulticastMgr::updateRedNo(), and CProxyElement_CkCacheManager::writebackChunk().
Definition at line 1734 of file ck.C.
References _prepareMsgBranch(), and ForNodeBocMsg.
Referenced by CProxyElement_CkNodeReductionMgr::collectMaxRedNo(), CProxyElement_CkNodeReductionMgr::DeleteChild(), CProxyElement_CkNodeReductionMgr::DeleteNewChild(), CProxyElement_CkNodeReductionMgr::modifyTree(), CProxyElement_CkNodeReductionMgr::RecvMsg(), CProxyElement_CkNodeReductionMgr::restartLocalGroupReductions(), and CProxyElement_CkNodeReductionMgr::unblockNode().
| void CkSetRefNum | ( | void * | msg, | |
| int | ref | |||
| ) |
| int CkGetRefNum | ( | void * | msg | ) |
Definition at line 392 of file ck.C.
References envelope::getRef(), and UsrToEnv().
Referenced by CkIndex_waitqd_QDChare::_callthr_waitQD_void().
| int CkGetSrcPe | ( | void * | msg | ) |
Definition at line 398 of file ck.C.
References envelope::getSrcPe(), and UsrToEnv().
Referenced by CkIndex_waitqd_QDChare::_callthr_waitQD_void(), and CkGetSrcNode().
| int CkGetSrcNode | ( | void * | msg | ) |
| void CkDeliverMessageFree | ( | int | epIdx, | |
| void * | msg, | |||
| void * | object | |||
| ) |
Definition at line 463 of file ck.C.
References _entryTable, _msgTable, CpdAfterEp(), and CpdBeforeEp().
Referenced by _invokeEntryNoTrace(), and CkLocRec_local::invokeEntry().
| void CkDeliverMessageReadonly | ( | int | epIdx, | |
| const void * | msg, | |||
| void * | object | |||
| ) |
Definition at line 484 of file ck.C.
References _entryTable, CkCopyMsg(), CpdAfterEp(), and CpdBeforeEp().
Referenced by CkLocRec_local::invokeEntry().
| void* CkLocalBranch | ( | CkGroupID | gID | ) |
Definition at line 410 of file ck.C.
References _localBranch().
Referenced by _deliverForBocMsg(), ComlibManager::ArraySend(), CProxyElement_CkCacheManager::cacheSync(), CkCacheManager::cacheSync(), chpt< StateType >::checkpoint(), CProxy_NodeGroup::ckGetChareID(), CProxy_Group::ckGetChareID(), CkLocMgr::CkLocMgr(), eventQueue::CommitStatsHelper(), LBgroup::computePeLoad(), eventQueue::eventQueue(), CProxyElement_CkCacheManager::getCache(), CkObjID::getObject(), GVT::GVT(), LBgroup::LBgroup(), LBstrategy::LBstrategy(), migrationDone(), LBDatabase::Object(), eventMsg::operator delete(), eventMsg::operator new(), sim::pup(), CkLocMgr::pup(), CProxy::pup(), PUPmarshall(), PVT::PVT(), CProxyElement_CkCacheManager::recvData(), rep::registerTimestamp(), CProxyElement_CkCacheManager::requestCacheEntryNoFetch(), CProxyElement_CkCacheManager::requestDataNoFetch(), sim::sim(), and strat::strat().
| void* CkLocalNodeBranch | ( | CkGroupID | gID | ) |
Definition at line 423 of file ck.C.
References _ckLocalNodeBranch(), and CsdScheduler().
Referenced by CkReductionMgr::finishReduction(), CProxy::pup(), and PUPmarshall().
| void* CkLocalChare | ( | const CkChareID * | chare | ) |
Definition at line 437 of file ck.C.
References Converse::CkMyPe(), VidBlock::getLocalChare(), CkChareID::objPtr, and CkChareID::onPE.
Referenced by CkObjID::getObject().
Definition at line 1764 of file ck.C.
References _infoIdx, _prepareOutgoingArrayMsg(), ArrayEltInitMsg, CldEnqueue(), envelope::getsetArrayMgr(), and UsrToEnv().
Referenced by CProxy_ArrayBase::ckInsertIdx(), CkArray::demandCreateElement(), CkArray::insertElement(), and CkArray::insertInitial().
Definition at line 1772 of file ck.C.
References _infoIdx, _noCldEnqueue(), _prepareOutgoingArrayMsg(), _skipCldEnqueue(), ForArrayEltMsg, sendTicketArrayRequest(), and UsrToEnv().
Referenced by CkLocRec_local::addedElement(), CkLocRec_remote::deliver(), CkLocRec_local::deliver(), and CkLocMgr::deliverUnknown().
1.5.5