ck-core/qd.C File Reference

Go to the source code of this file.

Functions
	CpvDeclare (QdState *, _qd)
static void	_bcastQD1 (QdState *state, QdMsg *msg)
static void	_bcastQD2 (QdState *state, QdMsg *msg)
static void	_handlePhase0 (QdState *state, QdMsg *msg)
static void	_handlePhase1 (QdState *state, QdMsg *msg)
static void	_handlePhase2 (QdState *state, QdMsg *msg)
static void	_callWhenIdle (QdMsg *msg)
static void	_invokeQD (QdMsg *msg)
void	_qdHandler (envelope *env)
void	_qdCommHandler (envelope *env)
void	CkStartQD (const CkCallback &cb)
void	CkStartQD (int eIdx, const CkChareID *cid)
	When quiescence occurs, send a message to this entry point of this Chare.
Variables
int	_qdCommHandlerIdx
int	_dummy_dq = 0

---

Function Documentation

CpvDeclare	(	QdState *	,
		_qd
	)

static void _bcastQD1	(	QdState *	state,
		QdMsg *	msg
	)			[inline, static]

Definition at line 22 of file qd.C.

References CmiMyPe(), Converse::CmiSyncSendAndFree(), QdState::getCreated(), QdState::getProcessed(), QdState::getStage(), envelope::getTotalsize(), QdState::markProcessed(), QdState::propagate(), QdState::reset(), QdMsg::setCreated(), QdMsg::setPhase(), QdMsg::setProcessed(), QdState::setStage(), and UsrToEnv().

Referenced by _handlePhase0(), _handlePhase1(), and _handlePhase2().

static void _bcastQD2	(	QdState *	state,
		QdMsg *	msg
	)			[inline, static]

Definition at line 59 of file qd.C.

References CmiMyPe(), Converse::CmiSyncSendAndFree(), QdState::getStage(), envelope::getTotalsize(), QdState::isDirty(), QdState::propagate(), QdState::reset(), QdMsg::setDirty(), QdMsg::setPhase(), QdState::setStage(), and UsrToEnv().

Referenced by _handlePhase1().

static void _handlePhase0	(	QdState *	state,
		QdMsg *	msg
	)			[inline, static]

Definition at line 73 of file qd.C.

References _bcastQD1(), CkFreeMsg(), CmiMyPe(), QdState::enq(), QdMsg::getCb(), QdMsg::getPhase(), and QdState::getStage().

Referenced by _callWhenIdle().

static void _handlePhase1	(	QdState *	state,
		QdMsg *	msg
	)			[inline, static]

Definition at line 89 of file qd.C.

References _bcastQD1(), _bcastQD2(), QdState::allReported(), CkFreeMsg(), CmiAbort(), CmiMyPe(), Converse::CmiSyncSendAndFree(), QdState::getCCreated(), QdState::getCProcessed(), QdMsg::getCreated(), QdState::getParent(), QdMsg::getPhase(), QdMsg::getProcessed(), QdState::getStage(), envelope::getTotalsize(), QdState::reported(), QdState::reset(), QdMsg::setCreated(), QdMsg::setProcessed(), QdState::setStage(), QdState::subtreeCreate(), QdState::subtreeProcess(), and UsrToEnv().

Referenced by _callWhenIdle().

static void _handlePhase2	(	QdState *	state,
		QdMsg *	msg
	)			[inline, static]

Definition at line 129 of file qd.C.

References _bcastQD1(), QdState::allReported(), CkFreeMsg(), CmiMyPe(), Converse::CmiSyncSendAndFree(), CmiWallTimer(), QdState::deq(), QdMsg::getDirty(), QdState::getParent(), QdMsg::getPhase(), QdState::getStage(), envelope::getTotalsize(), QdState::isDirty(), QdState::reported(), QdState::reset(), QdCallback::send(), QdMsg::setDirty(), QdState::setStage(), QdState::subtreeSetDirty(), and UsrToEnv().

Referenced by _callWhenIdle().

static void _callWhenIdle

(

QdMsg *

msg

)

[static]

Definition at line 165 of file qd.C.

References _handlePhase0(), _handlePhase1(), _handlePhase2(), CmiAbort(), CmiMyPe(), and QdMsg::getPhase().

Referenced by _qdHandler().

static void _invokeQD

(

QdMsg *

msg

)

[static]

Definition at line 177 of file qd.C.

References QdMsg::getCb(), and QdCallback::send().

Referenced by _qdHandler().

void _qdHandler

(

envelope *

env

)

Definition at line 184 of file qd.C.

References _callWhenIdle(), _invokeQD(), CcdCallFnAfter(), CcdCallOnCondition(), CmiMyPe(), EnvToUsr(), and msg.

Referenced by initQd().

void _qdCommHandler

(

envelope *

env

)

Definition at line 196 of file qd.C.

References CmiFree(), CmiMyPe(), QdCommMsg::count, EnvToUsr(), QdCommMsg::flag, and msg.

Referenced by initQd().

void CkStartQD

(

const CkCallback &

cb

)

Definition at line 226 of file qd.C.

References _CldEnqueue(), _infoIdx, _qdHandlerIdx, CkAllocMsg(), CmiFreeSendFn(), envelope::getTotalsize(), msg, QdMsg::setCb(), QdMsg::setPhase(), and UsrToEnv().

Referenced by SearchConductor::allSearchNodeDone(), MeshStreamer< ArrayDataItem< dtype, itype > >::associateCallback(), CkStartQD(), MeshStreamer< dtype >::finish(), SearchConductor::fire(), CkMemCheckPT::isMaster(), LV3D0_qd(), POSE_init(), sim::SeqResumeAfterCheckpoint(), PVT::setGVT(), pose::stop(), and waitqd_QDChare::waitQD().