43 #ifndef vtkMultiProcessController_h
44 #define vtkMultiProcessController_h
47 #include "vtkParallelCoreModule.h"
51 VTK_ABI_NAMESPACE_BEGIN
69 void* localArg,
void* remoteArg,
int remoteArgLength,
int remoteProcessId);
82 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv)) = 0;
89 virtual void Initialize(
90 int* vtkNotUsed(argc),
char*** vtkNotUsed(argv),
int initializedExternally) = 0;
97 virtual void Finalize() = 0;
104 virtual void Finalize(
int finalizedExternally) = 0;
112 void SetNumberOfProcesses(
int num);
113 int GetNumberOfProcesses();
136 virtual void SingleMethodExecute() = 0;
151 virtual void MultipleMethodExecute() = 0;
156 int GetLocalProcessId();
171 virtual void CreateOutputWindow() = 0;
217 virtual int RemoveFirstRMI(
int tag);
223 virtual int RemoveRMI(
unsigned long id);
233 vtkErrorMacro(
"RemoveRMI Not Implemented Yet");
248 virtual void RemoveAllRMICallbacks(
int tag);
253 virtual bool RemoveRMICallback(
unsigned long id);
258 void TriggerRMI(
int remoteProcessId,
void* arg,
int argLength,
int tag);
264 void TriggerBreakRMIs();
269 void TriggerRMI(
int remoteProcessId,
const char* arg,
int tag)
271 this->TriggerRMI(remoteProcessId, (
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
279 this->TriggerRMI(remoteProcessId,
nullptr, 0, tag);
291 void TriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
294 this->TriggerRMIOnAllChildren((
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
297 void BroadcastTriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
312 int ProcessRMIs(
int reportErrors,
int dont_loop = 0);
314 int BroadcastProcessRMIs(
int reportErrors,
int dont_loop = 0);
323 vtkSetMacro(BreakFlag,
int);
324 vtkGetMacro(BreakFlag,
int);
333 vtkSetMacro(BroadcastTriggerRMI,
bool);
334 vtkGetMacro(BroadcastTriggerRMI,
bool);
335 vtkBooleanMacro(BroadcastTriggerRMI,
bool);
371 XML_WRITER_DATA_INFO = 4
427 int Receive(
int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
428 int Receive(
unsigned int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
429 int Receive(
short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
430 int Receive(
unsigned short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
431 int Receive(
long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
432 int Receive(
unsigned long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
433 int Receive(
char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
434 int Receive(
unsigned char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
435 int Receive(
signed char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
436 int Receive(
float*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
437 int Receive(
double*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
438 int Receive(
long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
439 int Receive(
unsigned long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
471 return this->Communicator->Broadcast(data, length, srcProcessId);
475 return this->Communicator->Broadcast(data, length, srcProcessId);
479 return this->Communicator->Broadcast(data, length, srcProcessId);
483 return this->Communicator->Broadcast(data, length, srcProcessId);
487 return this->Communicator->Broadcast(data, length, srcProcessId);
491 return this->Communicator->Broadcast(data, length, srcProcessId);
495 return this->Communicator->Broadcast(data, length, srcProcessId);
499 return this->Communicator->Broadcast(data, length, srcProcessId);
503 return this->Communicator->Broadcast(data, length, srcProcessId);
507 return this->Communicator->Broadcast(data, length, srcProcessId);
511 return this->Communicator->Broadcast(data, length, srcProcessId);
515 return this->Communicator->Broadcast(data, length, srcProcessId);
519 return this->Communicator->Broadcast(data, length, srcProcessId);
523 return this->Communicator->Broadcast(data, srcProcessId);
527 return this->Communicator->Broadcast(data, srcProcessId);
533 return this->Communicator->Broadcast(stream, srcProcessId);
548 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
551 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int destProcessId)
553 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
557 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
562 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
566 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
569 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int destProcessId)
571 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
574 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int destProcessId)
576 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
580 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
583 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int destProcessId)
585 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
589 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
593 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
596 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int destProcessId)
598 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
603 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
607 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
623 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
636 std::vector<vtkMultiProcessStream>& recvBuffer,
int destProcessId)
638 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
656 return this->Communicator->GatherV(
657 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
659 int GatherV(
const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType sendLength,
662 return this->Communicator->GatherV(
663 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
668 return this->Communicator->GatherV(
669 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
671 int GatherV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType sendLength,
674 return this->Communicator->GatherV(
675 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
680 return this->Communicator->GatherV(
681 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
683 int GatherV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType sendLength,
686 return this->Communicator->GatherV(
687 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
689 int GatherV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType sendLength,
692 return this->Communicator->GatherV(
693 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
698 return this->Communicator->GatherV(
699 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
704 return this->Communicator->GatherV(
705 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
710 return this->Communicator->GatherV(
711 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
716 return this->Communicator->GatherV(
717 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
722 return this->Communicator->GatherV(
723 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
725 int GatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
728 return this->Communicator->GatherV(
729 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
736 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
741 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
753 return this->Communicator->GatherV(sendBuffer, recvBuffer, destProcessId);
757 return this->Communicator->GatherV(sendData, recvData, destProcessId);
771 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
774 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int srcProcessId)
776 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
780 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
785 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
789 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
792 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int srcProcessId)
794 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
797 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int srcProcessId)
799 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
803 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
806 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int srcProcessId)
808 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
812 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
816 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
819 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int srcProcessId)
821 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
823 int Scatter(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
826 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
830 return this->Communicator->Scatter(sendBuffer, recvBuffer, srcProcessId);
845 return this->Communicator->ScatterV(
846 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
851 return this->Communicator->ScatterV(
852 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
857 return this->Communicator->ScatterV(
858 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
860 int ScatterV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType* sendLengths,
863 return this->Communicator->ScatterV(
864 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
869 return this->Communicator->ScatterV(
870 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
872 int ScatterV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType* sendLengths,
875 return this->Communicator->ScatterV(
876 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
878 int ScatterV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType* sendLengths,
881 return this->Communicator->ScatterV(
882 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
887 return this->Communicator->ScatterV(
888 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
893 return this->Communicator->ScatterV(
894 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
899 return this->Communicator->ScatterV(
900 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
905 return this->Communicator->ScatterV(
906 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
911 return this->Communicator->ScatterV(
912 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
914 int ScatterV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
917 return this->Communicator->ScatterV(
918 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
928 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
932 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
936 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
940 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
944 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
948 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
952 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
956 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
960 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
964 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
968 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
972 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
975 const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
vtkIdType length)
977 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
981 return this->Communicator->AllGather(sendBuffer, recvBuffer);
994 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1007 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1017 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1022 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1027 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1032 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1037 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1042 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1047 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1052 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1057 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1062 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1067 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1072 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1074 int AllGatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1077 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1082 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, recvLengths, offsets);
1094 return this->Communicator->AllGatherV(sendBuffer, recvBuffer);
1104 const int* sendBuffer,
int* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1106 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1109 int operation,
int destProcessId)
1111 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1114 const short* sendBuffer,
short* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1116 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1119 int operation,
int destProcessId)
1121 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1124 const long* sendBuffer,
long* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1126 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1129 int operation,
int destProcessId)
1131 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1134 int operation,
int destProcessId)
1136 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1139 const char* sendBuffer,
char* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1141 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1144 int operation,
int destProcessId)
1146 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1149 const float* sendBuffer,
float* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1151 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1156 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1161 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1164 int operation,
int destProcessId)
1166 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1170 return this->Communicator->Reduce(sendBuffer, recvBuffer, operation, destProcessId);
1182 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1187 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1192 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1197 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1202 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1207 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1212 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1217 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1222 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1227 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1232 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1237 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1242 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1247 return this->Communicator->Reduce(sendBuffer, recvBuffer, operation, destProcessId);
1257 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1260 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int operation)
1262 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1266 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1269 const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType length,
int operation)
1271 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1275 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1278 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int operation)
1280 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1283 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int operation)
1285 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1289 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1292 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int operation)
1294 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1298 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1302 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1306 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1308 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1311 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1315 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1322 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1327 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1332 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1337 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1342 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1347 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1352 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1357 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1362 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1367 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1372 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1377 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1379 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1382 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1387 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1410 virtual bool CanProbe() {
return this->Communicator->CanProbe(); };
1424 return this->Communicator->Probe(source, tag, actualSource);
1438 virtual void TriggerRMIInternal(
1439 int remoteProcessId,
void* arg,
int argLength,
int rmiTag,
bool propagate);
1450 void ProcessRMI(
int remoteProcessId,
void* arg,
int argLength,
int rmiTag);
1484 unsigned long RMICount;
1487 vtkInternal* Internal;
1924 VTK_ABI_NAMESPACE_END
int Gather(vtkDataObject *sendBuffer, std::vector< vtkSmartPointer< vtkDataObject >> &recvBuffer, int destProcessId)
Gathers vtkDataObject (sendBuffer) from all ranks to the destProcessId.
int AllGather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllGather(const float *sendBuffer, float *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int Scatter(const int *sendBuffer, int *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
vtkCommunicator * Communicator
void TriggerRMI(int remoteProcessId, int tag)
Convenience method when there is no argument.
void(* vtkProcessFunctionType)(vtkMultiProcessController *controller, void *userData)
int Broadcast(short *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Send(vtkDataObject *data, int remoteHandle, int tag)
This method sends a data object to a destination.
int Scatter(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
A custom operation to use in a reduce command.
int ScatterV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int AllReduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
static int GetRMIArgTag()
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
abstract base class for most VTK objects
int Gather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllGather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllGatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int Scatter(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int ScatterV(const long long *sendBuffer, long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int AllGatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
void PrintSelf(ostream &os, vtkIndent indent) override
Methods invoked by print to print information about the object including superclasses.
int Scatter(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int AllGather(const long *sendBuffer, long *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int GatherV(const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
stream used to pass data across processes using vtkMultiProcessController.
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
void TriggerRMIOnAllChildren(const char *arg, int tag)
This is a convenicence method to trigger an RMI call on all the "children" of the current node...
int ScatterV(const double *sendBuffer, double *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Scatter(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
abstract class to specify dataset behavior
int AllGatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
void TriggerRMIOnAllChildren(int tag)
This is a convenicence method to trigger an RMI call on all the "children" of the current node...
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int GatherV(vtkDataObject *sendData, vtkSmartPointer< vtkDataObject > *recvData, int destProcessId)
This special form of GatherV will automatically determine recvLengths and offsets to tightly pack the...
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
This special form of AllGatherV will automatically determine recvLengths and offsets to tightly pack ...
int Gather(const long *sendBuffer, long *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllGather(const vtkMultiProcessStream &sendBuffer, std::vector< vtkMultiProcessStream > &recvBuffer)
Gathers vtkMultiProcessStream (sendBuffer) from all ranks to the destProcessId.
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation)
int AllGather(vtkDataObject *sendBuffer, std::vector< vtkSmartPointer< vtkDataObject >> &recvBuffer)
Gathers vtkDataObject (sendBuffer) from all ranks to all raks.
a process that can be launched by a vtkMultiProcessController
int GatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllReduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int ScatterV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Gather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Gather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllGatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Broadcast(int *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGather(const short *sendBuffer, short *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation)
Same as Reduce except that the result is placed in all of the processes.
dynamic, self-adjusting array of vtkIdType
vtkOutputWindow * OutputWindow
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int AllGather(const double *sendBuffer, double *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllGather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int ScatterV(const char *sendBuffer, char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int GatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int Gather(const short *sendBuffer, short *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Broadcast(unsigned long long *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
static int GetBreakRMITag()
Accessor to some default tags.
int Receive(vtkDataObject *data, int remoteHandle, int tag)
This method receives a data object from a corresponding send.
int Broadcast(vtkMultiProcessStream &stream, int srcProcessId)
int Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int Scatter(const short *sendBuffer, short *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int ScatterV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int AllGather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllGather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int AllGatherV(const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int Gather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int Broadcast(char *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Scatter(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
vtkDataObject * ReceiveDataObject(int remoteHandle, int tag)
The caller does not have to know the data type before this call is made.
int ScatterV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Gather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
void(* vtkRMIFunctionType)(void *localArg, void *remoteArg, int remoteArgLength, int remoteProcessId)
int Gather(const float *sendBuffer, float *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation, int destProcessId)
Reduce an array to the given destination process.
void TriggerRMI(int remoteProcessId, const char *arg, int tag)
Convenience method when the arg is a string.
int GatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Broadcast(float *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
a simple class to control print indentation
int GatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
topologically and geometrically regular array of data
virtual void RemoveRMI(vtkRMIFunctionType f, void *arg, int tag)
Take an RMI away.
Store on/off settings for data arrays, etc.
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
virtual vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
abstract superclass for arrays of numeric data
A subgroup of processes from a communicator.
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int Broadcast(vtkDataObject *data, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int AllGatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
vtkDataObject * ReceiveDataObject(int remoteId, int tag)
int GatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
Same as gather except that the result ends up on all processes.
int AllGather(const int *sendBuffer, int *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int GatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int ScatterV(const short *sendBuffer, short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
void Barrier()
This method can be used to synchronize processes.
int Broadcast(unsigned int *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
boost::graph_traits< vtkGraph * >::vertex_descriptor source(boost::graph_traits< vtkGraph * >::edge_descriptor e, vtkGraph *)
int Scatter(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int GatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
base class for writing debug output to a console
int AllGatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
vtkProcessFunctionType SingleMethod
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Gather(const vtkMultiProcessStream &sendBuffer, std::vector< vtkMultiProcessStream > &recvBuffer, int destProcessId)
Gathers vtkMultiProcessStream (sendBuffer) from all ranks to the destProcessId.
int Broadcast(unsigned char *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdTypeArray *recvLengths, vtkIdTypeArray *offsets, int destProcessId)
int GatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int AllGatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation)
Same as Reduce except that the result is placed in all of the processes.
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
virtual void Barrier()
Will block the processes until all other processes reach the Barrier function.
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int GatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int ScatterV(const float *sendBuffer, float *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int ScatterV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Send(const int *data, vtkIdType length, int remoteProcessId, int tag)
This method sends data to another process.
create and manipulate ordered lists of objects
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Scatter(const float *sendBuffer, float *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int Gather(const double *sendBuffer, double *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllGatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
vtkCommunicator * RMICommunicator
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int Broadcast(vtkDataArray *data, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Receive(int *data, vtkIdType maxlength, int remoteProcessId, int tag)
This method receives data from a corresponding send.
int AllGather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Broadcast(double *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Broadcast(long long *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int AllGather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int Broadcast(signed char *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Gather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Broadcast(unsigned long *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int Broadcast(unsigned short *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
virtual int Probe(int source, int tag, int *actualSource)
Blocking test for checking for a message tagged with tag from source process (if source == ANY_SOURCE...
int Scatter(const char *sendBuffer, char *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int AllGatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int Scatter(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int GatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllGatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Scatter(const double *sendBuffer, double *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int ScatterV(const long *sendBuffer, long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
virtual bool CanProbe()
Check if this controller implements a probe operation.
Used to send/receive messages in a multiprocess environment.
general representation of visualization data
int Gather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int ScatterV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int AllGatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Same as GatherV except that the result is placed in all processes.
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Broadcast(long *data, vtkIdType length, int srcProcessId)
Broadcast sends the array in the process with id srcProcessId to all of the other processes...
int Gather(const int *sendBuffer, int *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Scatter(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int GatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int GatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
This special form of GatherV will automatically determine recvLengths and offsets to tightly pack the...
Fast, simple class for representing and operating on 3D bounds.
int Gather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int Scatter(const long *sendBuffer, long *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int ScatterV(const int *sendBuffer, int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int Gather(const char *sendBuffer, char *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllGather(const char *sendBuffer, char *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
Multiprocessing communication superclass.