MeshStreamer< dtype > Class Template Reference

#include <MeshStreamer.h>

Inheritance diagram for MeshStreamer< dtype >:

[legend]

Collaboration diagram for MeshStreamer< dtype >:

[legend]

Public Member Functions
	MeshStreamer (int totalBufferCapacity, int numRows, int numColumns, int numPlanes, const CProxy_MeshStreamerClient< dtype > &clientProxy, int yieldFlag=0, double progressPeriodInMs=-1.0)
	~MeshStreamer ()
void	insertData (dtype &dataItem, const int destinationPe)
void	doneInserting ()
void	receiveAggregateData (MeshStreamerMessage< dtype > *msg)
void	flushBuckets (MeshStreamerMessage< dtype > **messageBuffers, const int numBuffers)
void	flushDirect ()
bool	isPeriodicFlushEnabled ()
void	associateCallback (CkCallback &cb, bool automaticFinish=true)
void	registerPeriodicProgressFunction ()
void	finish (CkReductionMsg *msg)
void	enablePeriodicFlushing ()
	MeshStreamer ()
	MeshStreamer (CkMigrateMessage *)
	MeshStreamer (int maxNumDataItemsBuffered, int numDimensions, int *dimensionSizes, int bufferSize, bool yieldFlag=0, double progressPeriodInMs=-1.0)
void	receiveAlongRoute (MeshStreamerMessage< dtype > *msg)
void	enablePeriodicFlushing ()
void	finish ()
void	init (int numLocalContributors, CkCallback startCb, CkCallback endCb, int prio, bool usePeriodicFlushing)
void	init (int numContributors, CkCallback startCb, CkCallback endCb, CProxy_CompletionDetector detector, int prio, bool usePeriodicFlushing)
void	init (CkArrayID senderArrayID, CkCallback startCb, CkCallback endCb, int prio, bool usePeriodicFlushing)
void	init (CkCallback startCb, int prio)
void	syncInit ()
virtual void	receiveAtDestination (MeshStreamerMessage< dtype > *msg)
void	flushIfIdle ()
bool	isPeriodicFlushEnabled ()
virtual void	insertData (const dtype &dataItem, int destinationPe)
virtual void	broadcast (const dtype &dataItem)
void	sendMeshStreamerMessage (MeshStreamerMessage< dtype > *destinationBuffer, int dimension, int destinationIndex)
void	registerPeriodicProgressFunction ()
void	done (int numContributorsFinished=1)
void	startStagedCompletion ()
void	markMessageReceived (int msgType, int finalCount)
bool	checkAllStagesCompleted ()
void	checkForCompletedStages ()
virtual void	pup (PUP::er &p)
Protected Member Functions
virtual int	copyDataItemIntoMessage (MeshStreamerMessage< dtype > *destinationBuffer, const void *dataItemHandle, bool copyIndirectly=false)
void	insertData (const void *dataItemHandle, int destinationPe)
void	broadcast (const void *dataItemHandle, int dimension, bool copyIndirectly)
void	storeMessage (int destinationPe, const Route &destinationCoordinates, const void *dataItem, bool copyIndirectly=false)
void	ctorHelper (int maxNumDataItemsBuffered, int numDimensions, int *dimensionSizes, int bufferSize, bool yieldFlag, double progressPeriodInMs)
Protected Attributes
RouterType	myRouter_
int	numMembers_
int	myIndex_
int	numDimensions_
bool	useStagedCompletion_
bool	stagedCompletionStarted_
bool	useCompletionDetection_
CompletionDetector *	detectorLocalObj_
Private Member Functions
void	determineLocation (const int destinationPe, MeshLocation &destinationCoordinates)
void	storeMessage (MeshStreamerMessage< dtype > **const messageBuffers, const int bucketIndex, const int destinationPe, const MeshLocation &destinationCoordinates, const dtype &dataItem)
void	flushLargestBucket (MeshStreamerMessage< dtype > **const messageBuffers, const int numBuffers, const int myIndex, const int dimensionFactor)
virtual void	localDeliver (const dtype &dataItem)
virtual void	localBroadcast (const dtype &dataItem)
virtual void	initLocalClients ()
void	sendLargestBuffer ()
void	flushToIntermediateDestinations ()
void	flushDimension (int dimension, bool sendMsgCounts=false)
Private Attributes
int	bucketSize_
int	totalBufferCapacity_
int	numDataItemsBuffered_
int	numNodes_
int	numRows_
int	numColumns_
int	numPlanes_
int	planeSize_
CProxy_MeshStreamerClient< dtype >	clientProxy_
MeshStreamerClient< dtype > *	clientObj_
int	myNodeIndex_
int	myPlaneIndex_
int	myColumnIndex_
int	myRowIndex_
CkCallback	userCallback_
int	yieldFlag_
double	progressPeriodInMs_
bool	isPeriodicFlushEnabled_
double	timeOfLastSend_
MeshStreamerMessage< dtype > **	personalizedBuffers_
MeshStreamerMessage< dtype > **	columnBuffers_
MeshStreamerMessage< dtype > **	planeBuffers_
MeshLocation *	cachedLocations
bool *	isCached
int	numNodesInLastPlane_
int	numFullRowsInLastPlane_
int	numColumnsInLastRow_
int	bufferSize_
int	maxNumDataItemsBuffered_
bool	yieldFlag_
bool	hasSentRecently_
std::vector< std::vector < MeshStreamerMessage< dtype > * > >	dataBuffers_
CProxy_CompletionDetector	detector_
int	prio_
int	yieldCount_
std::vector< std::vector< int > >	cntMsgSent_
std::vector< int >	cntMsgReceived_
std::vector< int >	cntMsgExpected_
std::vector< int >	cntFinished_
int	numLocalDone_
int	numLocalContributors_
CompletionStatus	myCompletionStatus_

---

Detailed Description

template<class dtype>
class MeshStreamer< dtype >

Definition at line 80 of file MeshStreamer.h.

---

Constructor & Destructor Documentation

template<class dtype>

MeshStreamer< dtype >::MeshStreamer	(	int	totalBufferCapacity,
		int	numRows,
		int	numColumns,
		int	numPlanes,
		const CProxy_MeshStreamerClient< dtype > &	clientProxy,
		int	yieldFlag = 0,
		double	progressPeriodInMs = -1.0
	)			[inline]

Definition at line 184 of file MeshStreamer.h.

References MeshStreamer< dtype >::bucketSize_, MeshStreamer< dtype >::cachedLocations, CkLocalBranch(), Converse::CkMyPe(), Converse::CkNumPes(), MeshStreamer< dtype >::clientObj_, MeshStreamer< dtype >::clientProxy_, MeshStreamer< dtype >::columnBuffers_, MeshStreamer< dtype >::isCached, MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::myColumnIndex_, MeshStreamer< dtype >::myNodeIndex_, MeshStreamer< dtype >::myPlaneIndex_, MeshStreamer< dtype >::myRowIndex_, MeshStreamer< dtype >::numColumns_, MeshStreamer< dtype >::numColumnsInLastRow_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numFullRowsInLastPlane_, MeshStreamer< dtype >::numNodes_, MeshStreamer< dtype >::numNodesInLastPlane_, MeshStreamer< dtype >::numPlanes_, MeshStreamer< dtype >::numRows_, MeshStreamer< dtype >::personalizedBuffers_, MeshStreamer< dtype >::planeBuffers_, MeshStreamer< dtype >::planeSize_, MeshStreamer< dtype >::progressPeriodInMs_, and MeshStreamer< dtype >::totalBufferCapacity_.

Here is the call graph for this function:

template<class dtype>

MeshStreamer< dtype >::~MeshStreamer

(

)

[inline]

Definition at line 247 of file MeshStreamer.h.

References MeshStreamer< dtype >::columnBuffers_, MeshStreamer< dtype >::numColumns_, MeshStreamer< dtype >::numPlanes_, MeshStreamer< dtype >::numRows_, MeshStreamer< dtype >::personalizedBuffers_, and MeshStreamer< dtype >::planeBuffers_.

template<class dtype>

MeshStreamer< dtype >::MeshStreamer

(

)

[inline]

Definition at line 162 of file NDMeshStreamer.h.

template<class dtype>

MeshStreamer< dtype >::MeshStreamer

(

CkMigrateMessage *

)

[inline]

Definition at line 163 of file NDMeshStreamer.h.

template<class dtype, class RouterType>

MeshStreamer< dtype, RouterType >::MeshStreamer	(	int	maxNumDataItemsBuffered,
		int	numDimensions,
		int *	dimensionSizes,
		int	bufferSize,
		bool	yieldFlag = 0,
		double	progressPeriodInMs = -1.0
	)			[inline]

Definition at line 307 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::ctorHelper().

Here is the call graph for this function:

---

Member Function Documentation

template<class dtype>

void MeshStreamer< dtype >::determineLocation	(	const int	destinationPe,
		MeshLocation &	destinationCoordinates
	)			[inline, private]

Definition at line 265 of file MeshStreamer.h.

References MeshStreamer< dtype >::cachedLocations, MeshLocation::columnIndex, ColumnMessage, MeshStreamer< dtype >::isCached, MeshLocation::msgType, MeshStreamer< dtype >::myColumnIndex_, MeshStreamer< dtype >::myPlaneIndex_, MeshStreamer< dtype >::numColumns_, PersonalizedMessage, MeshLocation::planeIndex, PlaneMessage, MeshStreamer< dtype >::planeSize_, and MeshLocation::rowIndex.

Referenced by MeshStreamer< dtype >::insertData(), and MeshStreamer< dtype >::receiveAggregateData().

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::storeMessage	(	MeshStreamerMessage< dtype > **const	messageBuffers,
		const int	bucketIndex,
		const int	destinationPe,
		const MeshLocation &	destinationCoordinates,
		const dtype &	dataItem
	)			[inline, private]

Definition at line 303 of file MeshStreamer.h.

References MeshStreamerMessage< dtype >::addDataItem(), MeshStreamer< dtype >::bucketSize_, MeshStreamer< dtype >::clientProxy_, MeshStreamer< dtype >::columnBuffers_, MeshLocation::columnIndex, ColumnMessage, MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamerMessage< dtype >::markDestination(), MeshLocation::msgType, MeshStreamer< dtype >::myColumnIndex_, MeshStreamer< dtype >::myNodeIndex_, MeshStreamer< dtype >::myPlaneIndex_, MeshStreamer< dtype >::myRowIndex_, MeshStreamer< dtype >::numColumns_, MeshStreamer< dtype >::numColumnsInLastRow_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numFullRowsInLastPlane_, MeshStreamer< dtype >::numNodes_, MeshStreamer< dtype >::numPlanes_, MeshStreamer< dtype >::numRows_, MeshStreamer< dtype >::personalizedBuffers_, PersonalizedMessage, MeshStreamer< dtype >::planeBuffers_, MeshLocation::planeIndex, PlaneMessage, MeshStreamer< dtype >::planeSize_, MeshLocation::rowIndex, MeshStreamer< dtype >::timeOfLastSend_, and MeshStreamer< dtype >::totalBufferCapacity_.

Referenced by MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::receiveAggregateData(), MeshStreamer< dtype >::receiveAlongRoute(), and ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::resendMisdeliveredItems().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::flushLargestBucket	(	MeshStreamerMessage< dtype > **const	messageBuffers,
		const int	numBuffers,
		const int	myIndex,
		const int	dimensionFactor
	)			[inline, private]

Definition at line 542 of file MeshStreamer.h.

References MeshStreamer< dtype >::bucketSize_, MeshStreamer< dtype >::clientProxy_, dtype, envelope::getTotalsize(), MeshStreamer< dtype >::myNodeIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::personalizedBuffers_, envelope::setTotalsize(), and UsrToEnv().

Referenced by MeshStreamer< dtype >::storeMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::insertData	(	dtype &	dataItem,
		const int	destinationPe
	)			[inline]

Definition at line 396 of file MeshStreamer.h.

References Converse::CkMyPe(), MeshStreamer< dtype >::clientObj_, MeshStreamer< dtype >::columnBuffers_, MeshLocation::columnIndex, ColumnMessage, count, CthYield(), MeshStreamer< dtype >::determineLocation(), MeshLocation::msgType, MeshStreamer< dtype >::personalizedBuffers_, PersonalizedMessage, MeshStreamer< dtype >::planeBuffers_, MeshLocation::planeIndex, PlaneMessage, MeshLocation::rowIndex, MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::yieldFlag_.

Referenced by GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::insertData(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), and MeshStreamer< dtype >::insertData().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::doneInserting

(

void

)

[inline]

Definition at line 442 of file MeshStreamer.h.

template<class dtype>

void MeshStreamer< dtype >::receiveAggregateData

(

MeshStreamerMessage< dtype > *

msg

)

[inline]

Definition at line 462 of file MeshStreamer.h.

References MeshStreamer< dtype >::columnBuffers_, MeshLocation::columnIndex, ColumnMessage, MeshStreamerMessage< dtype >::destinationPes, MeshStreamer< dtype >::determineLocation(), dtype, MeshStreamerMessage< dtype >::getDataItem(), MeshLocation::msgType, MeshStreamer< dtype >::myColumnIndex_, MeshStreamer< dtype >::myPlaneIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::personalizedBuffers_, PersonalizedMessage, MeshLocation::planeIndex, MeshLocation::rowIndex, and MeshStreamer< dtype >::storeMessage().

Here is the call graph for this function:

template<class dtype>

void MeshStreamer< dtype >::flushBuckets	(	MeshStreamerMessage< dtype > **	messageBuffers,
		const int	numBuffers
	)			[inline]

Definition at line 577 of file MeshStreamer.h.

References MeshStreamerMessage< dtype >::addDataItem(), MeshStreamer< dtype >::clientProxy_, MeshStreamerMessage< dtype >::destinationPes, dtype, MeshStreamerMessage< dtype >::getDataItem(), MeshStreamer< dtype >::myNodeIndex_, MeshStreamer< dtype >::myRowIndex_, MeshStreamer< dtype >::numColumns_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, and MeshStreamer< dtype >::personalizedBuffers_.

Referenced by MeshStreamer< dtype >::flushDirect().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::flushDirect

(

)

[inline]

Definition at line 609 of file MeshStreamer.h.

References MeshStreamer< dtype >::columnBuffers_, MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::numColumns_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numPlanes_, MeshStreamer< dtype >::numRows_, MeshStreamer< dtype >::personalizedBuffers_, MeshStreamer< dtype >::planeBuffers_, MeshStreamer< dtype >::progressPeriodInMs_, and MeshStreamer< dtype >::timeOfLastSend_.

Referenced by MeshStreamer< dtype >::finish(), and periodicProgressFunction().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

bool MeshStreamer< dtype >::isPeriodicFlushEnabled

(

)

[inline]

Definition at line 151 of file MeshStreamer.h.

References MeshStreamer< dtype >::isPeriodicFlushEnabled_.

Referenced by periodicProgressFunction().

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::associateCallback	(	CkCallback &	cb,
		bool	automaticFinish = true
	)			[inline]

Definition at line 155 of file MeshStreamer.h.

References CkStartQD(), and MeshStreamer< dtype >::userCallback_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::registerPeriodicProgressFunction

(

)

[inline]

Definition at line 642 of file MeshStreamer.h.

References CcdCallFnAfter(), and MeshStreamer< dtype >::progressPeriodInMs_.

Referenced by MeshStreamer< dtype >::enablePeriodicFlushing(), and periodicProgressFunction().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::finish

(

CkReductionMsg *

msg

)

[inline]

Definition at line 447 of file MeshStreamer.h.

References CkStartQD(), MeshStreamer< dtype >::flushDirect(), CkCallback::isInvalid(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, and MeshStreamer< dtype >::userCallback_.

Here is the call graph for this function:

template<class dtype>

void MeshStreamer< dtype >::enablePeriodicFlushing

(

)

[inline]

Definition at line 168 of file MeshStreamer.h.

References MeshStreamer< dtype >::isPeriodicFlushEnabled_, and MeshStreamer< dtype >::registerPeriodicProgressFunction().

Referenced by MeshStreamer< dtype >::init().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

virtual void MeshStreamer< dtype >::localDeliver

(

const dtype &

dataItem

)

[inline, private, virtual]

Definition at line 127 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localBroadcast(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localBroadcast(), MeshStreamer< dtype >::receiveAlongRoute(), and ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

Here is the caller graph for this function:

template<class dtype>

virtual void MeshStreamer< dtype >::localBroadcast

(

const dtype &

dataItem

)

[inline, private, virtual]

Definition at line 128 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), and MeshStreamer< dtype >::receiveAlongRoute().

Here is the caller graph for this function:

template<class dtype>

virtual void MeshStreamer< dtype >::initLocalClients

(

)

[inline, private, virtual]

Definition at line 130 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), and MeshStreamer< dtype >::init().

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::sendLargestBuffer

(

)

[inline, private]

Definition at line 726 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::dataBuffers_, dtype, MeshStreamerMessage< dtype >::finalMsgCount, MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::sendMeshStreamerMessage(), envelope::shrinkUsersize(), MeshStreamer< dtype >::useStagedCompletion_, and UsrToEnv().

Referenced by MeshStreamer< dtype >::storeMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::flushToIntermediateDestinations

(

)

[inline, private]

Definition at line 775 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::flushDimension(), and MeshStreamer< dtype >::numDimensions_.

Referenced by MeshStreamer< dtype >::flushIfIdle().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::flushDimension	(	int	dimension,
		bool	sendMsgCounts = false
	)			[inline, private]

Definition at line 783 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, CkPriorityPtr(), CkSetQueueing(), MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::dataBuffers_, dtype, MeshStreamerMessage< dtype >::finalMsgCount, envelope::getUsersize(), int, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::prio_, PUP::s, MeshStreamer< dtype >::sendMeshStreamerMessage(), envelope::shrinkUsersize(), MeshStreamer< dtype >::useStagedCompletion_, and UsrToEnv().

Referenced by MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::flushToIntermediateDestinations(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::startStagedCompletion().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

int MeshStreamer< dtype, RouterType >::copyDataItemIntoMessage	(	MeshStreamerMessage< dtype > *	destinationBuffer,
		const void *	dataItemHandle,
		bool	copyIndirectly = false
	)			[inline, protected, virtual]

Definition at line 385 of file NDMeshStreamer.h.

References MeshStreamerMessage< dtype >::addDataItem(), and dtype.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::copyDataItemIntoMessage(), and MeshStreamer< dtype >::storeMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::insertData	(	const void *	dataItemHandle,
		int	destinationPe
	)			[inline, protected]

Definition at line 523 of file NDMeshStreamer.h.

References CthYield(), MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::storeMessage(), MeshStreamer< dtype >::yieldCount_, and MeshStreamer< dtype >::yieldFlag_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::broadcast	(	const void *	dataItemHandle,
		int	dimension,
		bool	copyIndirectly
	)			[inline, protected]

Definition at line 491 of file NDMeshStreamer.h.

References CthYield(), Route::dimension, Route::dimensionIndex, MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::storeMessage(), MeshStreamer< dtype >::yieldCount_, and MeshStreamer< dtype >::yieldFlag_.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), and MeshStreamer< dtype >::receiveAlongRoute().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::storeMessage	(	int	destinationPe,
		const Route &	destinationCoordinates,
		const void *	dataItem,
		bool	copyIndirectly = false
	)			[inline, protected]

Definition at line 414 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, CkPriorityPtr(), CkSetQueueing(), MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::copyDataItemIntoMessage(), MeshStreamer< dtype >::dataBuffers_, Route::destinationPe, Route::dimension, Route::dimensionIndex, MeshStreamer< dtype >::hasSentRecently_, int, MeshStreamerMessage< dtype >::markDestination(), MeshStreamer< dtype >::maxNumDataItemsBuffered_, MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::sendLargestBuffer(), MeshStreamer< dtype >::sendMeshStreamerMessage(), and MeshStreamer< dtype >::useStagedCompletion_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::ctorHelper	(	int	maxNumDataItemsBuffered,
		int	numDimensions,
		int *	dimensionSizes,
		int	bufferSize,
		bool	yieldFlag,
		double	progressPeriodInMs
	)			[inline, protected]

Definition at line 316 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, Converse::CkMyPe(), Converse::CkNumPes(), MeshStreamer< dtype >::dataBuffers_, MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::maxNumDataItemsBuffered_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::numMembers_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::progressPeriodInMs_, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::userCallback_, MeshStreamer< dtype >::useStagedCompletion_, MeshStreamer< dtype >::yieldCount_, and MeshStreamer< dtype >::yieldFlag_.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::ArrayMeshStreamer(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupChunkMeshStreamer(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupMeshStreamer(), and MeshStreamer< dtype >::MeshStreamer().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::receiveAlongRoute

(

MeshStreamerMessage< dtype > *

msg

)

[inline]

Definition at line 676 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamerMessage< dtype >::destinationPes, dtype, MeshStreamerMessage< dtype >::finalMsgCount, MeshStreamerMessage< dtype >::getDataItem(), envelope::getSrcPe(), MeshStreamer< dtype >::localBroadcast(), MeshStreamer< dtype >::localDeliver(), MeshStreamer< dtype >::markMessageReceived(), MeshStreamerMessage< dtype >::msgType, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::storeMessage(), MeshStreamer< dtype >::useStagedCompletion_, and UsrToEnv().

Here is the call graph for this function:

template<class dtype>

void MeshStreamer< dtype >::enablePeriodicFlushing

(

)

[inline]

Definition at line 171 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::progressPeriodInMs_, and MeshStreamer< dtype >::registerPeriodicProgressFunction().

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::finish

(

)

[inline]

Definition at line 664 of file NDMeshStreamer.h.

References CkCallback::isInvalid(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, and MeshStreamer< dtype >::userCallback_.

Referenced by MeshStreamer< dtype >::init().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::init	(	int	numLocalContributors,
		CkCallback	startCb,
		CkCallback	endCb,
		int	prio,
		bool	usePeriodicFlushing
	)			[inline]

Definition at line 576 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::numLocalContributors_, MeshStreamer< dtype >::numLocalDone_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::userCallback_, MeshStreamer< dtype >::useStagedCompletion_, and MeshStreamer< dtype >::yieldCount_.

Referenced by MeshStreamer< dtype >::init().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::init	(	int	numContributors,
		CkCallback	startCb,
		CkCallback	endCb,
		CProxy_CompletionDetector	detector,
		int	prio,
		bool	usePeriodicFlushing
	)			[inline]

Definition at line 623 of file NDMeshStreamer.h.

References Converse::CkMyPe(), MeshStreamer< dtype >::detector_, MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::finish(), MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::userCallback_, MeshStreamer< dtype >::useStagedCompletion_, and MeshStreamer< dtype >::yieldCount_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::init	(	CkArrayID	senderArrayID,
		CkCallback	startCb,
		CkCallback	endCb,
		int	prio,
		bool	usePeriodicFlushing
	)			[inline]

Definition at line 655 of file NDMeshStreamer.h.

References CkArrayID::ckLocalBranch(), CkArray::getLocMgr(), MeshStreamer< dtype >::init(), and CkLocMgr::numLocalElements().

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::init	(	CkCallback	startCb,
		int	prio
	)			[inline]

Definition at line 556 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::userCallback_, MeshStreamer< dtype >::useStagedCompletion_, and MeshStreamer< dtype >::yieldCount_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::syncInit

(

)

[inline]

Definition at line 613 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::numLocalContributors_, and MeshStreamer< dtype >::startStagedCompletion().

Here is the call graph for this function:

template<class dtype>

virtual void MeshStreamer< dtype >::receiveAtDestination

(

MeshStreamerMessage< dtype > *

msg

)

[inline, virtual]

Definition at line 196 of file NDMeshStreamer.h.

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::flushIfIdle

(

)

[inline]

Definition at line 832 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::flushToIntermediateDestinations(), MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::isPeriodicFlushEnabled_, and MeshStreamer< dtype >::numDataItemsBuffered_.

Referenced by periodicProgressFunction().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

bool MeshStreamer< dtype >::isPeriodicFlushEnabled

(

)

[inline]

Definition at line 200 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::isPeriodicFlushEnabled_.

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::insertData	(	const dtype &	dataItem,
		int	destinationPe
	)			[inline, virtual]

Definition at line 541 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::insertData(), CompletionDetector::produce(), QdCreate(), MeshStreamer< dtype >::stagedCompletionStarted_, and MeshStreamer< dtype >::useCompletionDetection_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::broadcast

(

const dtype &

dataItem

)

[inline, virtual]

Definition at line 469 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::localBroadcast(), MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::numMembers_, CompletionDetector::produce(), QdCreate(), MeshStreamer< dtype >::stagedCompletionStarted_, and MeshStreamer< dtype >::useCompletionDetection_.

Here is the call graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::sendMeshStreamerMessage	(	MeshStreamerMessage< dtype > *	destinationBuffer,
		int	dimension,
		int	destinationIndex
	)			[inline]

Definition at line 392 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::myIndex_, and MeshStreamer< dtype >::myRouter_.

Referenced by MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::registerPeriodicProgressFunction

(

)

template<class dtype>

void MeshStreamer< dtype >::done

(

int

numContributorsFinished = 1

)

[inline]

Definition at line 211 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::detectorLocalObj_, CompletionDetector::done(), MeshStreamer< dtype >::numLocalContributors_, MeshStreamer< dtype >::numLocalDone_, MeshStreamer< dtype >::startStagedCompletion(), MeshStreamer< dtype >::useCompletionDetection_, and MeshStreamer< dtype >::useStagedCompletion_.

Here is the call graph for this function:

template<class dtype>

void MeshStreamer< dtype >::startStagedCompletion

(

)

[inline]

Definition at line 225 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::checkForCompletedStages(), CompletionStatus::dimensionsToFlush, MeshStreamer< dtype >::flushDimension(), initialCompletionStage, MeshStreamer< dtype >::myCompletionStatus_, MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::stagedCompletionStarted_, and CompletionStatus::stageIndex.

Referenced by MeshStreamer< dtype >::done(), and MeshStreamer< dtype >::syncInit().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::markMessageReceived	(	int	msgType,
		int	finalCount
	)			[inline]

Definition at line 237 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, MeshStreamer< dtype >::myIndex_, and MeshStreamer< dtype >::stagedCompletionStarted_.

Referenced by MeshStreamer< dtype >::receiveAlongRoute(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), and GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

bool MeshStreamer< dtype >::checkAllStagesCompleted

(

)

[inline]

Definition at line 253 of file NDMeshStreamer.h.

References finalCompletionStage, CkCallback::isInvalid(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::myCompletionStatus_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::numDataItemsBuffered_, CompletionStatus::stageIndex, and MeshStreamer< dtype >::userCallback_.

Referenced by MeshStreamer< dtype >::checkForCompletedStages().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype>

void MeshStreamer< dtype >::checkForCompletedStages

(

)

[inline]

Definition at line 273 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, CompletionStatus::dimensionsToFlush, MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::myCompletionStatus_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, CompletionStatus::numContributors, and CompletionStatus::stageIndex.

Referenced by MeshStreamer< dtype >::markMessageReceived(), MeshStreamer< dtype >::receiveAlongRoute(), and MeshStreamer< dtype >::startStagedCompletion().

Here is the call graph for this function:

Here is the caller graph for this function:

template<class dtype, class RouterType>

void MeshStreamer< dtype, RouterType >::pup

(

PUP::er &

p

)

[inline, virtual]

Definition at line 868 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, CkPupMessage(), MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::dataBuffers_, MeshStreamer< dtype >::detector_, MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::hasSentRecently_, PUP::er::isPacking(), MeshStreamer< dtype >::isPeriodicFlushEnabled_, PUP::er::isUnpacking(), MeshStreamer< dtype >::maxNumDataItemsBuffered_, MeshStreamer< dtype >::myCompletionStatus_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myRouter_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::numLocalContributors_, MeshStreamer< dtype >::numLocalDone_, MeshStreamer< dtype >::numMembers_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::progressPeriodInMs_, size, MeshStreamer< dtype >::stagedCompletionStarted_, MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::userCallback_, MeshStreamer< dtype >::useStagedCompletion_, MeshStreamer< dtype >::yieldCount_, and MeshStreamer< dtype >::yieldFlag_.

Here is the call graph for this function:

---

Field Documentation

template<class dtype>

int MeshStreamer< dtype >::bucketSize_ [private]

Definition at line 83 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::totalBufferCapacity_ [private]

Definition at line 84 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::numDataItemsBuffered_ [private]

Definition at line 85 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::flushIfIdle(), MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::numNodes_ [private]

Definition at line 87 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::numRows_ [private]

Definition at line 88 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

int MeshStreamer< dtype >::numColumns_ [private]

Definition at line 89 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

int MeshStreamer< dtype >::numPlanes_ [private]

Definition at line 90 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

int MeshStreamer< dtype >::planeSize_ [private]

Definition at line 91 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

CProxy_MeshStreamerClient<dtype> MeshStreamer< dtype >::clientProxy_ [private]

Definition at line 93 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

MeshStreamerClient<dtype>* MeshStreamer< dtype >::clientObj_ [private]

Definition at line 94 of file MeshStreamer.h.

Referenced by GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupChunkMeshStreamer(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupMeshStreamer(), MeshStreamer< dtype >::insertData(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), MeshStreamer< dtype >::MeshStreamer(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::processChunk(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::pup(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::pup(), and GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

template<class dtype>

int MeshStreamer< dtype >::myNodeIndex_ [private]

Definition at line 96 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::myPlaneIndex_ [private]

Definition at line 97 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::receiveAggregateData(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::myColumnIndex_ [private]

Definition at line 98 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::receiveAggregateData(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::myRowIndex_ [private]

Definition at line 99 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

CkCallback MeshStreamer< dtype >::userCallback_ [private]

Definition at line 101 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::associateCallback(), MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::finish(), MeshStreamer< dtype >::init(), and MeshStreamer< dtype >::pup().

template<class dtype>

int MeshStreamer< dtype >::yieldFlag_ [private]

Definition at line 102 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::insertData(), and MeshStreamer< dtype >::pup().

template<class dtype>

double MeshStreamer< dtype >::progressPeriodInMs_ [private]

Definition at line 104 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::registerPeriodicProgressFunction().

template<class dtype>

bool MeshStreamer< dtype >::isPeriodicFlushEnabled_ [private]

Definition at line 105 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::finish(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::flushIfIdle(), MeshStreamer< dtype >::isPeriodicFlushEnabled(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

double MeshStreamer< dtype >::timeOfLastSend_ [private]

Definition at line 106 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDirect(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

MeshStreamerMessage<dtype>** MeshStreamer< dtype >::personalizedBuffers_ [private]

Definition at line 108 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::receiveAggregateData(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

MeshStreamerMessage<dtype>** MeshStreamer< dtype >::columnBuffers_ [private]

Definition at line 109 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::receiveAggregateData(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

MeshStreamerMessage<dtype>** MeshStreamer< dtype >::planeBuffers_ [private]

Definition at line 110 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::storeMessage(), and MeshStreamer< dtype >::~MeshStreamer().

template<class dtype>

MeshLocation* MeshStreamer< dtype >::cachedLocations [private]

Definition at line 113 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), and MeshStreamer< dtype >::MeshStreamer().

template<class dtype>

bool* MeshStreamer< dtype >::isCached [private]

Definition at line 114 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::determineLocation(), and MeshStreamer< dtype >::MeshStreamer().

template<class dtype>

int MeshStreamer< dtype >::numNodesInLastPlane_ [private]

Definition at line 118 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::MeshStreamer().

template<class dtype>

int MeshStreamer< dtype >::numFullRowsInLastPlane_ [private]

Definition at line 119 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::numColumnsInLastRow_ [private]

Definition at line 120 of file MeshStreamer.h.

Referenced by MeshStreamer< dtype >::MeshStreamer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::bufferSize_ [private]

Definition at line 101 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::maxNumDataItemsBuffered_ [private]

Definition at line 102 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

bool MeshStreamer< dtype >::yieldFlag_ [private]

Definition at line 106 of file NDMeshStreamer.h.

template<class dtype>

bool MeshStreamer< dtype >::hasSentRecently_ [private]

Definition at line 110 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushIfIdle(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

std::vector<std::vector<MeshStreamerMessage<dtype> * > > MeshStreamer< dtype >::dataBuffers_ [private]

Definition at line 111 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

CProxy_CompletionDetector MeshStreamer< dtype >::detector_ [private]

Definition at line 113 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::init(), and MeshStreamer< dtype >::pup().

template<class dtype>

int MeshStreamer< dtype >::prio_ [private]

Definition at line 114 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::yieldCount_ [private]

Definition at line 115 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::insertData(), and MeshStreamer< dtype >::pup().

template<class dtype>

std::vector<std::vector<int> > MeshStreamer< dtype >::cntMsgSent_ [private]

Definition at line 118 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

std::vector<int> MeshStreamer< dtype >::cntMsgReceived_ [private]

Definition at line 119 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::markMessageReceived(), and MeshStreamer< dtype >::pup().

template<class dtype>

std::vector<int> MeshStreamer< dtype >::cntMsgExpected_ [private]

Definition at line 120 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::markMessageReceived(), and MeshStreamer< dtype >::pup().

template<class dtype>

std::vector<int> MeshStreamer< dtype >::cntFinished_ [private]

Definition at line 121 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::markMessageReceived(), and MeshStreamer< dtype >::pup().

template<class dtype>

int MeshStreamer< dtype >::numLocalDone_ [private]

Definition at line 123 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::done(), MeshStreamer< dtype >::init(), and MeshStreamer< dtype >::pup().

template<class dtype>

int MeshStreamer< dtype >::numLocalContributors_ [private]

Definition at line 124 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::done(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::syncInit().

template<class dtype>

CompletionStatus MeshStreamer< dtype >::myCompletionStatus_ [private]

Definition at line 125 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::startStagedCompletion().

template<class dtype>

RouterType MeshStreamer< dtype >::myRouter_ [protected]

Definition at line 138 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::checkForCompletedStages(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::receiveAlongRoute(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::resendMisdeliveredItems(), MeshStreamer< dtype >::sendLargestBuffer(), MeshStreamer< dtype >::sendMeshStreamerMessage(), MeshStreamer< dtype >::startStagedCompletion(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

int MeshStreamer< dtype >::numMembers_ [protected]

Definition at line 139 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::commonInit(), MeshStreamer< dtype >::ctorHelper(), and MeshStreamer< dtype >::pup().

template<class dtype>

int MeshStreamer< dtype >::myIndex_ [protected]

Definition at line 140 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::checkAllStagesCompleted(), MeshStreamer< dtype >::checkForCompletedStages(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::copyDataItemIntoMessage(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::flushDimension(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::insertData(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), MeshStreamer< dtype >::markMessageReceived(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::receiveAlongRoute(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::sendMeshStreamerMessage().

template<class dtype>

int MeshStreamer< dtype >::numDimensions_ [protected]

Definition at line 141 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::flushToIntermediateDestinations(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::pup(), and MeshStreamer< dtype >::sendLargestBuffer().

template<class dtype>

bool MeshStreamer< dtype >::useStagedCompletion_ [protected]

Definition at line 142 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::done(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::init(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::receiveAlongRoute(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< dtype >::storeMessage().

template<class dtype>

bool MeshStreamer< dtype >::stagedCompletionStarted_ [protected]

Definition at line 143 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::init(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), MeshStreamer< dtype >::insertData(), MeshStreamer< dtype >::markMessageReceived(), MeshStreamer< dtype >::pup(), MeshStreamer< dtype >::receiveAlongRoute(), and MeshStreamer< dtype >::startStagedCompletion().

template<class dtype>

bool MeshStreamer< dtype >::useCompletionDetection_ [protected]

Definition at line 144 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::done(), MeshStreamer< dtype >::init(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::initLocalClients(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), MeshStreamer< dtype >::insertData(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localBroadcast(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), MeshStreamer< dtype >::pup(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), and GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

template<class dtype>

CompletionDetector* MeshStreamer< dtype >::detectorLocalObj_ [protected]

Definition at line 145 of file NDMeshStreamer.h.

Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), MeshStreamer< dtype >::ctorHelper(), MeshStreamer< dtype >::done(), MeshStreamer< dtype >::init(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), MeshStreamer< dtype >::insertData(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localBroadcast(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), MeshStreamer< dtype >::pup(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), and GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

---

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

• libs/ck-libs/MeshStreamer/MeshStreamer.h
• libs/ck-libs/NDMeshStreamer/NDMeshStreamer.h