ck-core/ck.h File Reference

Go to the source code of this file.

Data Structures
class	VidBlock
	A set of "Virtual ChareID"'s. More...
class	CkMessageWatcher
	Message watcher: for record/replay support. More...
class	CkCoreState
	All the state that's useful to have on the receive side in the Charm Core (ck.C). More...
Functions
int	ConverseDeliver (int pe)
void	_CldEnqueue (int pe, void *msg, int infofn)
void	_CldEnqueueMulti (int npes, int *pes, void *msg, int infofn)
void	_CldEnqueueGroup (CmiGroup grp, void *msg, int infofn)
void	_CldNodeEnqueue (int node, void *msg, int infofn)
	CkpvExtern (CkVec< void * >, chare_objs)
	CkpvExtern (CkCoreState *, _coreState)
void	CpdHandleLBMessage (LBMigrateMsg **msg)
void	CkMessageWatcherInit (char **argv, CkCoreState *ck)
void	_processHandler (void *converseMsg, CkCoreState *ck)
void	_processBocInitMsg (CkCoreState *ck, envelope *msg)
void	_processNodeBocInitMsg (CkCoreState *ck, envelope *msg)
void	_infoFn (void *msg, CldPackFn *pfn, int *len, int *queueing, int *priobits, UInt **prioptr)
void	CkCreateLocalGroup (CkGroupID groupID, int eIdx, envelope *env)
void	CkCreateLocalNodeGroup (CkGroupID groupID, int eIdx, envelope *env)
void	_createGroup (CkGroupID groupID, envelope *env)
void	_createNodeGroup (CkGroupID groupID, envelope *env)
int	_getGroupIdx (int, int, int)
Variables
int	_replaySystem

---

Function Documentation

int ConverseDeliver

(

int

pe

)

Definition at line 30 of file debug-conv.c.

Referenced by _CldEnqueue(), _CldEnqueueGroup(), _CldEnqueueMulti(), _CldNodeEnqueue(), _noCldEnqueue(), _noCldEnqueueMulti(), _noCldNodeEnqueue(), _skipCldEnqueue(), Converse::CmiSyncBroadcast(), Converse::CmiSyncBroadcastAll(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncBroadcastAndFree(), Converse::CmiSyncListSend(), Converse::CmiSyncListSendAndFree(), Converse::CmiSyncMulticast(), Converse::CmiSyncMulticastAndFree(), Converse::CmiSyncSend(), and Converse::CmiSyncSendAndFree().

void _CldEnqueue	(	int	pe,
		void *	msg,
		int	infofn
	)			[inline]

Definition at line 27 of file ck.h.

References CldEnqueue(), CmiFree(), and ConverseDeliver().

Referenced by _processBufferedMsgs(), CkArrayManagerInsert(), CkCreateChare(), CkCreateLocalGroup(), CkSendMsg(), CkStartQD(), and VidBlock::msgDeliver().

void _CldEnqueueMulti	(	int	npes,
		int *	pes,
		void *	msg,
		int	infofn
	)			[inline]

Definition at line 34 of file ck.h.

References CldEnqueueMulti(), CmiFree(), and ConverseDeliver().

Referenced by _sendMsgBranchMulti().

void _CldEnqueueGroup	(	CmiGroup	grp,
		void *	msg,
		int	infofn
	)			[inline]

Definition at line 41 of file ck.h.

References CldEnqueueGroup(), CmiFree(), and ConverseDeliver().

Referenced by CkSendMsgBranchGroup().

void _CldNodeEnqueue	(	int	node,
		void *	msg,
		int	infofn
	)			[inline]

Definition at line 48 of file ck.h.

References CldNodeEnqueue(), CmiFree(), and ConverseDeliver().

Referenced by _sendMsgNodeBranch(), _sendMsgNodeBranchMulti(), and CkCreateLocalNodeGroup().

CkpvExtern	(	CkVec< void * >	,
		chare_objs
	)

CkpvExtern	(	CkCoreState *	,
		_coreState
	)

void CpdHandleLBMessage

(

LBMigrateMsg **

msg

)

Definition at line 2496 of file ck.C.

References CkCoreState::watcher.

Referenced by CentralLB::LoadBalance().

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().

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 _processBocInitMsg	(	CkCoreState *	ck,
		envelope *	msg
	)

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 *	msg
	)

Definition at line 1126 of file ck.C.

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

Referenced by _processBufferedNodeBocInits(), and _processHandler().

void _infoFn	(	void *	msg,
		CldPackFn *	pfn,
		int *	len,
		int *	queueing,
		int *	priobits,
		UInt **	prioptr
	)

Definition at line 1288 of file ck.C.

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

Referenced by _initCharm().

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().

int _getGroupIdx	(	int	,
		int	,
		int
	)

Definition at line 837 of file ck.C.

References idx, and n.

Referenced by _groupCreate(), and _nodeGroupCreate().

---

Variable Documentation

int _replaySystem

Definition at line 23 of file ck.h.

Referenced by _initCharm(), CkMessageWatcherInit(), and CentralLB::LoadBalance().