Ck

Charm Kernel--the groups and chares level of Charm++. More...

Data Structures

struct  CkChareID
struct  _ckGroupID

Typedefs

typedef _ckGroupID CkGroupID
typedef CkGroupID CkNodeGroupID
typedef envelope envelope

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, int npes, int *pes, CkGroupID gID, 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 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)

Detailed Description

Charm Kernel--the groups and chares level of Charm++.

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 Documentation

typedef struct _ckGroupID CkGroupID

typedef CkGroupID CkNodeGroupID

Definition at line 183 of file charm.h.

typedef struct envelope envelope

Definition at line 193 of file charm.h.

Function Documentation

void CkCreateChare ( int  chareIdx,
int  constructorIdx,
void *  msg,
CkChareID *  vid,
int  destPE 
)

Definition at line 439 of file ck.C.

References _charmHandlerIdx, _entryTable, _infoIdx, Converse::CkMyPe(), CldEnqueue(), 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_TraceSummaryInit::ckNew(), CProxy_TraceProjectionsInit::ckNew(), CProxy_TempoChare::ckNew(), CProxy_LBDBInit::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_FutureMain::CProxy_FutureMain(), CProxy_LBDBInit::CProxy_LBDBInit(), CProxy_Main::CProxy_Main(), CProxy_TraceProjectionsInit::CProxy_TraceProjectionsInit(), CProxy_TraceSummaryInit::CProxy_TraceSummaryInit(), and CProxy_waitqd_QDChare::CProxy_waitqd_QDChare().

CkGroupID CkCreateGroup ( int  chareIdx,
int  constructorIdx,
void *  msg 
)

Definition at line 636 of file ck.C.

References _entryTable, _groupCreate(), BocInitMsg, Converse::CkMyPe(), Converse::CkNumPes(), envelope::setEpIdx(), envelope::setMsgtype(), envelope::setSrcPe(), and UsrToEnv().

Referenced by CProxy_CkMulticastMgr::ckNew(), CProxy_CkCacheManager::ckNew(), CProxy_BaseLB::CProxy_BaseLB(), CProxy_BlockLB::CProxy_BlockLB(), CProxy_CentralLB::CProxy_CentralLB(), CProxy_CkArray::CProxy_CkArray(), CProxy_CkCacheManager::CProxy_CkCacheManager(), CProxy_CkLocMgr::CProxy_CkLocMgr(), CProxy_CkMemCheckPT::CProxy_CkMemCheckPT(), CProxy_CkMulticastMgr::CProxy_CkMulticastMgr(), CProxy_ComboCentLB::CProxy_ComboCentLB(), CProxy_Comm1LB::CProxy_Comm1LB(), CProxy_DummyLB::CProxy_DummyLB(), CProxy_FutureBOC::CProxy_FutureBOC(), CProxy_GreedyAgentLB::CProxy_GreedyAgentLB(), CProxy_GreedyCommLB::CProxy_GreedyCommLB(), CProxy_GreedyLB::CProxy_GreedyLB(), CProxy_GridCommLB::CProxy_GridCommLB(), CProxy_GridCommRefineLB::CProxy_GridCommRefineLB(), CProxy_GridHybridLB::CProxy_GridHybridLB(), CProxy_GridHybridSeedLB::CProxy_GridHybridSeedLB(), CProxy_GridMetisLB::CProxy_GridMetisLB(), CProxy_HbmLB::CProxy_HbmLB(), CProxy_HybridBaseLB::CProxy_HybridBaseLB(), CProxy_HybridLB::CProxy_HybridLB(), CProxy_MetisLB::CProxy_MetisLB(), CProxy_NborBaseLB::CProxy_NborBaseLB(), CProxy_NeighborCommLB::CProxy_NeighborCommLB(), CProxy_NeighborLB::CProxy_NeighborLB(), CProxy_NullLB::CProxy_NullLB(), CProxy_OrbLB::CProxy_OrbLB(), CProxy_PhasebyArrayLB::CProxy_PhasebyArrayLB(), CProxy_RandCentLB::CProxy_RandCentLB(), CProxy_RecBisectBfLB::CProxy_RecBisectBfLB(), CProxy_RefineCommLB::CProxy_RefineCommLB(), CProxy_RefineKLB::CProxy_RefineKLB(), CProxy_RefineLB::CProxy_RefineLB(), CProxy_RefineTopoLB::CProxy_RefineTopoLB(), CProxy_RotateLB::CProxy_RotateLB(), CProxy_TopoCentLB::CProxy_TopoCentLB(), CProxy_TopoLB::CProxy_TopoLB(), and CProxy_WSLB::CProxy_WSLB().

CkGroupID CkCreateNodeGroup ( int  chareIdx,
int  constructorIdx,
void *  msg 
)

Definition at line 650 of file ck.C.

References _entryTable, _nodeGroupCreate(), Converse::CkMyPe(), BGConverse::CkNumNodes(), NodeBocInitMsg, envelope::setEpIdx(), envelope::setMsgtype(), envelope::setSrcPe(), and UsrToEnv().

Referenced by CProxy_CkArrayReductionMgr::ckNew(), and CProxy_CkArrayReductionMgr::CProxy_CkArrayReductionMgr().

void CkCreateLocalGroup ( CkGroupID  groupID,
int  constructorIdx,
envelope *  env 
)

Definition at line 469 of file ck.C.

Referenced by _createGroup(), _processBocInitMsg(), and CkPupGroupData().

void CkCreateLocalNodeGroup ( CkGroupID  groupID,
int  constructorIdx,
envelope *  env 
)

Definition at line 495 of file ck.C.

Referenced by _createNodeGroup(), _processNodeBocInitMsg(), and CkPupNodeGroupData().

void CkSendMsg ( int  entryIndex,
void *  msg,
const CkChareID *  chare,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1119 of file ck.C.

References _infoIdx, _noCldEnqueue(), _prepareMsg(), CkSendMsgInline(), CldEnqueue(), CmiAbort(), opts, and UsrToEnv().

Referenced by CkDelegateMgr::ChareSend(), CkRemoteCallAsync(), CkSendMsgInline(), CProxy_Main::Finish(), CProxy_waitqd_QDChare::onQD(), CkCallback::send(), and CProxy_TempoChare::tempoGeneric().

void CkSendMsgBranch ( int  eIdx,
void *  msg,
int  destPE,
CkGroupID  gID,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1260 of file ck.C.

References _sendMsgBranch(), CkSendMsgBranchImmediate(), CkSendMsgBranchInline(), and opts.

Referenced by CProxyElement_CkReductionMgr::ArrayReductionHandler(), CProxyElement_TraceSummaryBOC::askSummary(), CProxyElement_ComlibManager::barrier2(), CProxyElement_TraceProjectionsBOC::calculateWeights(), CProxyElement_ckcallback_group::call(), CkRemoteBranchCallAsync(), CkSendMsgBranchInline(), CProxyElement_TraceProjectionsBOC::closeTrace(), CProxyElement_HybridBaseLB::CollectInfo(), CProxyElement_CkCacheManager::collectStatistics(), CProxyElement_ComlibManager::collectStats(), CProxyElement_CkMemCheckPT::cpFinish(), CProxyElement_TraceProjectionsBOC::determineOutliers(), CProxyElement_CkMemCheckPT::doItNow(), CProxyElement_CkLocMgr::dummyAtSync(), CProxyElement_TraceProjectionsBOC::endTimeReduction(), CProxyElement_TraceProjectionsBOC::finalReduction(), CProxyElement_CkCacheManager::finishedChunk(), CProxyElement_CkMemCheckPT::finishUp(), CProxyElement_CkMulticastMgr::freeup(), CkDelegateMgr::GroupSend(), ComlibManager::GroupSend(), BroadcastStrategy::handleHypercube(), BroadcastStrategy::handleTree(), CProxyElement_CkLocMgr::immigrate(), 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_CkMemCheckPT::quiescence(), CProxyElement_CentralLB::ReceiveCounts(), CProxyElement_WSLB::ReceiveMigration(), CProxyElement_NborBaseLB::ReceiveMigration(), CProxyElement_HybridBaseLB::ReceiveMigration(), CProxyElement_CentralLB::ReceiveMigration(), CProxyElement_HbmLB::ReceiveMigrationCount(), CProxyElement_HbmLB::ReceiveMigrationDelta(), CProxyElement_ComlibManager::receiveRemoteSend(), CProxyElement_HbmLB::ReceiveResumeClients(), CProxyElement_HybridBaseLB::ReceiveStats(), CProxyElement_HbmLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStatsViaTree(), CProxyElement_ComlibManager::receiveTable(), 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_CkArray::remoteDoneInserting(), CProxyElement_CkMemCheckPT::removeArrayElements(), CProxyElement_CkMemCheckPT::report(), CProxyElement_HybridBaseLB::reportLBMem(), CProxyElement_HybridBaseLB::reportLBQulity(), CProxyElement_HbmLB::reportLBQulity(), CProxyElement_CkMemCheckPT::resetReductionMgr(), CProxyElement_CkMemCheckPT::restart(), CProxyElement_WSLB::ResumeClients(), CProxyElement_NborBaseLB::ResumeClients(), CProxyElement_HybridBaseLB::ResumeClients(), CProxyElement_HbmLB::ResumeClients(), CProxyElement_CentralLB::ResumeClients(), CProxyElement_ComlibManager::resumeFromBarrier2(), CProxyElement_CkMulticastMgr::retire(), CProxyElement_CkMulticastMgr::retrieveCookie(), 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_CkMemCheckPT::syncFiles(), CProxyElement_CkMulticastMgr::teardown(), CProxyElement_HybridBaseLB::TotalObjMigrated(), CProxyElement_CkLocMgr::updateLocation(), and CProxyElement_CkMulticastMgr::updateRedNo().

void CkSendMsgInline ( int  entryIndex,
void *  msg,
const CkChareID *  chare,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1144 of file ck.C.

References _invokeEntryNoTrace(), _prepareMsg(), Converse::CkMyPe(), CkSendMsg(), CkUnpackMessage(), envelope::isPacked(), CkChareID::objPtr, CkChareID::onPE, opts, 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 1236 of file ck.C.

References _deliverForBocMsg(), _localBranch(), _prepareMsgBranch(), Converse::CkMyPe(), CkSendMsgBranch(), ForBocMsg, opts, and UsrToEnv().

Referenced by CkSendMsgBranch(), CkSendMsgBranchImmediate(), PipeBroadcastStrategy::deliverer(), and CkCallback::send().

void CkSendMsgBranchMulti ( int  eIdx,
void *  msg,
int  npes,
int *  pes,
CkGroupID  gID,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1292 of file ck.C.

References _sendMsgBranchMulti(), CkSendMsgBranchMultiImmediate(), and opts.

Referenced by CProxy_CkReductionMgr::ArrayReductionHandler(), CProxy_TraceSummaryBOC::askSummary(), CProxy_ComlibManager::barrier(), CProxy_ComlibManager::barrier2(), CProxy_TraceProjectionsBOC::calculateWeights(), CProxy_ckcallback_group::call(), CProxy_CkGroupReadyCallback::callMeBack(), CProxy_CkGroupInitCallback::callMeBack(), CProxy_CkCheckpointMgr::Checkpoint(), CProxy_TraceProjectionsBOC::closeTrace(), CProxy_HybridBaseLB::CollectInfo(), CProxy_CkCacheManager::collectStatistics(), CProxy_ComlibManager::collectStats(), CProxy_CkMemCheckPT::cpFinish(), CProxy_CkMemCheckPT::createEntry(), CProxy_CkLocMgr::deliverInline(), CProxy_TraceProjectionsBOC::determineOutliers(), CProxy_CkMemCheckPT::doItNow(), CProxy_CkLocMgr::dummyAtSync(), CProxy_TraceProjectionsBOC::endTimeReduction(), CProxy_TraceProjectionsBOC::finalReduction(), CProxy_CkCacheManager::finishedChunk(), CProxy_CkMemCheckPT::finishUp(), CProxy_CkMulticastMgr::freeup(), CProxy_CkLocMgr::immigrate(), CProxy_CkMemCheckPT::inmem_restore(), CProxy_CkArray::insertElement(), CProxy_CkReductionMgr::LateMigrantMsg(), CProxy_CentralLB::LoadBalance(), CProxy_HybridBaseLB::Loadbalancing(), CProxy_HbmLB::Loadbalancing(), CProxy_CkReductionMgr::MigrantDied(), CProxy_NullLB::migrationsDone(), CProxy_CentralLB::MissMigrate(), CProxy_HybridBaseLB::NotifyObjectMigrationDone(), CProxy_HbmLB::NotifyObjectMigrationDone(), CProxy_HybridBaseLB::ObjMigrated(), CProxy_HbmLB::ObjMigrated(), CProxy_TraceProjectionsBOC::outlierAverageReduction(), CProxy_HybridBaseLB::ProcessAtSync(), CProxy_HbmLB::ProcessAtSync(), CProxy_CentralLB::ProcessAtSync(), CProxy_HybridBaseLB::PropagateInfo(), CProxy_CkMemCheckPT::quiescence(), CProxy_CentralLB::ReceiveCounts(), CProxy_WSLB::ReceiveMigration(), CProxy_NborBaseLB::ReceiveMigration(), CProxy_HybridBaseLB::ReceiveMigration(), CProxy_CentralLB::ReceiveMigration(), CProxy_HbmLB::ReceiveMigrationCount(), CProxy_HbmLB::ReceiveMigrationDelta(), CProxy_ComlibManager::receiveRemoteSend(), CProxy_HbmLB::ReceiveResumeClients(), CProxy_WSLB::ReceiveStats(), CProxy_NborBaseLB::ReceiveStats(), CProxy_HybridBaseLB::ReceiveStats(), CProxy_HbmLB::ReceiveStats(), CProxy_CentralLB::ReceiveStats(), CProxy_CentralLB::ReceiveStatsViaTree(), CProxy_ComlibManager::receiveTable(), CProxy_HybridBaseLB::ReceiveVectorMigration(), CProxy_CkLocMgr::reclaimRemote(), CProxy_CkMemCheckPT::recoverArrayElements(), CProxy_CkMemCheckPT::recoverBuddies(), CProxy_CkArray::recvBroadcast(), CProxy_CkMulticastMgr::recvCookie(), CProxy_CkMulticastMgr::recvCookieInfo(), CProxy_CkCacheManager::recvData(), CProxy_CkMemCheckPT::recvData(), CProxy_CkArray::recvExpeditedBroadcast(), CProxy_CkMulticastMgr::recvMsg(), CProxy_CkMulticastMgr::recvPacket(), CProxy_CkMemCheckPT::recvProcData(), CProxy_CkMulticastMgr::recvRedMsg(), CProxy_CkReductionMgr::ReductionStarting(), CProxy_ckcallback_group::registerCcsCallback(), CProxy_CkArray::remoteDoneInserting(), CProxy_CkMemCheckPT::removeArrayElements(), CProxy_CkMemCheckPT::report(), CProxy_HybridBaseLB::reportLBMem(), CProxy_HybridBaseLB::reportLBQulity(), CProxy_HbmLB::reportLBQulity(), CProxy_CkMemCheckPT::resetReductionMgr(), CProxy_CkMemCheckPT::restart(), CProxy_WSLB::ResumeClients(), CProxy_NborBaseLB::ResumeClients(), CProxy_HybridBaseLB::ResumeClients(), CProxy_HbmLB::ResumeClients(), CProxy_CentralLB::ResumeClients(), CProxy_ComlibManager::resumeFromBarrier2(), CProxy_CkMulticastMgr::retire(), CProxy_CkMulticastMgr::retrieveCookie(), CProxy_CkArray::sendBroadcast(), CProxy_CkArray::sendExpeditedBroadcast(), CProxy_CkCheckpointMgr::SendRestartCB(), CProxy_CentralLB::SendStats(), CProxy_TraceSummaryBOC::sendSummaryBOC(), CProxy_FutureBOC::SetFuture(), CProxy_TraceProjectionsBOC::setOutliers(), CProxy_FutureBOC::SetSema(), CProxy_CkMulticastMgr::setup(), CProxy_TraceProjectionsBOC::shutdownAnalysis(), CProxy_HybridBaseLB::StartCollectInfo(), CProxy_TraceProjectionsBOC::startEndTimeAnalysis(), CProxy_TraceProjectionsBOC::startOutlierAnalysis(), CProxy_TraceSummaryBOC::startSumOnly(), CProxy_CkMemCheckPT::syncFiles(), CProxy_CkMulticastMgr::teardown(), CProxy_TempoGroup::tempoGeneric(), CProxy_HybridBaseLB::TotalObjMigrated(), CProxy_BaseLB::unregister(), CProxy_CkLocMgr::updateLocation(), and CProxy_CkMulticastMgr::updateRedNo().

void CkSendMsgNodeBranch ( int  eIdx,
void *  msg,
int  destNode,
CkGroupID  gID,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1376 of file ck.C.

References _sendMsgNodeBranch(), CkSendMsgNodeBranchImmediate(), CkSendMsgNodeBranchInline(), and opts.

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 1357 of file ck.C.

References _deliverForNodeBocMsg(), BGConverse::CkMyNode(), CkSendMsgNodeBranch(), opts, and UsrToEnv().

Referenced by CkSendMsgNodeBranch(), CkSendMsgNodeBranchImmediate(), and CkCallback::send().

void CkBroadcastMsgBranch ( int  eIdx,
void *  msg,
CkGroupID  gID,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1305 of file ck.C.

References _sendMsgBranch(), Converse::CkNumPes(), and opts.

Referenced by CProxy_CkReductionMgr::ArrayReductionHandler(), CProxy_TraceSummaryBOC::askSummary(), CProxy_ComlibManager::barrier(), CProxy_ComlibManager::barrier2(), CProxy_TraceProjectionsBOC::calculateWeights(), CProxy_ckcallback_group::call(), CProxy_CkGroupReadyCallback::callMeBack(), CProxy_CkGroupInitCallback::callMeBack(), CProxy_CkCheckpointMgr::Checkpoint(), CProxy_TraceProjectionsBOC::closeTrace(), CProxy_HybridBaseLB::CollectInfo(), CProxy_CkCacheManager::collectStatistics(), CProxy_ComlibManager::collectStats(), CProxy_CkMemCheckPT::cpFinish(), CProxy_CkMemCheckPT::createEntry(), CProxy_CkLocMgr::deliverInline(), CProxy_TraceProjectionsBOC::determineOutliers(), CProxy_CkMemCheckPT::doItNow(), CProxy_CkLocMgr::dummyAtSync(), CProxy_TraceProjectionsBOC::endTimeReduction(), CProxy_TraceProjectionsBOC::finalReduction(), CProxy_CkCacheManager::finishedChunk(), CProxy_CkMemCheckPT::finishUp(), CProxy_CkMulticastMgr::freeup(), CkDelegateMgr::GroupBroadcast(), CProxy_CkLocMgr::immigrate(), CProxy_CkMemCheckPT::inmem_restore(), CProxy_CkArray::insertElement(), CProxy_CkReductionMgr::LateMigrantMsg(), CProxy_CentralLB::LoadBalance(), CProxy_HybridBaseLB::Loadbalancing(), CProxy_HbmLB::Loadbalancing(), CProxy_CkReductionMgr::MigrantDied(), CProxy_NullLB::migrationsDone(), CProxy_CentralLB::MissMigrate(), CProxy_HybridBaseLB::NotifyObjectMigrationDone(), CProxy_HbmLB::NotifyObjectMigrationDone(), CProxy_HybridBaseLB::ObjMigrated(), CProxy_HbmLB::ObjMigrated(), CProxy_TraceProjectionsBOC::outlierAverageReduction(), CProxy_HybridBaseLB::ProcessAtSync(), CProxy_HbmLB::ProcessAtSync(), CProxy_CentralLB::ProcessAtSync(), CProxy_HybridBaseLB::PropagateInfo(), CProxy_CkMemCheckPT::quiescence(), CProxy_CentralLB::ReceiveCounts(), CProxy_WSLB::ReceiveMigration(), CProxy_NborBaseLB::ReceiveMigration(), CProxy_HybridBaseLB::ReceiveMigration(), CProxy_CentralLB::ReceiveMigration(), CProxy_HbmLB::ReceiveMigrationCount(), CProxy_HbmLB::ReceiveMigrationDelta(), CProxy_ComlibManager::receiveRemoteSend(), CProxy_HbmLB::ReceiveResumeClients(), CProxy_WSLB::ReceiveStats(), CProxy_NborBaseLB::ReceiveStats(), CProxy_HybridBaseLB::ReceiveStats(), CProxy_HbmLB::ReceiveStats(), CProxy_CentralLB::ReceiveStats(), CProxy_CentralLB::ReceiveStatsViaTree(), CProxy_ComlibManager::receiveTable(), CProxy_HybridBaseLB::ReceiveVectorMigration(), CProxy_CkLocMgr::reclaimRemote(), CProxy_CkMemCheckPT::recoverArrayElements(), CProxy_CkMemCheckPT::recoverBuddies(), CProxy_CkArray::recvBroadcast(), CProxy_CkMulticastMgr::recvCookie(), CProxy_CkMulticastMgr::recvCookieInfo(), CProxy_CkCacheManager::recvData(), CProxy_CkMemCheckPT::recvData(), CProxy_CkArray::recvExpeditedBroadcast(), CProxy_CkMulticastMgr::recvMsg(), CProxy_CkMulticastMgr::recvPacket(), CProxy_CkMemCheckPT::recvProcData(), CProxy_CkMulticastMgr::recvRedMsg(), CProxy_CkReductionMgr::ReductionStarting(), CProxy_ckcallback_group::registerCcsCallback(), CProxy_CkArray::remoteDoneInserting(), CProxy_CkMemCheckPT::removeArrayElements(), CProxy_CkMemCheckPT::report(), CProxy_HybridBaseLB::reportLBMem(), CProxy_HybridBaseLB::reportLBQulity(), CProxy_HbmLB::reportLBQulity(), CProxy_CkMemCheckPT::resetReductionMgr(), CProxy_CkMemCheckPT::restart(), CProxy_WSLB::ResumeClients(), CProxy_NborBaseLB::ResumeClients(), CProxy_HybridBaseLB::ResumeClients(), CProxy_HbmLB::ResumeClients(), CProxy_CentralLB::ResumeClients(), CProxy_ComlibManager::resumeFromBarrier2(), CProxy_CkMulticastMgr::retire(), CProxy_CkMulticastMgr::retrieveCookie(), CkCallback::send(), CProxy_CkArray::sendBroadcast(), CProxy_CkArray::sendExpeditedBroadcast(), CProxy_CkCheckpointMgr::SendRestartCB(), CProxy_CentralLB::SendStats(), CProxy_TraceSummaryBOC::sendSummaryBOC(), CProxy_FutureBOC::SetFuture(), CProxy_TraceProjectionsBOC::setOutliers(), CProxy_FutureBOC::SetSema(), CProxy_CkMulticastMgr::setup(), CProxy_TraceProjectionsBOC::shutdownAnalysis(), CProxy_HybridBaseLB::StartCollectInfo(), CProxy_TraceProjectionsBOC::startEndTimeAnalysis(), CProxy_TraceProjectionsBOC::startOutlierAnalysis(), CProxy_TraceSummaryBOC::startSumOnly(), CProxy_CkMemCheckPT::syncFiles(), CProxy_CkMulticastMgr::teardown(), CProxy_TempoGroup::tempoGeneric(), CProxy_HybridBaseLB::TotalObjMigrated(), CProxy_BaseLB::unregister(), CProxy_CkLocMgr::updateLocation(), and CProxy_CkMulticastMgr::updateRedNo().

void CkBroadcastMsgNodeBranch ( int  eIdx,
void *  msg,
CkGroupID  gID,
int opts  CK_MSGOPTIONAL 
)

Definition at line 1392 of file ck.C.

References _sendMsgNodeBranch(), BGConverse::CkNumNodes(), and opts.

Referenced by CProxy_CkNodeReductionMgr::collectMaxRedNo(), CProxy_CkNodeReductionMgr::DeleteChild(), CProxy_CkNodeReductionMgr::DeleteNewChild(), CProxy_CkNodeReductionMgr::modifyTree(), CkDelegateMgr::NodeGroupBroadcast(), CProxy_CkNodeReductionMgr::RecvMsg(), CProxy_CkNodeReductionMgr::ReductionStarting(), CProxy_CkNodeReductionMgr::restartLocalGroupReductions(), CkCallback::send(), CProxy_CkArrayReductionMgr::setAttachedGroup(), and CProxy_CkNodeReductionMgr::unblockNode().

int CkChareMsgPrep ( int  eIdx,
void *  msg,
const CkChareID *  pCid 
)

Definition at line 1401 of file ck.C.

References _prepareMsg().

Referenced by CProxy_Main::Finish(), CProxy_waitqd_QDChare::onQD(), and CProxy_TempoChare::tempoGeneric().

void CkGroupMsgPrep ( int  eIdx,
void *  msg,
CkGroupID  gID 
)

Definition at line 1404 of file ck.C.

References _prepareMsgBranch(), and ForBocMsg.

Referenced by CProxy_CkReductionMgr::ArrayReductionHandler(), CProxyElement_CkReductionMgr::ArrayReductionHandler(), CProxy_TraceSummaryBOC::askSummary(), CProxyElement_TraceSummaryBOC::askSummary(), CProxy_ComlibManager::barrier(), CProxy_ComlibManager::barrier2(), CProxyElement_ComlibManager::barrier2(), CProxy_TraceProjectionsBOC::calculateWeights(), CProxyElement_TraceProjectionsBOC::calculateWeights(), CProxy_ckcallback_group::call(), CProxyElement_ckcallback_group::call(), CProxy_CkGroupReadyCallback::callMeBack(), CProxy_CkGroupInitCallback::callMeBack(), CProxy_CkCheckpointMgr::Checkpoint(), CProxy_TraceProjectionsBOC::closeTrace(), CProxyElement_TraceProjectionsBOC::closeTrace(), CProxy_HybridBaseLB::CollectInfo(), CProxyElement_HybridBaseLB::CollectInfo(), CProxy_CkCacheManager::collectStatistics(), CProxyElement_CkCacheManager::collectStatistics(), CProxy_ComlibManager::collectStats(), CProxyElement_ComlibManager::collectStats(), CProxy_CkMemCheckPT::cpFinish(), CProxyElement_CkMemCheckPT::cpFinish(), CProxy_CkMemCheckPT::createEntry(), CProxy_CkLocMgr::deliverInline(), CProxy_TraceProjectionsBOC::determineOutliers(), CProxyElement_TraceProjectionsBOC::determineOutliers(), CProxy_CkMemCheckPT::doItNow(), CProxyElement_CkMemCheckPT::doItNow(), CProxy_CkLocMgr::dummyAtSync(), CProxyElement_CkLocMgr::dummyAtSync(), CProxy_TraceProjectionsBOC::endTimeReduction(), CProxyElement_TraceProjectionsBOC::endTimeReduction(), CProxy_TraceProjectionsBOC::finalReduction(), CProxyElement_TraceProjectionsBOC::finalReduction(), CProxy_CkCacheManager::finishedChunk(), CProxyElement_CkCacheManager::finishedChunk(), CProxy_CkMemCheckPT::finishUp(), CProxyElement_CkMemCheckPT::finishUp(), CProxy_CkMulticastMgr::freeup(), CProxyElement_CkMulticastMgr::freeup(), CProxy_CkLocMgr::immigrate(), CProxyElement_CkLocMgr::immigrate(), CProxy_CkMemCheckPT::inmem_restore(), CProxyElement_CkMemCheckPT::inmem_restore(), CProxy_CkArray::insertElement(), CProxy_CkReductionMgr::LateMigrantMsg(), CProxyElement_CkReductionMgr::LateMigrantMsg(), CProxy_CentralLB::LoadBalance(), CProxyElement_CentralLB::LoadBalance(), CProxy_HybridBaseLB::Loadbalancing(), CProxyElement_HybridBaseLB::Loadbalancing(), CProxy_HbmLB::Loadbalancing(), CProxyElement_HbmLB::Loadbalancing(), CProxy_CkReductionMgr::MigrantDied(), CProxyElement_CkReductionMgr::MigrantDied(), CProxy_NullLB::migrationsDone(), CProxy_CentralLB::MissMigrate(), CProxyElement_CentralLB::MissMigrate(), CProxy_HybridBaseLB::NotifyObjectMigrationDone(), CProxyElement_HybridBaseLB::NotifyObjectMigrationDone(), CProxy_HbmLB::NotifyObjectMigrationDone(), CProxyElement_HbmLB::NotifyObjectMigrationDone(), CProxy_HybridBaseLB::ObjMigrated(), CProxyElement_HybridBaseLB::ObjMigrated(), CProxy_HbmLB::ObjMigrated(), CProxyElement_HbmLB::ObjMigrated(), CProxy_TraceProjectionsBOC::outlierAverageReduction(), CProxyElement_TraceProjectionsBOC::outlierAverageReduction(), CProxy_HybridBaseLB::ProcessAtSync(), CProxy_HbmLB::ProcessAtSync(), CProxy_CentralLB::ProcessAtSync(), CProxy_HybridBaseLB::PropagateInfo(), CProxyElement_HybridBaseLB::PropagateInfo(), CProxy_CkMemCheckPT::quiescence(), CProxyElement_CkMemCheckPT::quiescence(), CProxy_CentralLB::ReceiveCounts(), CProxyElement_CentralLB::ReceiveCounts(), CProxy_WSLB::ReceiveMigration(), CProxyElement_WSLB::ReceiveMigration(), CProxy_NborBaseLB::ReceiveMigration(), CProxyElement_NborBaseLB::ReceiveMigration(), CProxy_HybridBaseLB::ReceiveMigration(), CProxyElement_HybridBaseLB::ReceiveMigration(), CProxy_CentralLB::ReceiveMigration(), CProxyElement_CentralLB::ReceiveMigration(), CProxy_HbmLB::ReceiveMigrationCount(), CProxyElement_HbmLB::ReceiveMigrationCount(), CProxy_HbmLB::ReceiveMigrationDelta(), CProxyElement_HbmLB::ReceiveMigrationDelta(), CProxy_ComlibManager::receiveRemoteSend(), CProxyElement_ComlibManager::receiveRemoteSend(), CProxy_HbmLB::ReceiveResumeClients(), CProxyElement_HbmLB::ReceiveResumeClients(), CProxy_WSLB::ReceiveStats(), CProxy_NborBaseLB::ReceiveStats(), CProxy_HybridBaseLB::ReceiveStats(), CProxyElement_HybridBaseLB::ReceiveStats(), CProxy_HbmLB::ReceiveStats(), CProxyElement_HbmLB::ReceiveStats(), CProxy_CentralLB::ReceiveStats(), CProxyElement_CentralLB::ReceiveStats(), CProxy_CentralLB::ReceiveStatsViaTree(), CProxyElement_CentralLB::ReceiveStatsViaTree(), CProxy_ComlibManager::receiveTable(), CProxyElement_ComlibManager::receiveTable(), CProxy_HybridBaseLB::ReceiveVectorMigration(), CProxyElement_HybridBaseLB::ReceiveVectorMigration(), CProxy_CkLocMgr::reclaimRemote(), CProxyElement_CkLocMgr::reclaimRemote(), CProxy_CkMemCheckPT::recoverArrayElements(), CProxyElement_CkMemCheckPT::recoverArrayElements(), CProxy_CkMemCheckPT::recoverBuddies(), CProxyElement_CkMemCheckPT::recoverBuddies(), CProxy_CkArray::recvBroadcast(), CProxyElement_CkArray::recvBroadcast(), CProxy_CkMulticastMgr::recvCookie(), CProxyElement_CkMulticastMgr::recvCookie(), CProxy_CkMulticastMgr::recvCookieInfo(), CProxyElement_CkMulticastMgr::recvCookieInfo(), CProxy_CkCacheManager::recvData(), CProxyElement_CkCacheManager::recvData(), CProxy_CkMemCheckPT::recvData(), CProxyElement_CkMemCheckPT::recvData(), CProxy_CkArray::recvExpeditedBroadcast(), CProxyElement_CkArray::recvExpeditedBroadcast(), CProxy_CkMulticastMgr::recvMsg(), CProxyElement_CkMulticastMgr::recvMsg(), CProxy_CkMulticastMgr::recvPacket(), CProxyElement_CkMulticastMgr::recvPacket(), CProxy_CkMemCheckPT::recvProcData(), CProxyElement_CkMemCheckPT::recvProcData(), CProxy_CkMulticastMgr::recvRedMsg(), CProxyElement_CkMulticastMgr::recvRedMsg(), CProxy_CkReductionMgr::ReductionStarting(), CProxy_ckcallback_group::registerCcsCallback(), CProxy_CkArray::remoteDoneInserting(), CProxyElement_CkArray::remoteDoneInserting(), CProxy_CkMemCheckPT::removeArrayElements(), CProxyElement_CkMemCheckPT::removeArrayElements(), CProxy_CkMemCheckPT::report(), CProxyElement_CkMemCheckPT::report(), CProxy_HybridBaseLB::reportLBMem(), CProxyElement_HybridBaseLB::reportLBMem(), CProxy_HybridBaseLB::reportLBQulity(), CProxyElement_HybridBaseLB::reportLBQulity(), CProxy_HbmLB::reportLBQulity(), CProxyElement_HbmLB::reportLBQulity(), CProxy_CkMemCheckPT::resetReductionMgr(), CProxyElement_CkMemCheckPT::resetReductionMgr(), CProxy_CkMemCheckPT::restart(), CProxyElement_CkMemCheckPT::restart(), CProxy_WSLB::ResumeClients(), CProxyElement_WSLB::ResumeClients(), CProxy_NborBaseLB::ResumeClients(), CProxyElement_NborBaseLB::ResumeClients(), CProxy_HybridBaseLB::ResumeClients(), CProxyElement_HybridBaseLB::ResumeClients(), CProxy_HbmLB::ResumeClients(), CProxyElement_HbmLB::ResumeClients(), CProxy_CentralLB::ResumeClients(), CProxyElement_CentralLB::ResumeClients(), CProxy_ComlibManager::resumeFromBarrier2(), CProxyElement_ComlibManager::resumeFromBarrier2(), CProxy_CkMulticastMgr::retire(), CProxyElement_CkMulticastMgr::retire(), CProxy_CkMulticastMgr::retrieveCookie(), CProxyElement_CkMulticastMgr::retrieveCookie(), CProxy_CkArray::sendBroadcast(), CProxyElement_CkArray::sendBroadcast(), CProxy_CkArray::sendExpeditedBroadcast(), CProxyElement_CkArray::sendExpeditedBroadcast(), CProxy_CkCheckpointMgr::SendRestartCB(), CProxyElement_CkCheckpointMgr::SendRestartCB(), CProxy_CentralLB::SendStats(), CProxyElement_CentralLB::SendStats(), CProxy_TraceSummaryBOC::sendSummaryBOC(), CProxyElement_TraceSummaryBOC::sendSummaryBOC(), CProxy_FutureBOC::SetFuture(), CProxy_TraceProjectionsBOC::setOutliers(), CProxyElement_TraceProjectionsBOC::setOutliers(), CProxy_FutureBOC::SetSema(), CProxyElement_FutureBOC::SetSema(), CProxy_CkMulticastMgr::setup(), CProxy_TraceProjectionsBOC::shutdownAnalysis(), CProxyElement_TraceProjectionsBOC::shutdownAnalysis(), CProxy_HybridBaseLB::StartCollectInfo(), CProxyElement_HybridBaseLB::StartCollectInfo(), CProxy_TraceProjectionsBOC::startEndTimeAnalysis(), CProxyElement_TraceProjectionsBOC::startEndTimeAnalysis(), CProxy_TraceProjectionsBOC::startOutlierAnalysis(), CProxy_TraceSummaryBOC::startSumOnly(), CProxy_CkMemCheckPT::syncFiles(), CProxyElement_CkMemCheckPT::syncFiles(), CProxy_CkMulticastMgr::teardown(), CProxyElement_CkMulticastMgr::teardown(), CProxy_TempoGroup::tempoGeneric(), CProxy_HybridBaseLB::TotalObjMigrated(), CProxyElement_HybridBaseLB::TotalObjMigrated(), CProxy_BaseLB::unregister(), CProxy_CkLocMgr::updateLocation(), CProxyElement_CkLocMgr::updateLocation(), CProxy_CkMulticastMgr::updateRedNo(), and CProxyElement_CkMulticastMgr::updateRedNo().

void CkNodeGroupMsgPrep ( int  eIdx,
void *  msg,
CkGroupID  gID 
)

Definition at line 1407 of file ck.C.

References _prepareMsgBranch(), and ForNodeBocMsg.

Referenced by CProxy_CkNodeReductionMgr::collectMaxRedNo(), CProxyElement_CkNodeReductionMgr::collectMaxRedNo(), CProxy_CkNodeReductionMgr::DeleteChild(), CProxyElement_CkNodeReductionMgr::DeleteChild(), CProxy_CkNodeReductionMgr::DeleteNewChild(), CProxyElement_CkNodeReductionMgr::DeleteNewChild(), CProxy_CkNodeReductionMgr::modifyTree(), CProxyElement_CkNodeReductionMgr::modifyTree(), CProxy_CkNodeReductionMgr::RecvMsg(), CProxyElement_CkNodeReductionMgr::RecvMsg(), CProxy_CkNodeReductionMgr::ReductionStarting(), CProxy_CkNodeReductionMgr::restartLocalGroupReductions(), CProxyElement_CkNodeReductionMgr::restartLocalGroupReductions(), CProxy_CkArrayReductionMgr::setAttachedGroup(), CProxy_CkNodeReductionMgr::unblockNode(), and CProxyElement_CkNodeReductionMgr::unblockNode().

void CkSetRefNum ( void *  msg,
int  ref 
)

Definition at line 313 of file ck.C.

References envelope::setRef(), and UsrToEnv().

int CkGetRefNum ( void *  msg  ) 

Definition at line 319 of file ck.C.

References envelope::getRef(), and UsrToEnv().

Referenced by CkIndex_waitqd_QDChare::_callthr_waitQD_void().

int CkGetSrcPe ( void *  msg  ) 

Definition at line 325 of file ck.C.

References envelope::getSrcPe(), and UsrToEnv().

Referenced by CkIndex_waitqd_QDChare::_callthr_waitQD_void(), and CkGetSrcNode().

int CkGetSrcNode ( void *  msg  ) 

Definition at line 331 of file ck.C.

References CkGetSrcPe(), and CmiNodeOf().

void CkDeliverMessageFree ( int  epIdx,
void *  msg,
void *  object 
)

Definition at line 390 of file ck.C.

References _entryTable, and CkFreeMsg().

Referenced by _invokeEntryNoTrace(), and CkLocRec_local::invokeEntry().

void CkDeliverMessageReadonly ( int  epIdx,
const void *  msg,
void *  object 
)

Definition at line 398 of file ck.C.

References _entryTable, and CkCopyMsg().

Referenced by MsgPacker::deliver(), and CkLocRec_local::invokeEntry().

void* CkLocalBranch ( CkGroupID  gID  ) 

Definition at line 337 of file ck.C.

References _localBranch().

Referenced by _deliverForBocMsg(), ComlibManager::AtSync(), CpdPythonGroup::buildIterator(), CProxyElement_CkCacheManager::cacheSync(), CkCacheManager::cacheSync(), chpt< StateType >::checkpoint(), CProxy_NodeGroup::ckGetChareID(), CProxy_Group::ckGetChareID(), CkLocMgr::CkLocMgr(), ComlibGetLastKnown(), eventQueue::CommitEvents(), eventQueue::CommitStatsHelper(), LBgroup::computePeLoad(), GVT::GVT(), LBgroup::LBgroup(), LBstrategy::LBstrategy(), ComlibArrayInfo::localBroadcast(), migrationDone(), LBDatabase::Object(), eventMsg::operator delete(), eventMsg::operator new(), sim::pup(), <