48 #ifndef __vtkMPIController_h
49 #define __vtkMPIController_h
83 int initializedExternally);
93 virtual void Finalize(
int finalizedExternally);
110 static char* ErrorString(
int err);
136 (data ,length, remoteProcessId, tag, req); }
140 (data, length, remoteProcessId, tag, req); }
144 (data, length, remoteProcessId, tag, req); }
148 (data, length, remoteProcessId, tag, req);}
152 (data, length, remoteProcessId, tag, req); }
156 (data, length, remoteProcessId, tag, req); }
168 (data, length, remoteProcessId, tag, req); }
170 int remoteProcessId,
int tag,
173 (data, length, remoteProcessId, tag, req); }
177 (data, length, remoteProcessId, tag, req); }
181 (data, length, remoteProcessId, tag, req); }
185 (data, length, remoteProcessId, tag, req); }
189 (data, length, remoteProcessId, tag, req); }
190 #ifdef VTK_USE_64BIT_IDS
194 (data, length, remoteProcessId, tag, req); }
208 source, tag, flag, actualSource); }
212 source, tag, flag, actualSource, type, size); }
216 source, tag, flag, actualSource, type, size); }
220 source, tag, flag, actualSource, type, size); }
224 source, tag, flag, actualSource, type, size); }
228 source, tag, flag, actualSource, type, size); }
274 static const char* GetProcessorName();
293 void InitializeRMICommunicator();
300 void* arg,
int argLength,
int rmiTag,
bool propagate);
310 friend class vtkMPIOutputWindow;
315 static char ProcessorName[];
int NoBlockSend(const double *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
GLsizei GLsizei GLenum GLenum const GLvoid * data
int NoBlockSend(const unsigned char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
GLuint GLuint GLsizei GLenum type
int NoBlockSend(const unsigned long *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
int WaitAll(const int count, vtkMPICommunicator::Request requests[])
int WaitAny(const int count, vtkMPICommunicator::Request requests[], int &idx)
virtual void Finalize()=0
Class for creating user defined MPI communicators.
int Iprobe(int source, int tag, int *flag, int *actualSource, const char *type, int *size)
GLuint GLuint GLsizei count
GLuint GLsizei GLsizei * length
virtual void TriggerRMIInternal(int remoteProcessId, void *arg, int argLength, int rmiTag, bool propagate)
virtual void MultipleMethodExecute()=0
#define vtkTypeMacro(thisClass, superclass)
static int UseSsendForRMI
int NoBlockReceive(unsigned char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
static void SetUseSsendForRMI(int use_send)
dynamic, self-adjusting array of int
int NoBlockSend(const int *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
virtual void Initialize(int *vtkNotUsed(argc), char ***vtkNotUsed(argv))=0
int NoBlockReceive(unsigned long *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
a simple class to control print indentation
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)
virtual void Initialize(int *argc, char ***argv)
int Iprobe(int source, int tag, int *flag, int *actualSource, double *type, int *size)
virtual void CreateOutputWindow()=0
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)
int NoBlockReceive(char *data, int length, int remoteProcessId, int tag, vtkMPICommunicator::Request &req)
void PrintSelf(ostream &os, vtkIndent indent)
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)
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
virtual vtkMultiProcessController * PartitionController(int localColor, int localKey)
virtual vtkMultiProcessController * CreateSubController(vtkProcessGroup *group)
int Iprobe(int source, int tag, int *flag, int *actualSource)
Multiprocessing communication superclass.
#define VTKPARALLELMPI_EXPORT