CkReductionMgr Class Reference

#include <ckreduction.h>

Inheritance diagram for CkReductionMgr:

[legend]

Collaboration diagram for CkReductionMgr:

[legend]

Public Types
typedef CkReductionClientFn	clientFn
Public Member Functions
	CkReductionMgr ()
	CkReductionMgr (CkMigrateMessage *m)
	~CkReductionMgr ()
void	ckSetReductionClient (CkCallback *cb)
	Add the given client function.
void	creatingContributors (void)
void	doneCreatingContributors (void)
void	contributorStamped (contributorInfo *ci)
void	contributorCreated (contributorInfo *ci)
void	contributorDied (contributorInfo *ci)
void	contributorLeaving (contributorInfo *ci)
void	contributorArriving (contributorInfo *ci)
void	contribute (contributorInfo *ci, CkReductionMsg *msg)
void	ReductionStarting (CkReductionNumberMsg *m)
void	LateMigrantMsg (CkReductionMsg *m)
void	MigrantDied (CkReductionNumberMsg *m)
void	RecvMsg (CkReductionMsg *m)
void	AddToInactiveList (CkReductionInactiveMsg *m)
void	barrier (CkReductionMsg *msg)
void	Barrier_RecvMsg (CkReductionMsg *m)
void	addBarrier (CkReductionMsg *m)
void	finishBarrier (void)
virtual bool	isReductionMgr (void)
virtual void	flushStates ()
int	getGCount ()
void	decGCount ()
void	incNumImmigrantRecObjs ()
void	decNumImmigrantRecObjs ()
void	incNumEmigrantRecObjs ()
void	decNumEmigrantRecObjs ()
int	numberReductionMessages ()
virtual void	pup (PUP::er &p)
	Pack/UnPack - tell the runtime how to serialize this class's data for migration, checkpoint, etc.
void	contributeViaMessage (CkReductionMsg *m)
Static Public Member Functions
static CkReductionMsg *	reduceMessages (CkMsgQ< CkReductionMsg > &msgs)
static bool	isIrreducible ()
Data Fields
CProxy_CkReductionMgr	thisProxy
int *	perProcessorCounts
int	processorCount
int	totalCount
Protected Member Functions
bool	hasParent (void)
int	treeParent (void)
int	firstKid (void)
int	treeKids (void)
void	resetCountersWhenFlushingStates ()
Protected Attributes
bool	disableNotifyChildrenStart
bool	isDestroying
Private Types
enum	{ TREE_WID = 2 }
Private Member Functions
void	startReduction (int number, int srcPE)
void	addContribution (CkReductionMsg *m)
void	finishReduction (void)
	function checks if it has got all contributions that it is supposed to get at this processor.
void	checkIsActive ()
void	informParentInactive ()
void	checkAndAddToInactiveList (int id, int red_no)
void	checkAndRemoveFromInactiveList (int id, int red_no)
void	sendReductionStartingToKids (int red_no)
void	init_BinomialTree ()
void	init_TopoTree ()
void	init_BinaryTree ()
int	treeRoot (void)
bool	isPast (int num) const
bool	isPresent (int num) const
bool	isFuture (int num) const
countAdjustment &	adj (int number)
Private Attributes
int	numImmigrantRecObjs
int	numEmigrantRecObjs
CkCallback	storedCallback
int	redNo
int	completedRedNo
bool	inProgress
bool	creating
bool	startRequested
int	gcount
int	lcount
int	maxStartRequest
int	nContrib
int	nRemote
bool	is_inactive
CkCallback	barrier_storedCallback
int	barrier_gCount
int	barrier_nSource
int	barrier_nContrib
int	barrier_nRemote
CkMsgQ< CkReductionMsg >	msgs
CkMsgQ< CkReductionMsg >	futureMsgs
CkMsgQ< CkReductionMsg >	futureRemoteMsgs
CkMsgQ< CkReductionMsg >	finalMsgs
std::map< int, int >	inactiveList
unsigned	upperSize
unsigned	label
int	parent
int	numKids
std::vector< int >	newKids
std::vector< int >	kids
std::vector< countAdjustment >	adjVec

---

Detailed Description

Definition at line 626 of file ckreduction.h.

---

Member Typedef Documentation

typedef CkReductionClientFn CkReductionMgr::clientFn

Reimplemented in serialCollideClient.

Definition at line 635 of file ckreduction.h.

---

Member Enumeration Documentation

anonymous enum [private]

Enumerator:

TREE_WID

Definition at line 778 of file ckreduction.h.

---

Constructor & Destructor Documentation

CkReductionMgr::CkReductionMgr

(

)

Definition at line 181 of file ckreduction.C.

References barrier_gCount, barrier_nContrib, barrier_nRemote, barrier_nSource, completedRedNo, creating, disableNotifyChildrenStart, gcount, init_BinaryTree(), init_BinomialTree(), init_TopoTree(), inProgress, is_inactive, lcount, maxStartRequest, nContrib, nRemote, numEmigrantRecObjs, numImmigrantRecObjs, redNo, and startRequested.

Here is the call graph for this function:

CkReductionMgr::CkReductionMgr

(

CkMigrateMessage *

m

)

Definition at line 215 of file ckreduction.C.

References barrier_gCount, barrier_nContrib, barrier_nRemote, barrier_nSource, completedRedNo, creating, gcount, inProgress, is_inactive, lcount, maxStartRequest, nContrib, nRemote, numEmigrantRecObjs, numImmigrantRecObjs, numKids, redNo, and startRequested.

CkReductionMgr::~CkReductionMgr

(

)

Definition at line 241 of file ckreduction.C.

---

Member Function Documentation

void CkReductionMgr::ckSetReductionClient

(

CkCallback *

cb

)

Add the given client function.

Overwrites any previous client. This manager will dispose of the callback when replaced or done.

Definition at line 268 of file ckreduction.C.

References Converse::CkMyPe(), _ckGroupID::idx, storedCallback, and IrrGroup::thisgroup.

Referenced by CkArray::CkArray().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::creatingContributors

(

void

)

Definition at line 281 of file ckreduction.C.

References creating.

Referenced by CkArrayReducer::ckBeginInserting(), and Group::Group().

Here is the caller graph for this function:

void CkReductionMgr::doneCreatingContributors

(

void

)

Definition at line 286 of file ckreduction.C.

References checkIsActive(), Converse::CkMyPe(), creating, finishReduction(), redNo, startReduction(), and startRequested.

Referenced by CkArrayReducer::ckEndInserting(), and Group::Group().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contributorStamped

(

contributorInfo *

ci

)

Definition at line 296 of file ckreduction.C.

References adj(), gcount, inProgress, redNo, and contributorInfo::redNo.

Referenced by CkArrayReducer::ckElementStamp(), and Group::Group().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contributorCreated

(

contributorInfo *

ci

)

Definition at line 310 of file ckreduction.C.

References adj(), checkIsActive(), _ckGroupID::idx, lcount, r, contributorInfo::redNo, redNo, and IrrGroup::thisgroup.

Referenced by CkArrayReducer::ckElementCreating(), and Group::Group().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contributorDied

(

contributorInfo *

ci

)

Definition at line 327 of file ckreduction.C.

References adj(), checkIsActive(), CkInRestarting(), finishReduction(), gcount, isDestroying, lcount, r, redNo, contributorInfo::redNo, and thisProxy.

Referenced by CkArrayReducer::ckElementDied().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contributorLeaving

(

contributorInfo *

ci

)

Definition at line 370 of file ckreduction.C.

References adj(), checkIsActive(), finishReduction(), lcount, r, redNo, and contributorInfo::redNo.

Referenced by CkArrayReducer::ckElementLeaving().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contributorArriving

(

contributorInfo *

ci

)

Definition at line 386 of file ckreduction.C.

References adj(), checkIsActive(), CkInRestarting(), lcount, r, redNo, and contributorInfo::redNo.

Referenced by CkArrayReducer::ckElementArriving().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::contribute	(	contributorInfo *	ci,
		CkReductionMsg *	msg
	)

Definition at line 408 of file ckreduction.C.

References addContribution(), CkReductionMsg::gcount, _ckGroupID::idx, ChareMlogData::immigrantRecFlag, CkReductionMsg::isMigratableContributor(), CkReductionMsg::log, Chare::mlogData, CkReductionMsg::redNo, contributorInfo::redNo, CkReductionMsg::sourceFlag, IrrGroup::thisgroup, thisProxy, and UsrToEnv().

Referenced by ArrayElement::contribute2(), PythonObject::print(), PythonObject::replyIntValue(), and GVT::sumGVTIterationCounts().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::ReductionStarting

(

CkReductionNumberMsg *

m

)

Definition at line 560 of file ckreduction.C.

References Converse::CkMyPe(), finishReduction(), inProgress, isFuture(), isPresent(), maxStartRequest, CkReductionNumberMsg::num, startReduction(), and UsrToEnv().

Here is the call graph for this function:

void CkReductionMgr::LateMigrantMsg

(

CkReductionMsg *

m

)

Definition at line 590 of file ckreduction.C.

References addContribution(), and CkReductionMsg::log.

Here is the call graph for this function:

void CkReductionMgr::MigrantDied

(

CkReductionNumberMsg *

m

)

Definition at line 599 of file ckreduction.C.

References adj(), Converse::CkMyPe(), completedRedNo, finishReduction(), and CkReductionNumberMsg::num.

Here is the call graph for this function:

void CkReductionMgr::RecvMsg

(

CkReductionMsg *

m

)

Definition at line 815 of file ckreduction.C.

References checkAndRemoveFromInactiveList(), Converse::CkMyPe(), CkQ< T >::enq(), finishReduction(), CkReductionMsg::fromPE, futureRemoteMsgs, isFuture(), isPresent(), CkReductionMsg::log, msgs, nRemote, CkReductionMsg::nSources(), CkReductionMsg::redNo, and startReduction().

Referenced by finishReduction().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::AddToInactiveList

(

CkReductionInactiveMsg *

m

)

Definition at line 839 of file ckreduction.C.

References checkAndAddToInactiveList(), checkIsActive(), finishReduction(), CkReductionInactiveMsg::id, redNo, and CkReductionInactiveMsg::redno.

Here is the call graph for this function:

void CkReductionMgr::barrier

(

CkReductionMsg *

msg

)

Definition at line 1174 of file ckreduction.C.

References barrier_nContrib, barrier_nSource, barrier_storedCallback, CkReductionMsg::callback, finishBarrier(), and CkCallback::isInvalid().

Here is the call graph for this function:

void CkReductionMgr::Barrier_RecvMsg

(

CkReductionMsg *

m

)

Definition at line 1223 of file ckreduction.C.

References barrier_gCount, barrier_nRemote, barrier_nSource, barrier_storedCallback, CkReductionMsg::callback, finishBarrier(), CkReductionMsg::gcount, CkCallback::isInvalid(), and CkReductionMsg::nSources().

Here is the call graph for this function:

void CkReductionMgr::addBarrier

(

CkReductionMsg *

m

)

void CkReductionMgr::finishBarrier

(

void

)

Definition at line 1184 of file ckreduction.C.

References barrier_gCount, barrier_nContrib, barrier_nRemote, barrier_nSource, barrier_storedCallback, CkReductionMsg::buildNew(), CkReductionMsg::callback, Converse::CkMyPe(), CkSetRefNum(), gcount, CkReductionMsg::gcount, CkReductionMsg::getUserFlag(), hasParent(), CkCallback::isInvalid(), lcount, CkReductionMsg::nSources(), CkCallback::send(), CkReductionMsg::sourceFlag, thisProxy, treeKids(), and treeParent().

Referenced by barrier(), and Barrier_RecvMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

virtual bool CkReductionMgr::isReductionMgr

(

void

)

[inline, virtual]

Reimplemented from IrrGroup.

Definition at line 683 of file ckreduction.h.

void CkReductionMgr::flushStates

(

)

[virtual]

Reimplemented from IrrGroup.

Reimplemented in CkArray, and Group.

Definition at line 245 of file ckreduction.C.

References adjVec, completedRedNo, creating, CkQ< T >::deq(), finalMsgs, futureMsgs, futureRemoteMsgs, inProgress, CkQ< T >::isEmpty(), maxStartRequest, msgs, nContrib, nRemote, redNo, and startRequested.

Referenced by Group::flushStates(), and CkArray::flushStates().

Here is the call graph for this function:

Here is the caller graph for this function:

int CkReductionMgr::getGCount

(

)

[inline]

Definition at line 693 of file ckreduction.h.

References gcount.

void CkReductionMgr::decGCount

(

)

[inline]

Definition at line 695 of file ckreduction.h.

References gcount.

Referenced by _distributedLocationHandler(), and _sendBackLocationHandler().

Here is the caller graph for this function:

void CkReductionMgr::incNumImmigrantRecObjs

(

)

[inline]

Definition at line 696 of file ckreduction.h.

References numImmigrantRecObjs.

Referenced by _distributedLocationHandler().

Here is the caller graph for this function:

void CkReductionMgr::decNumImmigrantRecObjs

(

)

[inline]

Definition at line 699 of file ckreduction.h.

References numImmigrantRecObjs.

Referenced by sendBackImmigrantRecObjs().

Here is the caller graph for this function:

void CkReductionMgr::incNumEmigrantRecObjs

(

)

[inline]

Definition at line 702 of file ckreduction.h.

References numEmigrantRecObjs.

Referenced by ElementDistributor::addLocation().

Here is the caller graph for this function:

void CkReductionMgr::decNumEmigrantRecObjs

(

)

[inline]

Definition at line 705 of file ckreduction.h.

References numEmigrantRecObjs.

Referenced by _sendBackLocationHandler().

Here is the caller graph for this function:

CkReductionMsg * CkReductionMgr::reduceMessages

(

CkMsgQ< CkReductionMsg > &

msgs

)

[static]

Definition at line 868 of file ckreduction.C.

References CkReductionMsg::buildNew(), CkReductionMsg::callback, Converse::CkMyPe(), CkQ< MSG * >::deq(), CkReductionMsg::gcount, CkReduction::invalid, CkCallback::isInvalid(), CkReductionMsg::isMigratableContributor(), CkQ< MSG * >::length(), CkReductionMsg::log, PUP::m, name, CkReduction::nop, CkReductionMsg::nSources(), r, CkReductionMsg::reducer, CkReduction::reducerTable(), CkReduction::set, CkReductionMsg::setMigratableContributor(), CkReductionMsg::sourceFlag, CkReduction::tuple, CkCallback::type, CkCallback::typeName(), MergeablePathHistory::updateMax(), CkReductionMsg::userFlag, and UsrToEnv().

Referenced by CkNodeReductionMgr::finishReduction(), and finishReduction().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::startReduction	(	int	number,
		int	srcPE
	)			[private]

Definition at line 610 of file ckreduction.C.

References Converse::CkMyPe(), completedRedNo, creating, disableNotifyChildrenStart, inProgress, isFuture(), isPast(), redNo, sendReductionStartingToKids(), and startRequested.

Referenced by addContribution(), doneCreatingContributors(), finishReduction(), RecvMsg(), and ReductionStarting().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::addContribution

(

CkReductionMsg *

m

)

[private]

Definition at line 646 of file ckreduction.C.

References Converse::CkMyPe(), CmiAbort(), CkQ< T >::enq(), finishReduction(), futureMsgs, isFuture(), isPast(), msgs, nContrib, CkReductionMsg::redNo, startReduction(), and thisProxy.

Referenced by contribute(), contributeViaMessage(), finishReduction(), and LateMigrantMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::finishReduction

(

void

)

[private]

function checks if it has got all contributions that it is supposed to get at this processor.

If it is done it sends the reduced result to the local nodegroup

Definition at line 676 of file ckreduction.C.

References addContribution(), adj(), adjVec, CkReductionMsg::callback, checkIsActive(), Converse::CkMyPe(), CkSetRefNum(), completedRedNo, creating, CkQ< T >::deq(), CkQ< T >::enq(), CkReductionMsg::fromPE, futureMsgs, futureRemoteMsgs, gcount, CkReductionMsg::gcount, CkReductionMsg::getUserFlag(), hasParent(), _ckGroupID::idx, inProgress, CkCallback::isInvalid(), lcount, CkQ< T >::length(), PUP::m, maxStartRequest, msgs, n, nContrib, nRemote, CkReductionMsg::nSources(), numEmigrantRecObjs, numImmigrantRecObjs, CkQ< T >::peek(), RecvMsg(), CkReductionMsg::redNo, redNo, reduceMessages(), CkReductionMsg::reducer, CkReduction::reducerTable(), CkCallback::send(), CkReductionMsg::sourceFlag, startReduction(), startRequested, storedCallback, IrrGroup::thisgroup, thisProxy, treeKids(), and treeParent().

Referenced by addContribution(), AddToInactiveList(), contributorDied(), contributorLeaving(), doneCreatingContributors(), MigrantDied(), RecvMsg(), and ReductionStarting().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::checkIsActive

(

)

[private]

Definition at line 457 of file ckreduction.C.

References inactiveList, informParentInactive(), is_inactive, lcount, numKids, and redNo.

Referenced by AddToInactiveList(), checkAndAddToInactiveList(), contributorArriving(), contributorCreated(), contributorDied(), contributorLeaving(), doneCreatingContributors(), finishReduction(), and pup().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::informParentInactive

(

)

[private]

Definition at line 526 of file ckreduction.C.

References Converse::CkMyPe(), hasParent(), redNo, thisProxy, and treeParent().

Referenced by checkIsActive().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::checkAndAddToInactiveList	(	int	id,
		int	red_no
	)			[private]

Definition at line 487 of file ckreduction.C.

References checkIsActive(), inactiveList, inProgress, redNo, and thisProxy.

Referenced by AddToInactiveList().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::checkAndRemoveFromInactiveList	(	int	id,
		int	red_no
	)			[private]

Definition at line 512 of file ckreduction.C.

References inactiveList.

Referenced by RecvMsg().

Here is the caller graph for this function:

void CkReductionMgr::sendReductionStartingToKids

(

int

red_no

)

[private]

Definition at line 538 of file ckreduction.C.

References inactiveList, kids, redNo, thisProxy, and treeKids().

Referenced by startReduction().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::init_BinomialTree

(

)

[private]

Definition at line 1115 of file ckreduction.C.

References BGConverse::CkMyNode(), Converse::CkMyPe(), BGConverse::CkNodeFirst(), BGConverse::CkNodeSize(), BGConverse::CkNumNodes(), Converse::CkNumPes(), count, int, kids, label, numKids, p, parent, and upperSize.

Referenced by CkReductionMgr(), and pup().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::init_TopoTree

(

)

[private]

Definition at line 1085 of file ckreduction.C.

References _topoTree, CmiSpanningTreeInfo::child_count, CmiSpanningTreeInfo::children, BGConverse::CkMyNode(), Converse::CkMyPe(), BGConverse::CkNodeFirst(), BGConverse::CkNodeSize(), kids, newKids, numKids, CmiSpanningTreeInfo::parent, parent, and PUP::t.

Referenced by CkReductionMgr(), and pup().

Here is the call graph for this function:

Here is the caller graph for this function:

void CkReductionMgr::init_BinaryTree

(

)

[private]

Definition at line 1055 of file ckreduction.C.

References BGConverse::CkMyNode(), Converse::CkMyPe(), BGConverse::CkNodeFirst(), BGConverse::CkNodeSize(), BGConverse::CkNumNodes(), firstKid(), kids, newKids, numKids, parent, and TREE_WID.

Referenced by CkReductionMgr(), and pup().

Here is the call graph for this function:

Here is the caller graph for this function:

int CkReductionMgr::treeRoot

(

void

)

[private]

Definition at line 1153 of file ckreduction.C.

Referenced by hasParent().

Here is the caller graph for this function:

bool CkReductionMgr::isPast

(

int

num

)

const [inline, private]

Definition at line 782 of file ckreduction.h.

References redNo.

Referenced by addContribution(), and startReduction().

Here is the caller graph for this function:

bool CkReductionMgr::isPresent

(

int

num

)

const [inline, private]

Definition at line 783 of file ckreduction.h.

References redNo.

Referenced by RecvMsg(), and ReductionStarting().

Here is the caller graph for this function:

bool CkReductionMgr::isFuture

(

int

num

)

const [inline, private]

Definition at line 784 of file ckreduction.h.

References redNo.

Referenced by addContribution(), RecvMsg(), ReductionStarting(), and startReduction().

Here is the caller graph for this function:

countAdjustment & CkReductionMgr::adj

(

int

number

)

[private]

Definition at line 857 of file ckreduction.C.

References adjVec, and completedRedNo.

Referenced by contributorArriving(), contributorCreated(), contributorDied(), contributorLeaving(), contributorStamped(), finishReduction(), and MigrantDied().

Here is the caller graph for this function:

bool CkReductionMgr::hasParent

(

void

)

[protected]

Definition at line 1157 of file ckreduction.C.

References Converse::CkMyPe(), and treeRoot().

Referenced by finishBarrier(), finishReduction(), informParentInactive(), and CkArray::initDone().

Here is the call graph for this function:

Here is the caller graph for this function:

int CkReductionMgr::treeParent

(

void

)

[protected]

Definition at line 1161 of file ckreduction.C.

References parent.

Referenced by finishBarrier(), finishReduction(), informParentInactive(), and CkArray::initDone().

Here is the caller graph for this function:

int CkReductionMgr::firstKid

(

void

)

[protected]

Referenced by init_BinaryTree().

Here is the caller graph for this function:

int CkReductionMgr::treeKids

(

void

)

[protected]

Definition at line 1165 of file ckreduction.C.

References numKids.

Referenced by finishBarrier(), finishReduction(), CkArray::initDone(), and sendReductionStartingToKids().

Here is the caller graph for this function:

void CkReductionMgr::resetCountersWhenFlushingStates

(

)

[inline, protected]

Definition at line 801 of file ckreduction.h.

References gcount, and lcount.

Referenced by CkArray::flushStates().

Here is the caller graph for this function:

int CkReductionMgr::numberReductionMessages

(

)

[inline]

Reimplemented in CkArray.

Definition at line 810 of file ckreduction.h.

References totalCount.

void CkReductionMgr::pup

(

PUP::er &

p

)

[virtual]

Pack/UnPack - tell the runtime how to serialize this class's data for migration, checkpoint, etc.

Reimplemented from CkGroupInitCallback.

Reimplemented in CkArray, Group, PVT, GVT, TimePool, and MemoryPool.

Definition at line 1000 of file ckreduction.C.

References adjVec, CkReductionClientBundle::callbackCfn(), CkCallback::callCFn, checkIsActive(), BGConverse::CkMyNode(), Converse::CkMyPe(), completedRedNo, creating, CkCallback::d, disableNotifyChildrenStart, finalMsgs, futureMsgs, futureRemoteMsgs, gcount, init_BinaryTree(), init_BinomialTree(), init_TopoTree(), inProgress, is_inactive, PUP::er::isUnpacking(), maxStartRequest, msgs, nContrib, nRemote, p, CkGroupInitCallback::pup(), redNo, startRequested, storedCallback, IrrGroup::thisgroup, thisProxy, and CkCallback::type.

Referenced by CkArray::pup(), and Group::pup().

Here is the call graph for this function:

Here is the caller graph for this function:

static bool CkReductionMgr::isIrreducible

(

)

[inline, static]

Reimplemented from IrrGroup.

Reimplemented in CkArray.

Definition at line 819 of file ckreduction.h.

void CkReductionMgr::contributeViaMessage

(

CkReductionMsg *

m

)

Definition at line 443 of file ckreduction.C.

References addContribution(), and UsrToEnv().

Here is the call graph for this function:

---

Field Documentation

CProxy_CkReductionMgr CkReductionMgr::thisProxy

Reimplemented in CkArray.

Definition at line 628 of file ckreduction.h.

Referenced by addContribution(), checkAndAddToInactiveList(), contribute(), contributorDied(), finishBarrier(), finishReduction(), informParentInactive(), pup(), and sendReductionStartingToKids().

int CkReductionMgr::numImmigrantRecObjs [private]

Definition at line 717 of file ckreduction.h.

Referenced by CkReductionMgr(), decNumImmigrantRecObjs(), finishReduction(), and incNumImmigrantRecObjs().

int CkReductionMgr::numEmigrantRecObjs [private]

Definition at line 718 of file ckreduction.h.

Referenced by CkReductionMgr(), decNumEmigrantRecObjs(), finishReduction(), and incNumEmigrantRecObjs().

CkCallback CkReductionMgr::storedCallback [private]

Definition at line 723 of file ckreduction.h.

Referenced by ckSetReductionClient(), finishReduction(), and pup().

int CkReductionMgr::redNo [private]

Definition at line 725 of file ckreduction.h.

Referenced by AddToInactiveList(), checkAndAddToInactiveList(), checkIsActive(), CkReductionMgr(), contributorArriving(), contributorCreated(), contributorDied(), contributorLeaving(), contributorStamped(), doneCreatingContributors(), finishReduction(), flushStates(), informParentInactive(), isFuture(), isPast(), isPresent(), pup(), sendReductionStartingToKids(), and startReduction().

int CkReductionMgr::completedRedNo [private]

Definition at line 726 of file ckreduction.h.

Referenced by adj(), CkReductionMgr(), finishReduction(), flushStates(), MigrantDied(), pup(), and startReduction().

bool CkReductionMgr::inProgress [private]

Definition at line 727 of file ckreduction.h.

Referenced by checkAndAddToInactiveList(), CkReductionMgr(), contributorStamped(), finishReduction(), flushStates(), pup(), ReductionStarting(), and startReduction().

bool CkReductionMgr::creating [private]

Definition at line 728 of file ckreduction.h.

Referenced by CkReductionMgr(), creatingContributors(), doneCreatingContributors(), finishReduction(), flushStates(), pup(), and startReduction().

bool CkReductionMgr::startRequested [private]

Definition at line 729 of file ckreduction.h.

Referenced by CkReductionMgr(), doneCreatingContributors(), finishReduction(), flushStates(), pup(), and startReduction().

int CkReductionMgr::gcount [private]

Definition at line 730 of file ckreduction.h.

Referenced by CkReductionMgr(), contributorDied(), contributorStamped(), decGCount(), finishBarrier(), finishReduction(), getGCount(), pup(), and resetCountersWhenFlushingStates().

int CkReductionMgr::lcount [private]

Definition at line 731 of file ckreduction.h.

Referenced by checkIsActive(), CkReductionMgr(), contributorArriving(), contributorCreated(), contributorDied(), contributorLeaving(), finishBarrier(), finishReduction(), and resetCountersWhenFlushingStates().

int CkReductionMgr::maxStartRequest [private]

Definition at line 732 of file ckreduction.h.

Referenced by CkReductionMgr(), finishReduction(), flushStates(), pup(), and ReductionStarting().

int CkReductionMgr::nContrib [private]

Definition at line 735 of file ckreduction.h.

Referenced by addContribution(), CkReductionMgr(), finishReduction(), flushStates(), and pup().

int CkReductionMgr::nRemote [private]

Definition at line 735 of file ckreduction.h.

Referenced by CkReductionMgr(), finishReduction(), flushStates(), pup(), and RecvMsg().

bool CkReductionMgr::is_inactive [private]

Definition at line 737 of file ckreduction.h.

Referenced by checkIsActive(), CkReductionMgr(), and pup().

CkCallback CkReductionMgr::barrier_storedCallback [private]

Definition at line 740 of file ckreduction.h.

Referenced by barrier(), Barrier_RecvMsg(), and finishBarrier().

int CkReductionMgr::barrier_gCount [private]

Definition at line 741 of file ckreduction.h.

Referenced by Barrier_RecvMsg(), CkReductionMgr(), and finishBarrier().

int CkReductionMgr::barrier_nSource [private]

Definition at line 742 of file ckreduction.h.

Referenced by barrier(), Barrier_RecvMsg(), CkReductionMgr(), and finishBarrier().

int CkReductionMgr::barrier_nContrib [private]

Definition at line 743 of file ckreduction.h.

Referenced by barrier(), CkReductionMgr(), and finishBarrier().

int CkReductionMgr::barrier_nRemote [private]

Definition at line 743 of file ckreduction.h.

Referenced by Barrier_RecvMsg(), CkReductionMgr(), and finishBarrier().

CkMsgQ<CkReductionMsg> CkReductionMgr::msgs [private]

Definition at line 746 of file ckreduction.h.

Referenced by addContribution(), finishReduction(), flushStates(), pup(), and RecvMsg().

CkMsgQ<CkReductionMsg> CkReductionMgr::futureMsgs [private]

Definition at line 749 of file ckreduction.h.

Referenced by addContribution(), finishReduction(), flushStates(), and pup().

CkMsgQ<CkReductionMsg> CkReductionMgr::futureRemoteMsgs [private]

Definition at line 751 of file ckreduction.h.

Referenced by finishReduction(), flushStates(), pup(), and RecvMsg().

CkMsgQ<CkReductionMsg> CkReductionMgr::finalMsgs [private]

Definition at line 753 of file ckreduction.h.

Referenced by flushStates(), and pup().

std::map<int, int> CkReductionMgr::inactiveList [private]

Definition at line 754 of file ckreduction.h.

Referenced by checkAndAddToInactiveList(), checkAndRemoveFromInactiveList(), checkIsActive(), and sendReductionStartingToKids().

unsigned CkReductionMgr::upperSize [private]

Definition at line 767 of file ckreduction.h.

Referenced by init_BinomialTree().

unsigned CkReductionMgr::label [private]

Definition at line 768 of file ckreduction.h.

Referenced by init_BinomialTree().

int CkReductionMgr::parent [private]

Definition at line 769 of file ckreduction.h.

Referenced by init_BinaryTree(), init_BinomialTree(), init_TopoTree(), and treeParent().

int CkReductionMgr::numKids [private]

Definition at line 770 of file ckreduction.h.

Referenced by checkIsActive(), CkReductionMgr(), init_BinaryTree(), init_BinomialTree(), init_TopoTree(), and treeKids().

std::vector<int> CkReductionMgr::newKids [private]

Definition at line 772 of file ckreduction.h.

Referenced by init_BinaryTree(), and init_TopoTree().

std::vector<int> CkReductionMgr::kids [private]

Definition at line 773 of file ckreduction.h.

Referenced by init_BinaryTree(), init_BinomialTree(), init_TopoTree(), and sendReductionStartingToKids().

std::vector<countAdjustment> CkReductionMgr::adjVec [private]

Definition at line 789 of file ckreduction.h.

Referenced by adj(), finishReduction(), flushStates(), and pup().

bool CkReductionMgr::disableNotifyChildrenStart [protected]

Definition at line 800 of file ckreduction.h.

Referenced by CkArray::CkArray(), CkReductionMgr(), pup(), and startReduction().

bool CkReductionMgr::isDestroying [protected]

Definition at line 802 of file ckreduction.h.

Referenced by CkArray::ckDestroy(), and contributorDied().

int* CkReductionMgr::perProcessorCounts

Definition at line 807 of file ckreduction.h.

int CkReductionMgr::processorCount

Definition at line 808 of file ckreduction.h.

int CkReductionMgr::totalCount

Reimplemented in SearchGroup.

Definition at line 809 of file ckreduction.h.

Referenced by numberReductionMessages().

---

The documentation for this class was generated from the following files:

• ck-core/ckreduction.h
• ck-core/ckreduction.C