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

#include <NDMeshStreamer.h>

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

[legend]

Collaboration diagram for GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >:

[legend]

Public Member Functions
	GroupMeshStreamer (int maxNumDataItemsBuffered, int numDimensions, int *dimensionSizes, CkGroupID clientGID, bool yieldFlag=0, double progressPeriodInMs=-1.0)
	GroupMeshStreamer (int numDimensions, int *dimensionSizes, CkGroupID clientGID, int bufferSize, bool yieldFlag=0, double progressPeriodInMs=-1.0)
	GroupMeshStreamer (CkMigrateMessage *)
void	pup (PUP::er &p)
Private Member Functions
void	receiveAtDestination (MeshStreamerMessage< dtype > *msg)
void	localDeliver (const dtype &dataItem)
void	localBroadcast (const dtype &dataItem)
void	initLocalClients ()
Private Attributes
CkGroupID	clientGID_
ClientType *	clientObj_

---

Detailed Description

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

Definition at line 935 of file NDMeshStreamer.h.

---

Constructor & Destructor Documentation

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

GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupMeshStreamer	(	int	maxNumDataItemsBuffered,
		int	numDimensions,
		int *	dimensionSizes,
		CkGroupID	clientGID,
		bool	yieldFlag = 0,
		double	progressPeriodInMs = -1.0
	)			[inline]

Definition at line 982 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>>

GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupMeshStreamer	(	int	numDimensions,
		int *	dimensionSizes,
		CkGroupID	clientGID,
		int	bufferSize,
		bool	yieldFlag = 0,
		double	progressPeriodInMs = -1.0
	)			[inline]

Definition at line 993 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>>

GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::GroupMeshStreamer

(

CkMigrateMessage *

)

[inline]

Definition at line 1004 of file NDMeshStreamer.h.

---

Member Function Documentation

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

void GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination

(

MeshStreamerMessage< dtype > *

msg

)

[inline, private]

Definition at line 942 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::clientObj_, CompletionDetector::consume(), data, MeshStreamer< dtype >::detectorLocalObj_, dtype, 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 GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver

(

const dtype &

dataItem

)

[inline, private]

Definition at line 964 of file NDMeshStreamer.h.

References MeshStreamer< dtype >::clientObj_, 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 GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localBroadcast

(

const dtype &

dataItem

)

[inline, private]

Definition at line 972 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 GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::initLocalClients

(

)

[inline, private]

Definition at line 976 of file NDMeshStreamer.h.

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

void GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::pup

(

PUP::er &

p

)

[inline]

Definition at line 1006 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>>

CkGroupID GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::clientGID_ [private]

Definition at line 939 of file NDMeshStreamer.h.

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

ClientType* GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::clientObj_ [private]

Definition at line 940 of file NDMeshStreamer.h.

---

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

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