PPL Logo

MeshStreamer< dtype > Class Template Reference

#include <MeshStreamer.h>

Inheritance diagram for MeshStreamer< dtype >:

Inheritance graph
[legend]
Collaboration diagram for MeshStreamer< dtype >:

Collaboration graph
[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 (int maxNumDataItemsBuffered, int numDimensions, int *dimensionSizes, bool yieldFlag=0, double progressPeriodInMs=-1.0)
 ~MeshStreamer ()
void receiveAlongRoute (MeshStreamerMessage< dtype > *msg)
virtual void receiveAtDestination (MeshStreamerMessage< dtype > *msg)=0
void flushDirect ()
void finish ()
bool isPeriodicFlushEnabled ()
virtual void insertData (dtype &dataItem, int destinationPe)
void insertData (void *dataItemHandle, int destinationPe)
void associateCallback (int numContributors, CkCallback startCb, CkCallback endCb, CProxy_CompletionDetector detector, int prio)
void flushAllBuffers ()
void registerPeriodicProgressFunction ()
void enablePeriodicFlushing ()
void done (int numContributorsFinished=1)
void init (CkCallback startCb, CkCallback endCb, int prio)
void startStagedCompletion ()
void markMessageReceived (int dimension, int finalCount)
void checkForCompletedStages ()

Protected Member Functions

virtual int copyDataItemIntoMessage (MeshStreamerMessage< dtype > *destinationBuffer, void *dataItemHandle, bool copyIndirectly=false)
MeshLocation determineLocation (int destinationPe, int dimensionReceivedAlong)

Protected Attributes

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)
void storeMessage (int destinationPe, const MeshLocation &destinationCoordinates, void *dataItem, bool copyIndirectly=false)
virtual void localDeliver (dtype &dataItem)=0
virtual int numElementsInClient ()=0
virtual int numLocalElementsInClient ()=0
virtual void initLocalClients ()=0
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_
int numMembers_
int numDimensions_
int * individualDimensionSizes_
int * combinedDimensionSizes_
int * startingIndexAtDimension_
int myIndex_
int * myLocationIndex_
bool yieldFlag_
bool hasSentRecently_
bool hasSentPreviously_
bool immediateMode_
MeshStreamerMessage< dtype > *** dataBuffers_
CProxy_CompletionDetector detector_
int prio_
int yieldCount_
MeshLocation * cachedLocations_
bool * isCached_
int ** cntMsgSent_
int * cntMsgReceived_
int * cntMsgExpected_
int * cntFinished_
int dimensionToFlush_
int numLocalDone_

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

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 ( int  maxNumDataItemsBuffered,
int  numDimensions,
int *  dimensionSizes,
bool  yieldFlag = 0,
double  progressPeriodInMs = -1.0 
) [inline]

Definition at line 270 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, MeshStreamer< dtype >::cachedLocations_, Converse::CkMyPe(), Converse::CkNumPes(), MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::combinedDimensionSizes_, MeshStreamer< dtype >::dataBuffers_, MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::immediateMode_, MeshStreamer< dtype >::individualDimensionSizes_, MeshStreamer< dtype >::isCached_, MeshStreamer< dtype >::isPeriodicFlushEnabled_, MeshStreamer< dtype >::maxNumDataItemsBuffered_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myLocationIndex_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::numDimensions_, MeshStreamer< dtype >::numMembers_, and MeshStreamer< dtype >::startingIndexAtDimension_.

template<class dtype>
MeshStreamer< dtype >::~MeshStreamer (  ) 

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(), MeshStreamer< dtype >::receiveAggregateData(), and MeshStreamer< dtype >::receiveAlongRoute().

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 >::insertData(), MeshStreamer< dtype >::receiveAggregateData(), and MeshStreamer< dtype >::receiveAlongRoute().

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_, envelope::getTotalsize(), MeshStreamer< dtype >::myNodeIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::personalizedBuffers_, envelope::setTotalsize(), and UsrToEnv().

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

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

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

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

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

template<class dtype>
bool MeshStreamer< dtype >::isPeriodicFlushEnabled (  )  [inline]

Definition at line 151 of file MeshStreamer.h.

Referenced by periodicProgressFunction().

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

Definition at line 155 of file MeshStreamer.h.

template<class dtype>
void MeshStreamer< dtype >::registerPeriodicProgressFunction (  )  [inline]

Definition at line 642 of file MeshStreamer.h.

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

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

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

template<class dtype>
void MeshStreamer< dtype >::enablePeriodicFlushing (  )  [inline]

Definition at line 168 of file MeshStreamer.h.

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

template<class dtype>
void MeshStreamer< dtype >::storeMessage ( int  destinationPe,
const MeshLocation &  destinationCoordinates,
void *  dataItem,
bool  copyIndirectly = false 
) [inline, private]

Definition at line 433 of file NDMeshStreamer.h.

References MeshLocation::bufferIndex, MeshStreamer< dtype >::bufferSize_, Converse::CkMyPe(), CkPriorityPtr(), CkSetQueueing(), MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::combinedDimensionSizes_, MeshStreamer< dtype >::copyDataItemIntoMessage(), MeshStreamer< dtype >::dataBuffers_, MeshLocation::dimension, MeshStreamer< dtype >::hasSentRecently_, MeshStreamerMessage< dtype >::markDestination(), MeshStreamer< dtype >::maxNumDataItemsBuffered_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myLocationIndex_, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::prio_, and MeshStreamer< dtype >::sendLargestBuffer().

template<class dtype>
virtual void MeshStreamer< dtype >::localDeliver ( dtype &  dataItem  )  [private, pure virtual]

Implemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

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

template<class dtype>
virtual int MeshStreamer< dtype >::numElementsInClient (  )  [private, pure virtual]

Implemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

template<class dtype>
virtual int MeshStreamer< dtype >::numLocalElementsInClient (  )  [private, pure virtual]

Implemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::done().

template<class dtype>
virtual void MeshStreamer< dtype >::initLocalClients (  )  [private, pure virtual]

Implemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

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

template<class dtype>
void MeshStreamer< dtype >::sendLargestBuffer (  )  [inline, private]

Definition at line 652 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, Converse::CkMyPe(), MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::combinedDimensionSizes_, MeshStreamer< dtype >::dataBuffers_, MeshStreamer< dtype >::flushDimension(), envelope::getPrioPtr(), envelope::getTotalsize(), MeshStreamer< dtype >::individualDimensionSizes_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myLocationIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::receiveAtDestination(), envelope::setTotalsize(), and UsrToEnv().

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

template<class dtype>
void MeshStreamer< dtype >::flushToIntermediateDestinations (  )  [inline, private]

Definition at line 763 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::flushDimension().

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

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

Definition at line 771 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::bufferSize_, Converse::CkMyPe(), CkPriorityPtr(), CkSetQueueing(), MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::combinedDimensionSizes_, MeshStreamer< dtype >::dataBuffers_, MeshStreamerMessage< dtype >::finalMsgCount, envelope::getPrioPtr(), envelope::getTotalsize(), MeshStreamer< dtype >::individualDimensionSizes_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myLocationIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, MeshStreamer< dtype >::prio_, envelope::setTotalsize(), and UsrToEnv().

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

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

Reimplemented in ArrayMeshStreamer< dtype, itype >.

Definition at line 425 of file NDMeshStreamer.h.

References MeshStreamerMessage< dtype >::addDataItem().

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

template<class dtype>
MeshLocation MeshStreamer< dtype >::determineLocation ( int  destinationPe,
int  dimensionReceivedAlong 
) [inline, protected]

Definition at line 388 of file NDMeshStreamer.h.

References MeshLocation::bufferIndex, MeshStreamer< dtype >::cachedLocations_, MeshStreamer< dtype >::combinedDimensionSizes_, MeshLocation::dimension, MeshStreamer< dtype >::isCached_, MeshStreamer< dtype >::myLocationIndex_, and MeshStreamer< dtype >::startingIndexAtDimension_.

template<class dtype>
void MeshStreamer< dtype >::receiveAlongRoute ( MeshStreamerMessage< dtype > *  msg  )  [inline]

Definition at line 615 of file NDMeshStreamer.h.

References Converse::CkMyPe(), MeshStreamerMessage< dtype >::destinationPes, MeshStreamer< dtype >::determineLocation(), MeshStreamerMessage< dtype >::dimension, MeshStreamerMessage< dtype >::finalMsgCount, MeshStreamer< dtype >::flushToIntermediateDestinations(), MeshStreamerMessage< dtype >::getDataItem(), MeshStreamer< dtype >::immediateMode_, MeshStreamer< dtype >::localDeliver(), MeshStreamer< dtype >::markMessageReceived(), MeshStreamerMessage< dtype >::numDataItems, and MeshStreamer< dtype >::storeMessage().

template<class dtype>
virtual void MeshStreamer< dtype >::receiveAtDestination ( MeshStreamerMessage< dtype > *  msg  )  [pure virtual]

Implemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

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

template<class dtype>
void MeshStreamer< dtype >::flushDirect (  ) 

template<class dtype>
void MeshStreamer< dtype >::finish (  )  [inline]

Definition at line 604 of file NDMeshStreamer.h.

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

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

template<class dtype>
bool MeshStreamer< dtype >::isPeriodicFlushEnabled (  )  [inline]

Definition at line 186 of file NDMeshStreamer.h.

template<class dtype>
virtual void MeshStreamer< dtype >::insertData ( dtype &  dataItem,
int  destinationPe 
) [virtual]

template<class dtype>
void MeshStreamer< dtype >::insertData ( void *  dataItemHandle,
int  destinationPe 
) [inline]

Definition at line 510 of file NDMeshStreamer.h.

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

template<class dtype>
void MeshStreamer< dtype >::associateCallback ( int  numContributors,
CkCallback  startCb,
CkCallback  endCb,
CProxy_CompletionDetector  detector,
int  prio 
) [inline]

Definition at line 568 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::detector_, MeshStreamer< dtype >::detectorLocalObj_, MeshStreamer< dtype >::enablePeriodicFlushing(), MeshStreamer< dtype >::finish(), MeshStreamer< dtype >::hasSentPreviously_, MeshStreamer< dtype >::hasSentRecently_, MeshStreamer< dtype >::immediateMode_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::progressPeriodInMs_, MeshStreamer< dtype >::userCallback_, and MeshStreamer< dtype >::yieldCount_.

template<class dtype>
void MeshStreamer< dtype >::flushAllBuffers (  )  [inline]

Definition at line 716 of file NDMeshStreamer.h.

References MeshStreamerMessage< dtype >::addDataItem(), CkPriorityPtr(), CkSetQueueing(), MeshStreamer< dtype >::dataBuffers_, MeshStreamerMessage< dtype >::destinationPes, MeshStreamerMessage< dtype >::getDataItem(), MeshStreamer< dtype >::individualDimensionSizes_, MeshStreamer< dtype >::myIndex_, MeshStreamer< dtype >::myLocationIndex_, MeshStreamerMessage< dtype >::numDataItems, MeshStreamer< dtype >::numDataItemsBuffered_, and MeshStreamer< dtype >::prio_.

template<class dtype>
void MeshStreamer< dtype >::registerPeriodicProgressFunction (  ) 

template<class dtype>
void MeshStreamer< dtype >::enablePeriodicFlushing (  )  [inline]

Definition at line 200 of file NDMeshStreamer.h.

template<class dtype>
void MeshStreamer< dtype >::done ( int  numContributorsFinished = 1  )  [inline]

Definition at line 205 of file NDMeshStreamer.h.

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

Definition at line 546 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::cntFinished_, MeshStreamer< dtype >::cntMsgExpected_, MeshStreamer< dtype >::cntMsgReceived_, MeshStreamer< dtype >::cntMsgSent_, MeshStreamer< dtype >::dimensionToFlush_, MeshStreamer< dtype >::individualDimensionSizes_, MeshStreamer< dtype >::initLocalClients(), MeshStreamer< dtype >::numLocalDone_, MeshStreamer< dtype >::prio_, MeshStreamer< dtype >::userCallback_, and MeshStreamer< dtype >::yieldCount_.

template<class dtype>
void MeshStreamer< dtype >::startStagedCompletion (  )  [inline]

Definition at line 218 of file NDMeshStreamer.h.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::done().

template<class dtype>
void MeshStreamer< dtype >::markMessageReceived ( int  dimension,
int  finalCount 
) [inline]

Definition at line 227 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::receiveAlongRoute(), and GroupMeshStreamer< dtype >::receiveAtDestination().

template<class dtype>
void MeshStreamer< dtype >::checkForCompletedStages (  )  [inline]

Definition at line 244 of file NDMeshStreamer.h.

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

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< ArrayDataItem< dtype, itype > >::checkForCompletedStages(), MeshStreamer< dtype >::flushAllBuffers(), MeshStreamer< dtype >::flushBuckets(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< dtype >::flushLargestBucket(), MeshStreamer< dtype >::MeshStreamer(), 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]

Reimplemented in GroupMeshStreamer< dtype >, and ArrayMeshStreamer< dtype, itype >.

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]

Reimplemented in GroupMeshStreamer< dtype >.

Definition at line 94 of file MeshStreamer.h.

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

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< ArrayDataItem< dtype, itype > >::associateCallback(), MeshStreamer< ArrayDataItem< dtype, itype > >::checkForCompletedStages(), MeshStreamer< dtype >::finish(), and MeshStreamer< dtype >::init().

template<class dtype>
int MeshStreamer< dtype >::yieldFlag_ [private]

Definition at line 102 of file MeshStreamer.h.

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

template<class dtype>
double MeshStreamer< dtype >::progressPeriodInMs_ [private]

Definition at line 104 of file MeshStreamer.h.

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

template<class dtype>
bool MeshStreamer< dtype >::isPeriodicFlushEnabled_ [private]

Definition at line 105 of file MeshStreamer.h.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::enablePeriodicFlushing(), MeshStreamer< dtype >::finish(), MeshStreamer< dtype >::flushDirect(), MeshStreamer< ArrayDataItem< dtype, itype > >::isPeriodicFlushEnabled(), MeshStreamer< dtype >::MeshStreamer(), 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 105 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::maxNumDataItemsBuffered_ [private]

Definition at line 106 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::numMembers_ [private]

Definition at line 109 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::numDimensions_ [private]

Definition at line 110 of file NDMeshStreamer.h.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::markMessageReceived(), and MeshStreamer< dtype >::MeshStreamer().

template<class dtype>
int* MeshStreamer< dtype >::individualDimensionSizes_ [private]

Definition at line 111 of file NDMeshStreamer.h.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::checkForCompletedStages(), MeshStreamer< dtype >::flushAllBuffers(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::init(), MeshStreamer< dtype >::MeshStreamer(), MeshStreamer< dtype >::sendLargestBuffer(), and MeshStreamer< ArrayDataItem< dtype, itype > >::startStagedCompletion().

template<class dtype>
int* MeshStreamer< dtype >::combinedDimensionSizes_ [private]

Definition at line 112 of file NDMeshStreamer.h.

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

template<class dtype>
int* MeshStreamer< dtype >::startingIndexAtDimension_ [private]

Definition at line 114 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::myIndex_ [private]

Definition at line 116 of file NDMeshStreamer.h.

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

template<class dtype>
int* MeshStreamer< dtype >::myLocationIndex_ [private]

Definition at line 117 of file NDMeshStreamer.h.

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

template<class dtype>
bool MeshStreamer< dtype >::yieldFlag_ [private]

Definition at line 120 of file NDMeshStreamer.h.

template<class dtype>
bool MeshStreamer< dtype >::hasSentRecently_ [private]

Definition at line 124 of file NDMeshStreamer.h.

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

template<class dtype>
bool MeshStreamer< dtype >::hasSentPreviously_ [private]

Definition at line 126 of file NDMeshStreamer.h.

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

template<class dtype>
bool MeshStreamer< dtype >::immediateMode_ [private]

Definition at line 127 of file NDMeshStreamer.h.

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

template<class dtype>
MeshStreamerMessage<dtype>*** MeshStreamer< dtype >::dataBuffers_ [private]

Definition at line 129 of file NDMeshStreamer.h.

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

template<class dtype>
CProxy_CompletionDetector MeshStreamer< dtype >::detector_ [private]

Definition at line 131 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::prio_ [private]

Definition at line 132 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::yieldCount_ [private]

Definition at line 133 of file NDMeshStreamer.h.

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

template<class dtype>
MeshLocation* MeshStreamer< dtype >::cachedLocations_ [private]

Definition at line 136 of file NDMeshStreamer.h.

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

template<class dtype>
bool* MeshStreamer< dtype >::isCached_ [private]

Definition at line 137 of file NDMeshStreamer.h.

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

template<class dtype>
int** MeshStreamer< dtype >::cntMsgSent_ [private]

Definition at line 142 of file NDMeshStreamer.h.

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

template<class dtype>
int* MeshStreamer< dtype >::cntMsgReceived_ [private]

Definition at line 143 of file NDMeshStreamer.h.

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

template<class dtype>
int* MeshStreamer< dtype >::cntMsgExpected_ [private]

Definition at line 144 of file NDMeshStreamer.h.

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

template<class dtype>
int* MeshStreamer< dtype >::cntFinished_ [private]

Definition at line 145 of file NDMeshStreamer.h.

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

template<class dtype>
int MeshStreamer< dtype >::dimensionToFlush_ [private]

Definition at line 146 of file NDMeshStreamer.h.

Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::checkForCompletedStages(), MeshStreamer< dtype >::init(), MeshStreamer< ArrayDataItem< dtype, itype > >::markMessageReceived(), and MeshStreamer< ArrayDataItem< dtype, itype > >::startStagedCompletion().

template<class dtype>
int MeshStreamer< dtype >::numLocalDone_ [private]

Definition at line 147 of file NDMeshStreamer.h.

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

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

Definition at line 166 of file NDMeshStreamer.h.

Referenced by MeshStreamer< dtype >::associateCallback(), MeshStreamer< ArrayDataItem< dtype, itype > >::done(), MeshStreamer< dtype >::MeshStreamer(), and GroupMeshStreamer< dtype >::receiveAtDestination().

The documentation for this class was generated from the following files:
Generated on Fri May 25 08:04:21 2012 for Charm++ by  doxygen 1.5.5