PPL Logo

GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod > Class Template Reference

#include <NDMeshStreamer.h>

Inheritance diagram for GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >:

Inheritance graph
[legend]
Collaboration diagram for GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >:

Collaboration graph
[legend]

Public Member Functions

 GroupChunkMeshStreamer (int maxNumDataItemsBuffered, int numDimensions, int *dimensionSizes, CkGroupID clientGID, bool yieldFlag=0, double progressPeriodInMs=-1.0, bool userHandlesFreeing=false)
 GroupChunkMeshStreamer (int numDimensions, int *dimensionSizes, CkGroupID clientGID, int bufferSize, bool yieldFlag=0, double progressPeriodInMs=-1.0, bool userHandlesFreeing=false)
 GroupChunkMeshStreamer (CkMigrateMessage *)
void commonInit ()
void insertData (dtype *dataArray, int numElements, int destinationPe, void *extraData=NULL, int extraDataSize=0)
void processChunk (const ChunkDataItem &chunk)
void localDeliver (const ChunkDataItem &chunk)
void receiveAtDestination (MeshStreamerMessage< ChunkDataItem > *msg)
void localBroadcast (const ChunkDataItem &dataItem)
void initLocalClients ()
void pup (PUP::er &p)

Private Attributes

std::list< ChunkOutOfOrderBuffer > outOfOrderBuffers_
std::vector< ChunkReceiveBuffer > lastReceived_
std::vector< int > currentBufferNumbers_
CkGroupID clientGID_
ClientType * clientObj_
bool userHandlesFreeing_

Detailed Description

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
class GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >

Definition at line 1383 of file NDMeshStreamer.h.

Constructor & Destructor Documentation

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupChunkMeshStreamer ( int  maxNumDataItemsBuffered,
int  numDimensions,
int *  dimensionSizes,
CkGroupID  clientGID,
bool  yieldFlag = 0,
double  progressPeriodInMs = -1.0,
bool  userHandlesFreeing = false 
) [inline]

Definition at line 1399 of file NDMeshStreamer.h.

References CkLocalBranch(), MeshStreamer< dtype >::clientObj_, and MeshStreamer< dtype >::ctorHelper().

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupChunkMeshStreamer ( int  numDimensions,
int *  dimensionSizes,
CkGroupID  clientGID,
int  bufferSize,
bool  yieldFlag = 0,
double  progressPeriodInMs = -1.0,
bool  userHandlesFreeing = false 
) [inline]

Definition at line 1412 of file NDMeshStreamer.h.

References CkLocalBranch(), MeshStreamer< dtype >::clientObj_, and MeshStreamer< dtype >::ctorHelper().

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupChunkMeshStreamer ( CkMigrateMessage *   )  [inline]

Definition at line 1425 of file NDMeshStreamer.h.

Member Function Documentation

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::commonInit ( void   )  [inline]

Definition at line 1427 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::numMembers_.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::insertData ( dtype *  dataArray,
int  numElements,
int  destinationPe,
void *  extraData = NULL,
int  extraDataSize = 0 
) [inline]

Definition at line 1434 of file NDMeshStreamer.h.

References ChunkDataItem::bufferNumber, ChunkDataItem::chunkNumber, ChunkDataItem::chunkSize, dtype, MeshStreamer< dtype >::insertData(), int, min(), MeshStreamer< dtype >::myIndex_, ChunkDataItem::numChunks, ChunkDataItem::numItems, offset, ChunkDataItem::rawData, and ChunkDataItem::sourcePe.

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::processChunk ( const ChunkDataItem &  chunk  )  [inline]

Definition at line 1483 of file NDMeshStreamer.h.

References ChunkReceiveBuffer::buffer, ChunkDataItem::bufferNumber, ChunkReceiveBuffer::bufferNumber, ChunkDataItem::chunkNumber, ChunkDataItem::chunkSize, MeshStreamer< dtype >::clientObj_, dtype, ChunkDataItem::numChunks, ChunkDataItem::numItems, ChunkDataItem::rawData, ChunkReceiveBuffer::receivedChunks, and ChunkDataItem::sourcePe.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver ( const ChunkDataItem &  chunk  )  [inline]

Definition at line 1551 of file NDMeshStreamer.h.

References CompletionDetector::consume(), MeshStreamer< dtype >::detectorLocalObj_, QdProcess(), and MeshStreamer< dtype >::useCompletionDetection_.

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination ( MeshStreamerMessage< ChunkDataItem > *  msg  )  [inline]

Definition at line 1559 of file NDMeshStreamer.h.

References CompletionDetector::consume(), MeshStreamer< dtype >::detectorLocalObj_, MeshStreamerMessage< dtype >::finalMsgCount, MeshStreamerMessage< dtype >::getDataItem(), envelope::getSrcPe(), MeshStreamer< dtype >::markMessageReceived(), MeshStreamerMessage< dtype >::msgType, MeshStreamer< dtype >::myIndex_, MeshStreamerMessage< dtype >::numDataItems, QdProcess(), MeshStreamer< dtype >::useCompletionDetection_, MeshStreamer< dtype >::useStagedCompletion_, and UsrToEnv().

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localBroadcast ( const ChunkDataItem &  dataItem  )  [inline]

Definition at line 1584 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::localDeliver().

Here is the call graph for this function:

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::initLocalClients (  )  [inline]

Definition at line 1588 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
void GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::pup ( PUP::er &  p  )  [inline]

Definition at line 1592 of file NDMeshStreamer.h.

References CkLocalBranch(), MeshStreamer< dtype >::clientObj_, and PUP::er::isUnpacking().

Here is the call graph for this function:

Field Documentation

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
std::list<ChunkOutOfOrderBuffer> GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::outOfOrderBuffers_ [private]

Definition at line 1389 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
std::vector<ChunkReceiveBuffer> GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::lastReceived_ [private]

Definition at line 1390 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
std::vector<int> GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::currentBufferNumbers_ [private]

Definition at line 1391 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
CkGroupID GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::clientGID_ [private]

Definition at line 1393 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
ClientType* GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::clientObj_ [private]

Definition at line 1394 of file NDMeshStreamer.h.

template<class dtype, class ClientType, class RouterType, int(*)(char *, void *) EntryMethod = defaultMeshStreamerDeliver<dtype,ClientType>>
bool GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::userHandlesFreeing_ [private]

Definition at line 1396 of file NDMeshStreamer.h.

The documentation for this class was generated from the following file:
Generated on Mon Sep 21 08:25:28 2020 for Charm++ by  doxygen 1.5.5