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

Typedefs

typedef std::unordered_map
< CmiUInt8, ArrayElement * > ArrayObjMap

Functions

int ConverseDeliver (int pe)

void _CldEnqueue (int pe, void *msg, int infofn)

void _CldEnqueueMulti (int npes, const int *pes, void *msg, int infofn)

void _CldEnqueueGroup (CmiGroup grp, void *msg, int infofn)

void _CldNodeEnqueue (int node, void *msg, int infofn)

CkpvExtern (std::vector< void * >, chare_objs)

CkpvExtern (ArrayObjMap, array_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)

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

IrrGroup * _getCkLocalBranchFromGroupID (CkGroupID &gID)

void QdCreate (int n)

void QdProcess (int n)

Variables

int _replaySystem = 0

Typedef Documentation

typedef std::unordered_map<CmiUInt8, ArrayElement*> ArrayObjMap

Definition at line 96 of file ck.h.

Function Documentation

int ConverseDeliver ( int pe )

Definition at line 36 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().

Here is the caller graph for this function:

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

Definition at line 26 of file ck.h.

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 39 of file ck.h.

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

Referenced by _sendMsgBranchMulti().

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 46 of file ck.h.

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

Referenced by CkSendMsgBranchGroup().

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 53 of file ck.h.

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

CkpvExtern	(	std::vector< void * >	,
		chare_objs
	)

CkpvExtern	(	ArrayObjMap	,
		array_objs
	)

CkpvExtern	(	CkCoreState *	,
		_coreState
	)

void CpdHandleLBMessage ( LBMigrateMsg ** msg )

Definition at line 2991 of file ck.C.

References CkCoreState::watcher.

Referenced by CentralLB::ApplyDecision().

Here is the caller graph for this function:

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

Definition at line 3003 of file ck.C.

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

Referenced by _initCharm().

Here is the call graph for this function:

Here is the caller graph for this function:

void _processHandler	(	void *	converseMsg,
		CkCoreState *	ck
	)

Definition at line 1214 of file ck.C.

References _processArrayEltMsg(), _processBocInitMsg(), _processDeleteVidMsg(), _processFillVidMsg(), _processForBocMsg(), _processForNodeBocMsg(), _processForPlainChareMsg(), _processForVidMsg(), _processNewChareMsg(), _processNewVChareMsg(), _processNodeBocInitMsg(), BCAST_SEND, BocInitMsg, CkFreeMsg(), Converse::CkMyPe(), CkRdmaIssueRgets(), CkUnpackMessage(), CmiAbort(), DeleteVidMsg, EnvToUsr(), FillVidMsg, ForArrayEltMsg, ForBocMsg, ForChareMsg, ForNodeBocMsg, ForVidMsg, envelope::getMsgtype(), envelope::isPacked(), NewChareMsg, NewVChareMsg, NodeBocInitMsg, P2P_SEND, postProcessReceivedMessage(), preProcessReceivedMessage(), and CkCoreState::watcher.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void _processBocInitMsg	(	CkCoreState *	ck,
		envelope *	msg
	)

Definition at line 1156 of file ck.C.

References CkCreateLocalGroup(), envelope::getEpIdx(), envelope::getGroupNum(), isGroupDepUnsatisfied(), and CkCoreState::process().

Referenced by _processBufferedBocInits(), and _processHandler().

Here is the call graph for this function:

Here is the caller graph for this function:

void _processNodeBocInitMsg	(	CkCoreState *	ck,
		envelope *	msg
	)

Definition at line 1166 of file ck.C.

References CkCreateLocalNodeGroup(), envelope::getEpIdx(), envelope::getGroupNum(), isGroupDepUnsatisfied(), and CkCoreState::process().

Referenced by _processBufferedNodeBocInits(), and _processHandler().

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 1352 of file ck.C.

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

Referenced by _initCharm().

Here is the call graph for this function:

Here is the caller graph for this function:

void _createGroup	(	CkGroupID	groupID,
		envelope *	env
	)

Definition at line 771 of file ck.C.

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

Referenced by _groupCreate().

Here is the call graph for this function:

Here is the caller graph for this function:

void _createNodeGroup	(	CkGroupID	groupID,
		envelope *	env
	)

Definition at line 793 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().

Here is the call graph for this function:

Here is the caller graph for this function:

int _getGroupIdx	(	int	,
		int	,
		int
	)

Definition at line 849 of file ck.C.

References idx, int, n, and x.

Referenced by _groupCreate(), and _nodeGroupCreate().

Here is the caller graph for this function:

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

IrrGroup* _getCkLocalBranchFromGroupID ( CkGroupID & gID )

Definition at line 1115 of file ck.C.

References CkCoreState::localBranch().

Referenced by getArrayMgrFromMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

void QdCreate ( int n )

Definition at line 469 of file ck.C.

void QdProcess ( int n )

Definition at line 473 of file ck.C.

Variable Documentation

int _replaySystem = 0

Definition at line 32 of file debug-conv.C.

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


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...
Typedefs
typedef std::unordered_map < CmiUInt8, ArrayElement * >	ArrayObjMap
Functions
int	ConverseDeliver (int pe)
void	_CldEnqueue (int pe, void *msg, int infofn)
void	_CldEnqueueMulti (int npes, const int pes, void msg, int infofn)
void	_CldEnqueueGroup (CmiGroup grp, void *msg, int infofn)
void	_CldNodeEnqueue (int node, void *msg, int infofn)
	CkpvExtern (std::vector< void * >, chare_objs)
	CkpvExtern (ArrayObjMap, array_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)
static IrrGroup *	_lookupGroupAndBufferIfNotThere (const CkCoreState ck, const envelope env, const CkGroupID &groupID)
IrrGroup *	_getCkLocalBranchFromGroupID (CkGroupID &gID)
void	QdCreate (int n)
void	QdProcess (int n)
Variables
int	_replaySystem = 0