43 #ifndef vtkMPIController_h
44 #define vtkMPIController_h
46 #include "vtkParallelMPIModule.h"
75 virtual void Initialize(
int* argc,
char*** argv) VTK_OVERRIDE
78 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv),
79 int initializedExternally) VTK_OVERRIDE;
93 virtual void Finalize(
int finalizedExternally) VTK_OVERRIDE;
106 virtual
void MultipleMethodExecute() VTK_OVERRIDE;
113 virtual
void CreateOutputWindow() VTK_OVERRIDE;
119 static
char* ErrorString(
int err);
135 virtual
vtkMPIController *PartitionController(
int localColor,
int localKey) VTK_OVERRIDE;
146 int NoBlockSend(const
int*
data,
int length,
int remoteProcessId,
int tag,
149 (data ,length, remoteProcessId, tag, req); }
153 (data, length, remoteProcessId, tag, req); }
157 (data, length, remoteProcessId, tag, req); }
161 (data, length, remoteProcessId, tag, req);}
165 (data, length, remoteProcessId, tag, req); }
169 (data, length, remoteProcessId, tag, req); }
170 #ifdef VTK_USE_64BIT_IDS
174 (data, length, remoteProcessId, tag, req); }
188 (data, length, remoteProcessId, tag, req); }
190 int remoteProcessId,
int tag,
193 (data, length, remoteProcessId, tag, req); }
197 (data, length, remoteProcessId, tag, req); }
201 (data, length, remoteProcessId, tag, req); }
205 (data, length, remoteProcessId, tag, req); }
209 (data, length, remoteProcessId, tag, req); }
210 #ifdef VTK_USE_64BIT_IDS
211 int NoBlockReceive(
vtkIdType* data,
int length,
int remoteProcessId,
214 (data, length, remoteProcessId, tag, req); }
229 source, tag, flag, actualSource); }
233 source, tag, flag, actualSource, type, size); }
237 source, tag, flag, actualSource, type, size); }
241 source, tag, flag, actualSource, type, size); }
245 source, tag, flag, actualSource, type, size); }
249 source, tag, flag, actualSource, type, size); }
298 static const char* GetProcessorName();
316 void InitializeRMICommunicator();
324 void* arg,
int argLength,
int rmiTag,
bool propagate) VTK_OVERRIDE;
333 friend class vtkMPIOutputWindow;
338 static char ProcessorName[];
int NoBlockSend(const double *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int NoBlockSend(const unsigned char *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 WaitAll(const int count, vtkMPICommunicator::Request requests[])
Given the request objects of a set of non-blocking operations (send and/or receive) this method block...
int WaitAny(const int count, vtkMPICommunicator::Request requests[], int &idx)
Blocks until one of the specified requests in the given request array completes.
virtual void Finalize()=0
This method is for cleaning up.
Class for creating user defined MPI communicators.
int Iprobe(int source, int tag, int *flag, int *actualSource, const char *type, int *size)
virtual void TriggerRMIInternal(int remoteProcessId, void *arg, int argLength, int rmiTag, bool propagate)
Implementation for TriggerRMI() provides subclasses an opportunity to modify the behaviour eg...
static int UseSsendForRMI
When set, TriggerRMI uses Ssend instead of Send.
int NoBlockReceive(unsigned char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
static void SetUseSsendForRMI(int use_send)
When set to 1, TriggerRMI uses Ssend() instead of Send() calls.
dynamic, self-adjusting array of int
int NoBlockSend(const int *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
This method sends data to another process (non-blocking).
virtual void Initialize(int *vtkNotUsed(argc), char ***vtkNotUsed(argv))=0
This method is for setting up the processes.
int NoBlockReceive(unsigned long *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
a simple class to control print indentation
void PrintSelf(ostream &os, vtkIndent indent) override
Methods invoked by print to print information about the object including superclasses.
virtual void Initialize(int *argc, char ***argv) override
This method is for setting up the processes.
A subgroup of processes from a communicator.
Process communication using MPI.
static vtkMPICommunicator * WorldRMICommunicator
int NoBlockReceive(float *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int Iprobe(int source, int tag, int *flag, int *actualSource, double *type, int *size)
int NoBlockSend(const char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
boost::graph_traits< vtkGraph * >::vertex_descriptor source(boost::graph_traits< vtkGraph * >::edge_descriptor e, vtkGraph *)
int Iprobe(int source, int tag, int *flag, int *actualSource, unsigned long *type, int *size)
int NoBlockReceive(double *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
virtual void Finalize() override
This method is for cleaning up and has to be called before the end of the program if MPI was initiali...
int NoBlockReceive(char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int Iprobe(int source, int tag, int *flag, int *actualSource, float *type, int *size)
static int GetUseSsendForRMI()
int NoBlockReceive(int *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
This method receives data from a corresponding send (non-blocking).
static vtkObject * New()
Create an object with Debug turned off, modified time initialized to zero, and reference counting on...
int NoBlockSend(const float *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int Iprobe(int source, int tag, int *flag, int *actualSource, int *type, int *size)
virtual void SingleMethodExecute()=0
Execute the SingleMethod (as define by SetSingleMethod) using this->NumberOfProcesses processes...
int Iprobe(int source, int tag, int *flag, int *actualSource)
Nonblocking test for a message.
Multiprocessing communication superclass.