ck-core/ck.C File Reference

Go to the source code of this file.

Data Structures
class	ElementDestroyer
class	CkMessageRecorder
class	CkMessageDetailRecorder
class	CkMessageReplay
class	CkMessageDetailReplay
Typedefs
typedef std::map< int, CkChareID >	Vidblockmap
Functions
void	automaticallySetMessagePriority (envelope *env)
	Callable from inside charm++ delivery mechanisms (after envelope contains epIdx):.
	CkpvDeclare (CkVec< void * >, chare_objs)
	CkpvDeclare (CkVec< int >, chare_types)
	CkpvDeclare (CkVec< VidBlock * >, vidblocks)
	CkpvDeclare (Vidblockmap, vmap)
	CkpvDeclare (int, currentChareIdx)
void	_initChareTables ()
	CKSECTIONID_CONSTRUCTOR_DEF (1D)
void	CUDACallbackManager (void *fn)
void	CkSetRefNum (void *msg, CMK_REFNUM_TYPE ref)
CMK_REFNUM_TYPE	CkGetRefNum (void *msg)
int	CkGetSrcPe (void *msg)
int	CkGetSrcNode (void *msg)
void *	CkLocalBranch (CkGroupID gID)
static void *	_ckLocalNodeBranch (CkGroupID groupID)
void *	CkLocalNodeBranch (CkGroupID groupID)
void *	CkLocalChare (const CkChareID *pCid)
	CkpvDeclare (char **, Ck_argv)
char **	CkGetArgv (void)
int	CkGetArgc (void)
void	CkDeliverMessageFree (int epIdx, void *msg, void *obj)
void	CkDeliverMessageReadonly (int epIdx, const void *msg, void *obj)
static void	_invokeEntryNoTrace (int epIdx, envelope *env, void *obj)
static void	_invokeEntry (int epIdx, envelope *env, void *obj)
void	CkCreateChare (int cIdx, int eIdx, void *msg, CkChareID *pCid, int destPE)
void	CkCreateLocalGroup (CkGroupID groupID, int epIdx, envelope *env)
void	CkCreateLocalNodeGroup (CkGroupID groupID, int epIdx, envelope *env)
void	_createGroup (CkGroupID groupID, envelope *env)
void	_createNodeGroup (CkGroupID groupID, envelope *env)
static CkGroupID	_groupCreate (envelope *env)
static CkGroupID	_nodeGroupCreate (envelope *env)
int	_getGroupIdx (int numNodes, int myNode, int numGroups)
CkGroupID	CkCreateGroup (int cIdx, int eIdx, void *msg)
CkGroupID	CkCreateNodeGroup (int cIdx, int eIdx, void *msg)
static void *	_allocNewChare (envelope *env, int &idx)
static void	_processNewChareMsg (CkCoreState *ck, envelope *env)
void	CkCreateLocalChare (int epIdx, envelope *env)
static void	_processNewVChareMsg (CkCoreState *ck, envelope *env)
static void	_processForPlainChareMsg (CkCoreState *ck, envelope *env)
static void	_processForChareMsg (CkCoreState *ck, envelope *env)
static void	_processFillVidMsg (CkCoreState *ck, envelope *env)
static void	_processForVidMsg (CkCoreState *ck, envelope *env)
static void	_processDeleteVidMsg (CkCoreState *ck, envelope *env)
static IrrGroup *	_lookupGroupAndBufferIfNotThere (CkCoreState *ck, envelope *env, const CkGroupID &groupID)
	Return a pointer to the local BOC of "groupID".
IrrGroup *	lookupGroupAndBufferIfNotThere (CkCoreState *ck, envelope *env, const CkGroupID &groupID)
static void	_deliverForBocMsg (CkCoreState *ck, int epIdx, envelope *env, IrrGroup *obj)
static void	_processForBocMsg (CkCoreState *ck, envelope *env)
static void	_deliverForNodeBocMsg (CkCoreState *ck, envelope *env, void *obj)
static void	_deliverForNodeBocMsg (CkCoreState *ck, int epIdx, envelope *env, void *obj)
static void	_processForNodeBocMsg (CkCoreState *ck, envelope *env)
void	_processBocInitMsg (CkCoreState *ck, envelope *env)
void	_processNodeBocInitMsg (CkCoreState *ck, envelope *env)
static void	_processArrayEltInitMsg (CkCoreState *ck, envelope *env)
static void	_processArrayEltMsg (CkCoreState *ck, envelope *env)
void	_processHandler (void *converseMsg, CkCoreState *ck)
void	_infoFn (void *converseMsg, CldPackFn *pfn, int *len, int *queueing, int *priobits, unsigned int **prioptr)
void	CkPackMessage (envelope **pEnv)
void	CkUnpackMessage (envelope **pEnv)
void	_skipCldHandler (void *converseMsg)
void	_skipCldEnqueue (int pe, envelope *env, int infoFn)
static void	_noCldEnqueueMulti (int npes, int *pes, envelope *env)
static void	_noCldEnqueue (int pe, envelope *env)
void	_noCldNodeEnqueue (int node, envelope *env)
static int	_prepareMsg (int eIdx, void *msg, const CkChareID *pCid)
static int	_prepareImmediateMsg (int eIdx, void *msg, const CkChareID *pCid)
void	CkSendMsg (int entryIdx, void *msg, const CkChareID *pCid, int opts)
void	CkSendMsgInline (int entryIndex, void *msg, const CkChareID *pCid, int opts)
static envelope *	_prepareMsgBranch (int eIdx, void *msg, CkGroupID gID, int type)
static envelope *	_prepareImmediateMsgBranch (int eIdx, void *msg, CkGroupID gID, int type)
static void	_sendMsgBranch (int eIdx, void *msg, CkGroupID gID, int pe=CLD_BROADCAST_ALL, int opts=0)
static void	_sendMsgBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *pes)
void	CkSendMsgBranchImmediate (int eIdx, void *msg, int destPE, CkGroupID gID)
void	CkSendMsgBranchInline (int eIdx, void *msg, int destPE, CkGroupID gID, int opts)
void	CkSendMsgBranch (int eIdx, void *msg, int pe, CkGroupID gID, int opts)
void	CkSendMsgBranchMultiImmediate (int eIdx, void *msg, CkGroupID gID, int npes, int *pes)
void	CkSendMsgBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *pes, int opts)
void	CkSendMsgBranchGroup (int eIdx, void *msg, CkGroupID gID, CmiGroup grp, int opts)
void	CkBroadcastMsgBranch (int eIdx, void *msg, CkGroupID gID, int opts)
static void	_sendMsgNodeBranch (int eIdx, void *msg, CkGroupID gID, int node=CLD_BROADCAST_ALL, int opts=0)
static void	_sendMsgNodeBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *nodes)
void	CkSendMsgNodeBranchImmediate (int eIdx, void *msg, int node, CkGroupID gID)
void	CkSendMsgNodeBranchInline (int eIdx, void *msg, int node, CkGroupID gID, int opts)
void	CkSendMsgNodeBranch (int eIdx, void *msg, int node, CkGroupID gID, int opts)
void	CkSendMsgNodeBranchMultiImmediate (int eIdx, void *msg, CkGroupID gID, int npes, int *nodes)
void	CkSendMsgNodeBranchMulti (int eIdx, void *msg, CkGroupID gID, int npes, int *nodes, int opts)
void	CkBroadcastMsgNodeBranch (int eIdx, void *msg, CkGroupID gID, int opts)
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	_ckModuleInit (void)
void	CkArrayManagerInsert (int onPe, void *msg)
static void	_prepareOutgoingArrayMsg (envelope *env, int type)
void	CkArrayManagerInsert (int pe, void *msg, CkGroupID aID)
void	CkArrayManagerDeliver (int pe, void *msg, int opts)
void	CkDeleteChares ()
	CkpvDeclare (int, envelopeEventID)
static FILE *	openReplayFile (const char *prefix, const char *suffix, const char *permissions)
void	CkMessageReplayQuiescence (void *rep, double time)
void	CkMessageDetailReplayDone (void *rep, double time)
void	CthEnqueueBigSimThread (CthThreadToken *token, int s, int pb, unsigned int *prio)
static CmiBool	CpdExecuteThreadResume (CthThreadToken *token)
	CpvCExtern (int, CthResumeNormalThreadIdx)
void	CthResumeNormalThreadDebug (CthThreadToken *token)
void	CpdHandleLBMessage (LBMigrateMsg **msg)
	CpvExtern (int, CthResumeBigSimThreadIdx)
void	CkMessageWatcherInit (char **argv, CkCoreState *ck)
int	CkMessageToEpIdx (void *msg)
int	getCharmEnvelopeSize ()
int	isCharmEnvelope (void *msg)
Variables
int	_defaultObjectQ
static int	index_objectQHandler
int	index_tokenHandler
int	index_skipCldHandler
int	_recplay_crc = 0
int	_recplay_checksum = 0
int	_recplay_logsize = 1024*1024

---

Typedef Documentation

typedef std::map<int, CkChareID> Vidblockmap

Definition at line 28 of file ck.C.

---

Function Documentation

CkpvDeclare	(	CkVec< void * >	,
		chare_objs
	)

CkpvDeclare	(	CkVec< int >	,
		chare_types
	)

CkpvDeclare	(	CkVec< VidBlock * >	,
		vidblocks
	)

CkpvDeclare	(	Vidblockmap	,
		vmap
	)

CkpvDeclare	(	int	,
		currentChareIdx
	)

CKSECTIONID_CONSTRUCTOR_DEF

(

1D

)

Definition at line 406 of file ck.C.

void CUDACallbackManager

(

void *

fn

)

Definition at line 470 of file ck.C.

References CkCallback::send().

static void* _ckLocalNodeBranch

(

CkGroupID

groupID

)

[static]

Definition at line 509 of file ck.C.

Referenced by CkLocalNodeBranch().

CkpvDeclare	(	char **	,
		Ck_argv
	)

char** CkGetArgv

(

void

)

Definition at line 558 of file ck.C.

Referenced by _loadbalancerInit(), AMPI_Init(), ampiProcInit(), armciLibStart(), CtgInit(), FEM_Init(), FTN_NAME(), ConfigurableRRMapLoader::haveConfiguration(), LV3D0_ProcInit(), POSEreadCmdLine(), TCharm::procInit(), PUPfunctionpointer(), and TCHARM_Get_num_chunks().

int CkGetArgc

(

void

)

Definition at line 561 of file ck.C.

References CmiGetArgc().

Referenced by armciLibStart(), FTN_NAME(), and PUPfunctionpointer().

static void _invokeEntryNoTrace	(	int	epIdx,
		envelope *	env,
		void *	obj
	)			[inline, static]

Definition at line 618 of file ck.C.

References CkDeliverMessageFree(), and EnvToUsr().

Referenced by _invokeEntry(), CkCreateLocalGroup(), CkCreateLocalNodeGroup(), and CkSendMsgInline().

static void _invokeEntry	(	int	epIdx,
		envelope *	env,
		void *	obj
	)			[inline, static]

Definition at line 625 of file ck.C.

References _entryTable, and _invokeEntryNoTrace().

Referenced by _deliverForBocMsg(), _processForChareMsg(), _processForPlainChareMsg(), _processNewChareMsg(), and _processNewVChareMsg().

void _createGroup	(	CkGroupID	groupID,
		envelope *	env
	)

Definition at line 750 of file ck.C.

References _bocHandlerIdx, _chareTable, _entryTable, _numInitMsgs, CkCreateLocalGroup(), Converse::CkMyPe(), Converse::CkNumPes(), CkPackMessage(), CkUnpackMessage(), Converse::CmiSyncBroadcast(), envelope::getEpIdx(), envelope::getTotalsize(), envelope::setGroupEpoch(), envelope::setGroupNum(), envelope::setRednMgr(), envelope::setSrcPe(), and _ckGroupID::setZero().

Referenced by _groupCreate().

void _createNodeGroup	(	CkGroupID	groupID,
		envelope *	env
	)

Definition at line 781 of file ck.C.

References _bocHandlerIdx, _numInitMsgs, CkCreateLocalNodeGroup(), Converse::CkMyPe(), BGConverse::CkNumNodes(), CkPackMessage(), CkUnpackMessage(), envelope::getEpIdx(), envelope::getTotalsize(), envelope::setGroupEpoch(), envelope::setGroupNum(), and envelope::setSrcPe().

Referenced by _nodeGroupCreate().

static CkGroupID _groupCreate

(

envelope *

env

)

[static]

Definition at line 804 of file ck.C.

References _createGroup(), _getGroupIdx(), Converse::CkMyPe(), Converse::CkNumPes(), and _ckGroupID::idx.

Referenced by CkCreateGroup().

static CkGroupID _nodeGroupCreate

(

envelope *

env

)

[static]

Definition at line 819 of file ck.C.

References _createNodeGroup(), _getGroupIdx(), BGConverse::CkMyNode(), BGConverse::CkNumNodes(), and _ckGroupID::idx.

Referenced by CkCreateNodeGroup().

int _getGroupIdx	(	int	numNodes,
		int	myNode,
		int	numGroups
	)

Definition at line 837 of file ck.C.

References idx, and n.

Referenced by _groupCreate(), and _nodeGroupCreate().

static void* _allocNewChare	(	envelope *	env,
		int &	idx
	)			[inline, static]

Definition at line 879 of file ck.C.

References _chareTable, _entryTable, envelope::getEpIdx(), malloc(), setMemoryTypeChare(), and size.

Referenced by _processNewChareMsg(), and _processNewVChareMsg().

static void _processNewChareMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[static]

Definition at line 893 of file ck.C.

References _allocNewChare(), _invokeEntry(), envelope::getEpIdx(), and idx.

Referenced by _processHandler(), and CkCreateLocalChare().

void CkCreateLocalChare	(	int	epIdx,
		envelope *	env
	)

Definition at line 904 of file ck.C.

References _processNewChareMsg(), and envelope::setEpIdx().

Referenced by CkPupChareData().

static void _processNewVChareMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[static]

Definition at line 910 of file ck.C.

References _allocMsg(), _allocNewChare(), _charmHandlerIdx, _invokeEntry(), Converse::CkMyPe(), Converse::CmiSyncSendAndFree(), FillVidMsg, envelope::getByPe(), envelope::getEpIdx(), envelope::getTotalsize(), envelope::getVidPtr(), idx, CkChareID::objPtr, CkChareID::onPE, envelope::setSrcPe(), envelope::setVidPtr(), and UsrToEnv().

Referenced by _processHandler().

static void _processForPlainChareMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 946 of file ck.C.

References _chareTable, _entryTable, _invokeEntry(), _mainTable, Converse::CkMyPe(), envelope::getEpIdx(), envelope::getObjPtr(), and TypeChare.

Referenced by _processHandler().

static void _processForChareMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 968 of file ck.C.

References _invokeEntry(), envelope::getEpIdx(), and envelope::getObjPtr().

Referenced by _deliverForNodeBocMsg(), and _processForNodeBocMsg().

static void _processFillVidMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 975 of file ck.C.

References CmiFree(), EnvToUsr(), VidBlock::fill(), envelope::getVidPtr(), CkChareID::objPtr, and CkChareID::onPE.

Referenced by _processHandler().

static void _processForVidMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 989 of file ck.C.

References envelope::getVidPtr(), and VidBlock::send().

Referenced by _processHandler().

static void _processDeleteVidMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 1001 of file ck.C.

References CmiFree(), and envelope::getVidPtr().

Referenced by _processHandler().

static IrrGroup* _lookupGroupAndBufferIfNotThere	(	CkCoreState *	ck,
		envelope *	env,
		const CkGroupID &	groupID
	)			[inline, static]

Return a pointer to the local BOC of "groupID".

The message "env" passed in has some known dependency on this groupID (either it is to be delivered to this BOC, or it depends on this BOC being there). Therefore, if the return value is NULL, this function buffers the massage so that it will be re-sent (by CkCreateLocalBranch) when this groupID is eventually constructed. The message passed in must have its handlers correctly set so that it can be scheduled again.

Definition at line 1022 of file ck.C.

References GroupIdxArray< dtype >::find(), CkCoreState::getGroupTable(), CkCoreState::localBranch(), and CkCoreState::process().

Referenced by _processArrayEltInitMsg(), _processArrayEltMsg(), _processBocInitMsg(), _processForBocMsg(), and lookupGroupAndBufferIfNotThere().

IrrGroup* lookupGroupAndBufferIfNotThere	(	CkCoreState *	ck,
		envelope *	env,
		const CkGroupID &	groupID
	)

Definition at line 1037 of file ck.C.

References _lookupGroupAndBufferIfNotThere().

Referenced by CProxy_ArrayBase::ckInsertIdx().

static void _deliverForBocMsg	(	CkCoreState *	ck,
		int	epIdx,
		envelope *	env,
		IrrGroup *	obj
	)			[inline, static]

Definition at line 1042 of file ck.C.

References _invokeEntry(), _lbdb, CkLocalBranch(), LBDatabase::ObjectStart(), LBDatabase::ObjectStop(), and LBDatabase::RunningObject().

Referenced by _processForBocMsg(), and CkSendMsgBranchInline().

static void _processForBocMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 1061 of file ck.C.

References _deliverForBocMsg(), _lookupGroupAndBufferIfNotThere(), envelope::getEpIdx(), and envelope::getGroupNum().

Referenced by _processHandler().

static void _deliverForNodeBocMsg	(	CkCoreState *	ck,
		envelope *	env,
		void *	obj
	)			[inline, static]

Definition at line 1070 of file ck.C.

References _processForChareMsg(), ForChareMsg, envelope::setMsgtype(), and envelope::setObjPtr().

Referenced by _deliverForNodeBocMsg(), and CkSendMsgNodeBranchInline().

static void _deliverForNodeBocMsg	(	CkCoreState *	ck,
		int	epIdx,
		envelope *	env,
		void *	obj
	)			[inline, static]

Definition at line 1078 of file ck.C.

References _deliverForNodeBocMsg(), and envelope::setEpIdx().

static void _processForNodeBocMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[inline, static]

Definition at line 1084 of file ck.C.

References _processForChareMsg(), CmiDelayImmediate(), ForChareMsg, envelope::getGroupNum(), CkCoreState::process(), envelope::setMsgtype(), and envelope::setObjPtr().

Referenced by _processHandler().

void _processBocInitMsg	(	CkCoreState *	ck,
		envelope *	env
	)

Definition at line 1112 of file ck.C.

References _lookupGroupAndBufferIfNotThere(), CkCreateLocalGroup(), envelope::getEpIdx(), envelope::getGroupDep(), envelope::getGroupNum(), _ckGroupID::isZero(), and CkCoreState::process().

Referenced by _processBufferedBocInits(), and _processHandler().

void _processNodeBocInitMsg	(	CkCoreState *	ck,
		envelope *	env
	)

Definition at line 1126 of file ck.C.

References CkCreateLocalNodeGroup(), envelope::getEpIdx(), and envelope::getGroupNum().

Referenced by _processBufferedNodeBocInits(), and _processHandler().

static void _processArrayEltInitMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[static]

Definition at line 1135 of file ck.C.

References _lookupGroupAndBufferIfNotThere(), EnvToUsr(), envelope::getsetArrayMgr(), and CkArray::insertElement().

Referenced by _processHandler().

static void _processArrayEltMsg	(	CkCoreState *	ck,
		envelope *	env
	)			[static]

Definition at line 1142 of file ck.C.

References _lookupGroupAndBufferIfNotThere(), CkLocMgr::deliverInline(), EnvToUsr(), CkArray::getLocMgr(), and envelope::getsetArrayMgr().

Referenced by _processHandler().

void _processHandler	(	void *	converseMsg,
		CkCoreState *	ck
	)

Definition at line 1158 of file ck.C.

References _processArrayEltInitMsg(), _processArrayEltMsg(), _processBocInitMsg(), _processDeleteVidMsg(), _processFillVidMsg(), _processForBocMsg(), _processForNodeBocMsg(), _processForPlainChareMsg(), _processForVidMsg(), _processNewChareMsg(), _processNewVChareMsg(), _processNodeBocInitMsg(), ArrayEltInitMsg, BocInitMsg, Converse::CkMyPe(), CkUnpackMessage(), CmiAbort(), criticalPath_end(), criticalPath_start(), DeleteVidMsg, FillVidMsg, ForArrayEltMsg, ForBocMsg, ForChareMsg, ForNodeBocMsg, ForVidMsg, envelope::getMsgtype(), envelope::isPacked(), NewChareMsg, NewVChareMsg, NodeBocInitMsg, postProcessReceivedMessage(), preProcessReceivedMessage(), CkCoreState::process(), envelope::sender, envelope::SN, and CkCoreState::watcher.

Referenced by _initCharm(), _processBufferedBocInits(), _processBufferedMsgs(), _resume_charm_message(), and traceCommonInit().

void _infoFn	(	void *	converseMsg,
		CldPackFn *	pfn,
		int *	len,
		int *	queueing,
		int *	priobits,
		unsigned int **	prioptr
	)

Definition at line 1288 of file ck.C.

References CkPackMessage(), envelope::getPriobits(), envelope::getPrioPtr(), envelope::getQueueing(), and envelope::getTotalsize().

Referenced by _initCharm().

void CkPackMessage

(

envelope **

pEnv

)

Definition at line 1299 of file ck.C.

References _msgTable, EnvToUsr(), envelope::getMsgIdx(), envelope::isPacked(), envelope::setPacked(), and UsrToEnv().

Referenced by _createGroup(), _createNodeGroup(), _infoFn(), _initCharm(), _noCldEnqueue(), _noCldEnqueueMulti(), _noCldNodeEnqueue(), _skipCldEnqueue(), ComlibManager::ArraySectionSend(), ComlibManager::ArraySend(), CkPupMessage(), RectMulticastStrategy::forwardMulticast(), ComlibSectionInfo::getNewMulticastMessage(), ComlibManager::GroupBroadcast(), ComlibManager::GroupSend(), RectMulticastStrategy::handleNewMulticastMessage(), RectMulticastStrategy::insertMessage(), MulticastStrategy::insertMessage(), ChunkMulticastStrategy::insertMessage(), BroadcastStrategy::insertMessage(), CkMemCheckPT::isMaster(), CkMessageReplay::isNext(), ComlibManager::multicast(), CkMessageReplay::process(), CkMessageDetailRecorder::process(), CkMessageRecorder::process(), RectMulticastStrategy::remoteMulticast(), OneTimeMulticastStrategy::remoteMulticast(), MulticastStrategy::remoteMulticast(), ChunkMulticastStrategy::remoteMulticast(), sendMlogLocation(), RectMulticastStrategy::sendRectDest(), and CkMulticastMgr::sendToSection().

void CkUnpackMessage

(

envelope **

pEnv

)

Definition at line 1313 of file ck.C.

References _msgTable, EnvToUsr(), envelope::getMsgIdx(), envelope::isPacked(), envelope::setPacked(), and UsrToEnv().

Referenced by _createGroup(), _createNodeGroup(), _initCharm(), _initHandler(), _processBufferedBocInits(), _processBufferedNodeBocInits(), _processHandler(), _receiveMlogLocationHandler(), CkPupMessage(), CkSendMsgInline(), PipeBroadcastStrategy::deliver(), EachToManyMulticastStrategy::deliver(), ComlibArrayInfo::deliver(), CharmStrategy::deliverToIndices(), OneTimeMulticastStrategy::handleMessage(), ChunkMulticastStrategy::handleMessage(), RectMulticastStrategy::handleNewMulticastMessage(), MulticastStrategy::handleNewMulticastMessage(), ChunkMulticastStrategy::insertMessage(), CkMemCheckPT::isMaster(), CkMessageReplay::isNext(), EachToManyMulticastStrategy::localMulticast(), ComlibArrayInfo::localMulticast(), CkMessageReplay::process(), CkMessageDetailRecorder::process(), CkMessageRecorder::process(), CpdList_localQ::pup(), CpdList_localQ::pupSingleMessage(), recv_array_msg(), CkMulticastMgr::recvPacket(), CkMulticastMgr::sendToSection(), and CkDiskCheckPTInfo::updateBuffer().

void _skipCldEnqueue	(	int	pe,
		envelope *	env,
		int	infoFn
	)

Definition at line 1361 of file ck.C.

References _enqObjQueue(), CkFindObjectPtr(), Chare::CkGetObjQueue(), Converse::CkMyPe(), CkPackMessage(), CmiFree(), CmiNodeOf(), CmiPersistentOneSend(), Converse::CmiSyncBroadcast(), Converse::CmiSyncBroadcastAll(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncBroadcastAndFree(), Converse::CmiSyncSend(), Converse::CmiSyncSendAndFree(), ConverseDeliver(), CqsEnqueueGeneral(), envelope::getPriobits(), envelope::getPrioPtr(), envelope::getQueueing(), envelope::getTotalsize(), printf(), and CkObjectMsgQ::queue().

Referenced by _localMessageAckHandler(), _sendMsgBranch(), CkArrayManagerDeliver(), generalCldEnqueue(), and sendLocalMsg().

static void _noCldEnqueueMulti	(	int	npes,
		int *	pes,
		envelope *	env
	)			[static]

Definition at line 1432 of file ck.C.

References CkPackMessage(), CmiFree(), Converse::CmiSyncListSendAndFree(), ConverseDeliver(), and envelope::getTotalsize().

Referenced by CkSendMsgBranchMultiImmediate(), and CkSendMsgNodeBranchMultiImmediate().

static void _noCldEnqueue	(	int	pe,
		envelope *	env
	)			[static]

Definition at line 1445 of file ck.C.

References CkPackMessage(), CmiFree(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncBroadcastAndFree(), Converse::CmiSyncSendAndFree(), ConverseDeliver(), and envelope::getTotalsize().

Referenced by _sendMsgBranch(), CkArrayManagerDeliver(), CkSendMsg(), and CkSendMsgBranchImmediate().

void _noCldNodeEnqueue	(	int	node,
		envelope *	env
	)

Definition at line 1467 of file ck.C.

References CkPackMessage(), CmiFree(), ConverseDeliver(), and envelope::getTotalsize().

Referenced by _sendMsgNodeBranch(), CkSendMsgNodeBranchImmediate(), and generalCldEnqueue().

static int _prepareMsg	(	int	eIdx,
		void *	msg,
		const CkChareID *	pCid
	)			[inline, static]

Definition at line 1506 of file ck.C.

References _charmHandlerIdx, automaticallySetMessagePriority(), Converse::CkMyPe(), criticalPath_send(), ForChareMsg, ForVidMsg, VidBlock::getLocalChare(), CkChareID::objPtr, CkChareID::onPE, VidBlock::send(), envelope::setEpIdx(), setEventID(), setMemoryOwnedBy(), envelope::setMsgtype(), envelope::setSrcPe(), and UsrToEnv().

Referenced by _prepareImmediateMsg(), CkChareMsgPrep(), CkSendMsg(), and CkSendMsgInline().

static int _prepareImmediateMsg	(	int	eIdx,
		void *	msg,
		const CkChareID *	pCid
	)			[inline, static]

Definition at line 1559 of file ck.C.

References _prepareMsg(), automaticallySetMessagePriority(), criticalPath_send(), and UsrToEnv().

static envelope* _prepareMsgBranch	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	type
	)			[inline, static]

Definition at line 1630 of file ck.C.

References _charmHandlerIdx, automaticallySetMessagePriority(), Converse::CkMyPe(), criticalPath_send(), envelope::setEpIdx(), setEventID(), envelope::setGroupNum(), setMemoryOwnedBy(), envelope::setMsgtype(), envelope::setRednMgr(), envelope::setSrcPe(), _ckGroupID::setZero(), and UsrToEnv().

Referenced by _prepareImmediateMsgBranch(), _sendMsgBranch(), _sendMsgBranchMulti(), _sendMsgNodeBranch(), _sendMsgNodeBranchMulti(), CkGroupMsgPrep(), CkNodeGroupMsgPrep(), CkSendMsgBranchGroup(), CkSendMsgBranchInline(), and CkSendMsgNodeBranchInline().

static envelope* _prepareImmediateMsgBranch	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	type
	)			[inline, static]

Definition at line 1660 of file ck.C.

References _prepareMsgBranch(), automaticallySetMessagePriority(), and criticalPath_send().

Referenced by CkSendMsgBranchImmediate(), CkSendMsgBranchMultiImmediate(), CkSendMsgNodeBranchImmediate(), and CkSendMsgNodeBranchMultiImmediate().

static void _sendMsgBranch	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	pe = CLD_BROADCAST_ALL,
		int	opts = 0
	)			[inline, static]

Definition at line 1671 of file ck.C.

References _infoIdx, _noCldEnqueue(), _prepareMsgBranch(), _skipCldEnqueue(), Converse::CkNumPes(), ForBocMsg, opts, sendGroupMsg(), and sendTicketGroupRequest().

Referenced by CkBroadcastMsgBranch(), and CkSendMsgBranch().

static void _sendMsgBranchMulti	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	npes,
		int *	pes
	)			[inline, static]

Definition at line 1691 of file ck.C.

References _CldEnqueueMulti(), _infoIdx, _prepareMsgBranch(), and ForBocMsg.

Referenced by CkSendMsgBranchMulti(), and CkSendMsgBranchMultiImmediate().

void CkSendMsgBranchImmediate	(	int	eIdx,
		void *	msg,
		int	destPE,
		CkGroupID	gID
	)

Definition at line 1701 of file ck.C.

References _noCldEnqueue(), _prepareImmediateMsgBranch(), Converse::CkMyPe(), Converse::CkNumPes(), CkSendMsgBranchInline(), ForBocMsg, and UsrToEnv().

Referenced by CkSendMsgBranch().

void CkSendMsgBranchMultiImmediate	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	npes,
		int *	pes
	)

Definition at line 1766 of file ck.C.

References _noCldEnqueueMulti(), _prepareImmediateMsgBranch(), _sendMsgBranchMulti(), and ForBocMsg.

Referenced by CkSendMsgBranchMulti().

static void _sendMsgNodeBranch	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	node = CLD_BROADCAST_ALL,
		int	opts = 0
	)			[inline, static]

Definition at line 1821 of file ck.C.

References _CldNodeEnqueue(), _infoIdx, _noCldNodeEnqueue(), _prepareMsgBranch(), BGConverse::CkNumNodes(), ForNodeBocMsg, opts, sendNodeGroupMsg(), and sendTicketNodeGroupRequest().

Referenced by CkBroadcastMsgNodeBranch(), and CkSendMsgNodeBranch().

static void _sendMsgNodeBranchMulti	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	npes,
		int *	nodes
	)			[inline, static]

Definition at line 1845 of file ck.C.

References _CldNodeEnqueue(), _infoIdx, _prepareMsgBranch(), and ForNodeBocMsg.

Referenced by CkSendMsgNodeBranchMulti(), and CkSendMsgNodeBranchMultiImmediate().

void CkSendMsgNodeBranchImmediate	(	int	eIdx,
		void *	msg,
		int	node,
		CkGroupID	gID
	)

Definition at line 1857 of file ck.C.

References _noCldNodeEnqueue(), _prepareImmediateMsgBranch(), BGConverse::CkMyNode(), BGConverse::CkNumNodes(), CkSendMsgNodeBranchInline(), ForNodeBocMsg, and UsrToEnv().

Referenced by CkSendMsgNodeBranch().

void CkSendMsgNodeBranchMultiImmediate	(	int	eIdx,
		void *	msg,
		CkGroupID	gID,
		int	npes,
		int *	nodes
	)

Definition at line 1922 of file ck.C.

References _noCldEnqueueMulti(), _prepareImmediateMsgBranch(), _sendMsgNodeBranchMulti(), and ForNodeBocMsg.

Referenced by CkSendMsgNodeBranchMulti().

void CkArrayManagerInsert	(	int	onPe,
		void *	msg
	)

static void _prepareOutgoingArrayMsg	(	envelope *	env,
		int	type
	)			[static]

Definition at line 1983 of file ck.C.

References _charmHandlerIdx, setMemoryOwnedBy(), and envelope::setMsgtype().

Referenced by CkArrayManagerDeliver(), and CkArrayManagerInsert().

void CkDeleteChares

(

)

Definition at line 2031 of file ck.C.

References BGConverse::CkMyRank(), IrrGroup::isLocMgr(), and CkLocMgr::iterate().

CkpvDeclare	(	int	,
		envelopeEventID
	)

static FILE* openReplayFile	(	const char *	prefix,
		const char *	suffix,
		const char *	permissions
	)			[static]

Definition at line 2095 of file ck.C.

References Converse::CkMyPe(), and CkMessageWatcher::f.

Referenced by CkMessageWatcherInit(), CkMessageReplay::process(), and CkMessageRecorder::process().

void CkMessageReplayQuiescence	(	void *	rep,
		double	time
	)

Definition at line 2450 of file ck.C.

References Converse::CkMyPe().

Referenced by CkMessageReplay::CkMessageReplay().

void CkMessageDetailReplayDone	(	void *	rep,
		double	time
	)

Definition at line 2458 of file ck.C.

References Converse::CkMyPe(), ConverseExit(), and CkMessageDetailReplay::starttime.

Referenced by CkMessageDetailReplay::CkMessageDetailReplay().

void CthEnqueueBigSimThread	(	CthThreadToken *	token,
		int	s,
		int	pb,
		unsigned int *	prio
	)

Referenced by CkMessageReplay::flush().

static CmiBool CpdExecuteThreadResume

(

CthThreadToken *

token

)

[static]

Definition at line 2464 of file ck.C.

References CmiTrue, and CkCoreState::watcher.

Referenced by CthResumeNormalThreadDebug().

CpvCExtern	(	int	,
		CthResumeNormalThreadIdx
	)

void CthResumeNormalThreadDebug

(

CthThreadToken *

token

)

Definition at line 2473 of file ck.C.

References CpdExecuteThreadResume(), CthResume(), CthTraceResume(), free(), and CthThreadToken::thread.

Referenced by CkMessageWatcherInit().

void CpdHandleLBMessage

(

LBMigrateMsg **

msg

)

Definition at line 2496 of file ck.C.

References CkCoreState::watcher.

Referenced by CentralLB::LoadBalance().

CpvExtern	(	int	,
		CthResumeBigSimThreadIdx
	)

Referenced by KillOnAllSigs().

void CkMessageWatcherInit	(	char **	argv,
		CkCoreState *	ck
	)

Definition at line 2508 of file ck.C.

References _Cmi_mype, _Cmi_numpes, _replaySystem, CkCoreState::addWatcher(), Converse::CkMyPe(), CmiAbort(), CmiArgGroup(), CmiFalse, CmiGetArgFlagDesc(), CmiGetArgIntDesc(), CmiGetArgStringDesc(), CmiMemoryIs(), CmiNumberHandler(), CmiPrintf(), CmiTrue, CpdSetInitializeMemory(), CthResumeNormalThreadDebug(), CkListString::includes(), list, and openReplayFile().

Referenced by _initCharm().

int CkMessageToEpIdx

(

void *

msg

)

Definition at line 2578 of file ck.C.

References envelope::getEpIdx(), envelope::getsetArrayBcastEp(), and UsrToEnv().

Referenced by _call_freeze_on_break_point(), and CpdPupMessage().

int getCharmEnvelopeSize

(

)

Definition at line 2588 of file ck.C.

Referenced by cpd_memory_single_pup().

int isCharmEnvelope

(

void *

msg

)

Definition at line 2593 of file ck.C.

References _entryTable, BGConverse::CkNumNodes(), Converse::CkNumPes(), envelope::getEpIdx(), envelope::getMsgtype(), envelope::getSrcPe(), envelope::getTotalsize(), and LAST_CK_ENVELOPE_TYPE.

Referenced by traceCommonInit().

---

Variable Documentation

int index_objectQHandler [static]

Definition at line 1332 of file ck.C.

int index_tokenHandler

Definition at line 1334 of file ck.C.

int _recplay_crc = 0

Definition at line 2084 of file ck.C.

int _recplay_checksum = 0

Definition at line 2085 of file ck.C.

int _recplay_logsize = 1024*1024

Definition at line 2086 of file ck.C.