The ProcessCommunicator and corresponding buffers (represented by this class) are separated in order to allow share the same buffer by several communicators. More...

#include <processcomm.h>

Inheritance diagram for oofem::ProcessCommunicatorBuff:

Collaboration diagram for oofem::ProcessCommunicatorBuff:

Public Member Functions
	ProcessCommunicatorBuff (CommBuffType t)
	Constructor, creates empty send and receive com buffs in MPI_COMM_WORLD. More...

virtual	~ProcessCommunicatorBuff ()

virtual int	givePackSizeOfInt (int count)

virtual int	givePackSizeOfDouble (int count)

virtual int	givePackSizeOfChar (int count)

virtual int	givePackSizeOfBool (int count)

virtual int	givePackSizeOfLong (int count)

virtual int	write (const int *data, int count)
	Writes count integer values from array pointed by data. More...

virtual int	write (const long *data, int count)
	Writes count long values from array pointed by data. More...

virtual int	write (const unsigned long *data, int count)
	Writes count unsigned long values from array pointed by data. More...

virtual int	write (const double *data, int count)
	Writes count double values from array pointed by data. More...

virtual int	write (const char *data, int count)
	Writes count char values from array pointed by data. More...

virtual int	write (bool data)
	Writes a bool value. More...

virtual int	read (int *data, int count)
	Reads count integer values into array pointed by data. More...

virtual int	read (long *data, int count)
	Reads count long values into array pointed by data. More...

virtual int	read (unsigned long *data, int count)
	Reads count unsigned long values into array pointed by data. More...

virtual int	read (double *data, int count)
	Reads count double values into array pointed by data. More...

virtual int	read (char *data, int count)
	Reads count char values into array pointed by data. More...

virtual int	read (bool &data)
	Reads a bool value from data. More...

void	initSendBuff ()
	Initializes send buffer to empty state. All packed data are lost. More...

void	initRecvBuff ()
	Initializes send buffer to empty state. All packed data are lost. More...

void	init ()
	Initializes receiver buffers. More...

void	initForPacking ()
	Initialize for packing. More...

void	initForUnpacking ()
	Initialize for Unpacking (data already received). More...

int	initExchange (int rank, int tag)
	Initializes data exchange with associated problem. More...

int	initSend (int rank, int tag)
	Initialize the send data exchange with associate problem. More...

int	initReceive (int rank, int tag)
	Initialize the receive data exchange with associate problem. More...

void	clearBuffers ()
	Clears all buffer contents. More...

void	resizeSendBuffer (int size)

void	resizeReceiveBuffer (int size)

CommunicationBuffer *	giveSendBuff ()
	Returns send buffer of receiver. More...

CommunicationBuffer *	giveRecvBuff ()
	Returns receive buffer of receiver. More...

Methods for manipulating/testing receiver state
int	sendCompleted ()

int	receiveCompleted ()

int	testCompletion ()

int	waitCompletion ()

Public Member Functions inherited from oofem::DataStream
virtual	~DataStream ()
	Destructor. More...

int	read (int &data)

int	read (unsigned long &data)

int	read (long &data)

int	read (double &data)

int	read (char &data)

int	read (std::string &data)
	Reads a string (stored as an int for the length followed by char*). More...

int	write (int data)

int	write (unsigned long data)

int	write (long data)

int	write (double data)

int	write (char data)

int	write (const std::string &data)
	Reads a string (stored as an int for the length followed by char*). More...

int	write (const char *data)
	Writes a string (wrapper needed, otherwise write(bool) is called ) More...

Protected Attributes
CommunicationBuffer *	send_buff
	Send buffer. More...

CommunicationBuffer *	recv_buff
	Receive buffer. More...

Detailed Description

The ProcessCommunicator and corresponding buffers (represented by this class) are separated in order to allow share the same buffer by several communicators.

Here sharing means reusing for different but NON-OVERLAPPING communications. if communications overlap, the different instances of ProcessCommunicatorBuff should be used! The ProcessCommunicatorBuff objects are registered in corresponding communicator, then if maps are available, comBuff should be resized and used in subsequent operations.

The registration is necessary, otherwise before each send operation the buffers (given probably as parameter) will be resized again (size have to be computed again) and this is probably quite cost operation. When comBuff will be registered, resize is needed only when maps change, and this will not occur frequently (its even quite rare).

Definition at line 64 of file processcomm.h.

Constructor & Destructor Documentation

oofem::ProcessCommunicatorBuff::ProcessCommunicatorBuff ( CommBuffType t )

Constructor, creates empty send and receive com buffs in MPI_COMM_WORLD.

Definition at line 45 of file processcomm.C.

References oofem::CBT_static, recv_buff, and send_buff.

oofem::ProcessCommunicatorBuff::~ProcessCommunicatorBuff ( )

virtual

Definition at line 66 of file processcomm.C.

Member Function Documentation

void oofem::ProcessCommunicatorBuff::clearBuffers ( )

inline

Clears all buffer contents.

Definition at line 147 of file processcomm.h.

virtual int oofem::ProcessCommunicatorBuff::givePackSizeOfBool ( int count )

inlinevirtual

rank	Partition number.
tag	Message tag.

rank	Partition number.
tag	Message tag.

rank	Partition number.
tag	Message tag.

Public Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation