38 #ifndef vtkMPICommunicator_h
39 #define vtkMPICommunicator_h
72 void PrintSelf(ostream& os,
vtkIndent indent);
97 int remoteProcessId,
int tag);
99 int remoteProcessId,
int tag);
108 int NoBlockSend(
const int*
data,
int length,
int remoteProcessId,
int tag,
110 int NoBlockSend(
const unsigned long*
data,
int length,
int remoteProcessId,
112 int NoBlockSend(
const char*
data,
int length,
int remoteProcessId,
114 int NoBlockSend(
const unsigned char*
data,
int length,
int remoteProcessId,
116 int NoBlockSend(
const float*
data,
int length,
int remoteProcessId,
118 int NoBlockSend(
const double*
data,
int length,
int remoteProcessId,
120 #ifdef VTK_USE_64BIT_IDS
131 int NoBlockReceive(
int*
data,
int length,
int remoteProcessId,
133 int NoBlockReceive(
unsigned long*
data,
int length,
134 int remoteProcessId,
int tag,
Request& req);
135 int NoBlockReceive(
char*
data,
int length,
int remoteProcessId,
137 int NoBlockReceive(
unsigned char*
data,
int length,
int remoteProcessId,
139 int NoBlockReceive(
float*
data,
int length,
int remoteProcessId,
141 int NoBlockReceive(
double*
data,
int length,
int remoteProcessId,
143 #ifdef VTK_USE_64BIT_IDS
154 virtual void Barrier();
157 virtual int GatherVoidArray(
const void *sendBuffer,
void *recvBuffer,
159 virtual int GatherVVoidArray(
const void *sendBuffer,
void *recvBuffer,
162 virtual int ScatterVoidArray(
const void *sendBuffer,
void *recvBuffer,
164 virtual int ScatterVVoidArray(
const void *sendBuffer,
void *recvBuffer,
168 virtual int AllGatherVoidArray(
const void *sendBuffer,
void *recvBuffer,
170 virtual int AllGatherVVoidArray(
const void *sendBuffer,
void *recvBuffer,
173 virtual int ReduceVoidArray(
const void *sendBuffer,
void *recvBuffer,
175 int operation,
int destProcessId);
176 virtual int ReduceVoidArray(
const void *sendBuffer,
void *recvBuffer,
178 Operation *operation,
int destProcessId);
179 virtual int AllReduceVoidArray(
const void *sendBuffer,
void *recvBuffer,
182 virtual int AllReduceVoidArray(
const void *sendBuffer,
void *recvBuffer,
195 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource);
196 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource,
198 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource,
200 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource,
202 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource,
204 int Iprobe(
int source,
int tag,
int* flag,
int* actualSource,
215 int WaitAny(
const int count,
Request requests[],
int& idx);
222 const int count,
Request requests[],
int &NCompleted,
int *completed );
228 int TestAll(
const int count,
Request requests[],
int& flag );
231 int TestAny(
const int count,
Request requests[],
int &idx,
int &flag );
239 int& NCompleted,
int *completed);
247 return this->MPIComm;
254 static char* Allocate(
size_t size);
255 static void Free(
char* ptr);
279 int InitializeNumberOfProcesses();
308 virtual int ReceiveDataInternal(
310 int remoteProcessId,
int tag,
312 int useCopy,
int& senderId);
322 static int CheckForMPIError(
int err);
GLsizei GLsizei GLenum GLenum const GLvoid * data
GLuint GLuint GLsizei GLenum type
vtkMPICommunicatorOpaqueRequest * Req
static vtkMPICommunicator * WorldCommunicator
#define vtkGetMacro(name, type)
Class for creating user defined MPI communicators.
GLuint GLuint GLsizei count
GLuint GLsizei GLsizei * length
#define vtkSetClampMacro(name, type, min, max)
vtkMPICommunicatorOpaqueComm * MPIComm
#define vtkTypeMacro(thisClass, superclass)
a simple class to control print indentation
A subgroup of processes from a communicator.
Process communication using MPI.
boost::graph_traits< vtkGraph * >::vertex_descriptor source(boost::graph_traits< vtkGraph * >::edge_descriptor e, vtkGraph *)
#define vtkBooleanMacro(name, type)
Used to send/receive messages in a multiprocess environment.
vtkMPICommunicatorOpaqueComm * GetMPIComm()
#define vtkSetMacro(name, type)
#define VTKPARALLELMPI_EXPORT