vtkMPIController Class Reference

#include <vtkMPIController.h>

Inheritance diagram for vtkMPIController:

[legend]

Collaboration diagram for vtkMPIController:

[legend]

List of all members.

Detailed Description

Process communication using MPI.

vtkMPIController is a concrete class which implements the abstract multi-process control methods defined in vtkMultiProcessController using MPI (Message Passing Interface) cf. Using MPI / Portable Parallel Programming with the Message-Passing Interface, Gropp et al, MIT Press. It also provide functionality specific to MPI and not present in vtkMultiProcessController. Before any MPI communication can occur Initialize() must be called by all processes. It is required to be called once, controllers created after this need not call Initialize(). At the end of the program Finalize() must be called by all processes.

The use of user-defined communicators are supported with the CreateSubController method. Note that a duplicate of the user defined communicator is used for internal communications (RMIs). This communicator has the same properties as the user one except that it has a new context which prevents the two communicators from interfering with each other.

See also:: vtkOutputPort vtkInputPort vtkMultiProcessController vtkMPICommunicator vtkProcessGroup

Tests:: vtkMPIController (Tests)

Definition at line 54 of file vtkMPIController.h.


static const char *	GetProcessorName ()
static void	SetUseSsendForRMI (int use_send)
static int	GetUseSsendForRMI ()
int	NoBlockReceive (int *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockReceive (unsigned long *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockReceive (char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockReceive (float *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
Public Types
typedef vtkMultiProcessController	Superclass
Public Member Functions
virtual const char *	GetClassName ()
virtual int	IsA (const char *type)
void	PrintSelf (ostream &os, vtkIndent indent)
virtual void	Initialize (int vtkNotUsed(argc), char **vtkNotUsed(argv), int initializedExternally)
virtual void	Finalize ()
virtual void	Finalize (int finalizedExternally)
virtual void	SingleMethodExecute ()
virtual void	MultipleMethodExecute ()
virtual void	CreateOutputWindow ()
void	SetCommunicator (vtkMPICommunicator *comm)
virtual vtkMPIController *	CreateSubController (vtkProcessGroup *group)

virtual void	Initialize (int argc, char **argv)

int	NoBlockSend (const int *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockSend (const unsigned long *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockSend (const char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int	NoBlockSend (const float *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
Static Public Member Functions
static vtkMPIController *	New ()
static int	IsTypeOf (const char *type)
static vtkMPIController *	SafeDownCast (vtkObject *o)
static char *	ErrorString (int err)
Protected Member Functions
	vtkMPIController ()
	~vtkMPIController ()
void	InitializeCommunicator (vtkMPICommunicator *comm)
void	InitializeRMICommunicator ()

virtual void	TriggerRMIInternal (int remoteProcessId, void *arg, int argLength, int rmiTag, bool propagate)
Static Protected Attributes
static vtkMPICommunicator *	WorldRMICommunicator
static int	Initialized
static char	ProcessorName []
static int	UseSsendForRMI
Friends
class	vtkMPIOutputWindow

Member Typedef Documentation

typedef vtkMultiProcessController vtkMPIController::Superclass

Reimplemented from vtkMultiProcessController.

Definition at line 60 of file vtkMPIController.h.

Constructor & Destructor Documentation

vtkMPIController::vtkMPIController ( ) [protected]

vtkMPIController::~vtkMPIController ( ) [protected]

Member Function Documentation

static vtkMPIController* vtkMPIController::New ( ) [static]

Create an object with Debug turned off, modified time initialized to zero, and reference counting on.

Reimplemented from vtkObject.

virtual const char* vtkMPIController::GetClassName ( ) [virtual]

Reimplemented from vtkMultiProcessController.

static int vtkMPIController::IsTypeOf ( const char * name ) [static]

Return 1 if this class type is the same type of (or a subclass of) the named class. Returns 0 otherwise. This method works in combination with vtkTypeRevisionMacro found in vtkSetGet.h.

Reimplemented from vtkMultiProcessController.

virtual int vtkMPIController::IsA ( const char * name ) [virtual]

Return 1 if this class is the same type of (or a subclass of) the named class. Returns 0 otherwise. This method works in combination with vtkTypeRevisionMacro found in vtkSetGet.h.

Reimplemented from vtkMultiProcessController.

static vtkMPIController* vtkMPIController::SafeDownCast ( vtkObject * o ) [static]

Reimplemented from vtkMultiProcessController.

void vtkMPIController::PrintSelf	(	ostream &	os,
		vtkIndent	indent
	)			`[virtual]`

Methods invoked by print to print information about the object including superclasses. Typically not called by the user (use Print() instead) but used in the hierarchical print process to combine the output of several classes.

Reimplemented from vtkMultiProcessController.

virtual void vtkMPIController::Initialize	(	int *	argc,
		char ***	argv
	)			`[inline, virtual]`

This method is for setting up the processes. It needs to be called only once during program execution. Calling it more than once will have no effect. Controllers created after this call will be initialized automatically (i.e. they will have the proper LocalProcessId and NumberOfProcesses). The addresses of argc and argv should be passed to this method otherwise command line arguments will not be correct (because usually MPI implementations add their own arguments during startup).

Definition at line 72 of file vtkMPIController.h.

virtual void vtkMPIController::Initialize	(	int *	vtkNotUsedargc,
		char ***	vtkNotUsedargv,
		int	initializedExternally
	)			`[virtual]`

This method is for setting up the processes. If a subclass needs to initialize process communication (i.e. MPI) it would over ride this method. Provided for initialization outside vtk.

Implements vtkMultiProcessController.

virtual void vtkMPIController::Finalize ( ) [inline, virtual]

This method is for cleaning up and has to be called before the end of the program if MPI was initialized with Initialize()

Implements vtkMultiProcessController.

Definition at line 81 of file vtkMPIController.h.

virtual void vtkMPIController::Finalize ( int finalizedExternally ) [virtual]

This method is for cleaning up. If a subclass needs to clean up process communication (i.e. MPI) it would over ride this method. Provided for finalization outside vtk.

Implements vtkMultiProcessController.

virtual void vtkMPIController::SingleMethodExecute ( ) [virtual]

Execute the SingleMethod (as define by SetSingleMethod) using this->NumberOfProcesses processes.

Implements vtkMultiProcessController.

virtual void vtkMPIController::MultipleMethodExecute ( ) [virtual]

Execute the MultipleMethods (as define by calling SetMultipleMethod for each of the required this->NumberOfProcesses methods) using this->NumberOfProcesses processes.

Implements vtkMultiProcessController.

virtual void vtkMPIController::CreateOutputWindow ( ) [virtual]

This method can be used to tell the controller to create a special output window in which all messages are preceded by the process id.

Implements vtkMultiProcessController.

static char* vtkMPIController::ErrorString ( int err ) [static]

Given an MPI error code, return a string which contains an error message. This string has to be freed by the user.

void vtkMPIController::SetCommunicator ( vtkMPICommunicator * comm )

MPIController uses this communicator in all sends and receives. By default, MPI_COMM_WORLD is used. THIS SHOULD ONLY BE CALLED ON THE PROCESSES INCLUDED IN THE COMMUNICATOR. FOR EXAMPLE, IF THE COMMUNICATOR CONTAINES PROCESSES 0 AND 1, INVOKING THIS METHOD ON ANY OTHER PROCESS WILL CAUSE AN MPI ERROR AND POSSIBLY LEAD TO A CRASH.

virtual vtkMPIController* vtkMPIController::CreateSubController ( vtkProcessGroup * group ) [virtual]

Creates a new controller with the processes specified by the given group. The new controller will already be initialized for you. You are responsible for deleting the controller once you are done. It is invalid to pass this method a group with a different communicator than is used by this controller. This operation is collective accross all processes defined in the group. It is undefined what will happen if the group is not the same on all processes. This method must be called by all processes in the controller regardless of whether they are in the group. NULL is returned on all process not in the group.

Reimplemented from vtkMultiProcessController.

int vtkMPIController::NoBlockSend	(	const int *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`

This method sends data to another process (non-blocking). Tag eliminates ambiguity when multiple sends or receives exist in the same process. The last argument, vtkMPICommunicator::Request& req can later be used (with req.Test() ) to test the success of the message. Note: These methods delegate to the communicator

Definition at line 120 of file vtkMPIController.h.

int vtkMPIController::NoBlockSend	(	const unsigned long *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`

This method sends data to another process (non-blocking). Tag eliminates ambiguity when multiple sends or receives exist in the same process. The last argument, vtkMPICommunicator::Request& req can later be used (with req.Test() ) to test the success of the message. Note: These methods delegate to the communicator

Definition at line 124 of file vtkMPIController.h.

int vtkMPIController::NoBlockSend	(	const char *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`

This method sends data to another process (non-blocking). Tag eliminates ambiguity when multiple sends or receives exist in the same process. The last argument, vtkMPICommunicator::Request& req can later be used (with req.Test() ) to test the success of the message. Note: These methods delegate to the communicator

Definition at line 128 of file vtkMPIController.h.

int vtkMPIController::NoBlockSend	(	const float *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`

This method sends data to another process (non-blocking). Tag eliminates ambiguity when multiple sends or receives exist in the same process. The last argument, vtkMPICommunicator::Request& req can later be used (with req.Test() ) to test the success of the message. Note: These methods delegate to the communicator

Definition at line 132 of file vtkMPIController.h.

int vtkMPIController::NoBlockReceive	(	int *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`

This method receives data from a corresponding send (non-blocking). The last argument, vtkMPICommunicator::Request& req can later be used (with req.Test() ) to test the success of the message. Note: These methods delegate to the communicator

Definition at line 143 of file vtkMPIController.h.

int vtkMPIController::NoBlockReceive	(	unsigned long *	data,
		int	length,
		int	remoteProcessId,
		int	tag,
		vtkMPICommunicator::Request &	req
	)			`[inline]`