55 #ifndef vtkMultiProcessController_h
56 #define vtkMultiProcessController_h
59 #include "vtkParallelCoreModule.h"
80 void* localArg,
void* remoteArg,
int remoteArgLength,
int remoteProcessId);
93 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv)) = 0;
100 virtual void Initialize(
101 int* vtkNotUsed(argc),
char*** vtkNotUsed(argv),
int initializedExternally) = 0;
108 virtual void Finalize() = 0;
115 virtual void Finalize(
int finalizedExternally) = 0;
123 void SetNumberOfProcesses(
int num);
124 int GetNumberOfProcesses();
147 virtual void SingleMethodExecute() = 0;
162 virtual void MultipleMethodExecute() = 0;
167 int GetLocalProcessId();
182 virtual void CreateOutputWindow() = 0;
228 virtual int RemoveFirstRMI(
int tag);
234 virtual int RemoveRMI(
unsigned long id);
244 vtkErrorMacro(
"RemoveRMI Not Implemented Yet");
259 virtual void RemoveAllRMICallbacks(
int tag);
264 virtual bool RemoveRMICallback(
unsigned long id);
269 void TriggerRMI(
int remoteProcessId,
void* arg,
int argLength,
int tag);
275 void TriggerBreakRMIs();
280 void TriggerRMI(
int remoteProcessId,
const char* arg,
int tag)
282 this->TriggerRMI(remoteProcessId, (
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
290 this->TriggerRMI(remoteProcessId,
nullptr, 0, tag);
302 void TriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
305 this->TriggerRMIOnAllChildren((
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
308 void BroadcastTriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
323 int ProcessRMIs(
int reportErrors,
int dont_loop = 0);
325 int BroadcastProcessRMIs(
int reportErrors,
int dont_loop = 0);
334 vtkSetMacro(BreakFlag,
int);
335 vtkGetMacro(BreakFlag,
int);
344 vtkSetMacro(BroadcastTriggerRMI,
bool);
345 vtkGetMacro(BroadcastTriggerRMI,
bool);
346 vtkBooleanMacro(BroadcastTriggerRMI,
bool);
382 XML_WRITER_DATA_INFO = 4
438 int Receive(
int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
439 int Receive(
unsigned int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
440 int Receive(
short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
441 int Receive(
unsigned short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
442 int Receive(
long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
443 int Receive(
unsigned long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
444 int Receive(
char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
445 int Receive(
unsigned char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
446 int Receive(
signed char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
447 int Receive(
float*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
448 int Receive(
double*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
449 int Receive(
long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
450 int Receive(
unsigned long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
482 return this->Communicator->Broadcast(data, length, srcProcessId);
486 return this->Communicator->Broadcast(data, length, srcProcessId);
490 return this->Communicator->Broadcast(data, length, srcProcessId);
494 return this->Communicator->Broadcast(data, length, srcProcessId);
498 return this->Communicator->Broadcast(data, length, srcProcessId);
502 return this->Communicator->Broadcast(data, length, srcProcessId);
506 return this->Communicator->Broadcast(data, length, srcProcessId);
510 return this->Communicator->Broadcast(data, length, srcProcessId);
514 return this->Communicator->Broadcast(data, length, srcProcessId);
518 return this->Communicator->Broadcast(data, length, srcProcessId);
522 return this->Communicator->Broadcast(data, length, srcProcessId);
526 return this->Communicator->Broadcast(data, length, srcProcessId);
530 return this->Communicator->Broadcast(data, length, srcProcessId);
534 return this->Communicator->Broadcast(data, srcProcessId);
538 return this->Communicator->Broadcast(data, srcProcessId);
544 return this->Communicator->Broadcast(stream, srcProcessId);
559 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
562 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int destProcessId)
564 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
568 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
573 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
577 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
580 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int destProcessId)
582 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
585 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int destProcessId)
587 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
591 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
594 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int destProcessId)
596 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
600 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
604 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
607 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int destProcessId)
609 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
614 return this->Communicator->Gather(sendBuffer, recvBuffer, length, destProcessId);
618 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
634 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
647 std::vector<vtkMultiProcessStream>& recvBuffer,
int destProcessId)
649 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
667 return this->Communicator->GatherV(
668 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
670 int GatherV(
const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType sendLength,
673 return this->Communicator->GatherV(
674 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
679 return this->Communicator->GatherV(
680 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
682 int GatherV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType sendLength,
685 return this->Communicator->GatherV(
686 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
691 return this->Communicator->GatherV(
692 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
694 int GatherV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType sendLength,
697 return this->Communicator->GatherV(
698 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
700 int GatherV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType sendLength,
703 return this->Communicator->GatherV(
704 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
709 return this->Communicator->GatherV(
710 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
715 return this->Communicator->GatherV(
716 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
721 return this->Communicator->GatherV(
722 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
727 return this->Communicator->GatherV(
728 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
733 return this->Communicator->GatherV(
734 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
736 int GatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
739 return this->Communicator->GatherV(
740 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
747 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
752 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
764 return this->Communicator->GatherV(sendBuffer, recvBuffer, destProcessId);
768 return this->Communicator->GatherV(sendData, recvData, destProcessId);
782 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
785 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int srcProcessId)
787 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
791 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
796 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
800 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
803 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int srcProcessId)
805 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
808 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int srcProcessId)
810 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
814 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
817 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int srcProcessId)
819 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
823 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
827 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
830 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int srcProcessId)
832 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
834 int Scatter(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
837 return this->Communicator->Scatter(sendBuffer, recvBuffer, length, srcProcessId);
841 return this->Communicator->Scatter(sendBuffer, recvBuffer, srcProcessId);
856 return this->Communicator->ScatterV(
857 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
862 return this->Communicator->ScatterV(
863 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
868 return this->Communicator->ScatterV(
869 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
871 int ScatterV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType* sendLengths,
874 return this->Communicator->ScatterV(
875 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
880 return this->Communicator->ScatterV(
881 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
883 int ScatterV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType* sendLengths,
886 return this->Communicator->ScatterV(
887 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
889 int ScatterV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType* sendLengths,
892 return this->Communicator->ScatterV(
893 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
898 return this->Communicator->ScatterV(
899 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
904 return this->Communicator->ScatterV(
905 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
910 return this->Communicator->ScatterV(
911 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
916 return this->Communicator->ScatterV(
917 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
922 return this->Communicator->ScatterV(
923 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
925 int ScatterV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
928 return this->Communicator->ScatterV(
929 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
939 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
943 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
947 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
951 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
955 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
959 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
963 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
967 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
971 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
975 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
979 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
983 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
986 const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
vtkIdType length)
988 return this->Communicator->AllGather(sendBuffer, recvBuffer, length);
992 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1005 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1018 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1028 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1033 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1038 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1043 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1048 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1053 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1058 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1063 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1068 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1073 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1078 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1083 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1085 int AllGatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1088 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1093 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, recvLengths, offsets);
1105 return this->Communicator->AllGatherV(sendBuffer, recvBuffer);
1115 const int* sendBuffer,
int* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1117 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1120 int operation,
int destProcessId)
1122 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1125 const short* sendBuffer,
short* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1127 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1130 int operation,
int destProcessId)
1132 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1135 const long* sendBuffer,
long* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1137 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1140 int operation,
int destProcessId)
1142 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1145 int operation,
int destProcessId)
1147 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1150 const char* sendBuffer,
char* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1152 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1155 int operation,
int destProcessId)
1157 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1160 const float* sendBuffer,
float* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1162 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1167 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1172 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1175 int operation,
int destProcessId)
1177 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1181 return this->Communicator->Reduce(sendBuffer, recvBuffer, operation, destProcessId);
1193 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1198 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1203 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1208 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1213 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1218 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1223 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1228 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1233 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1238 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1243 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1248 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1253 return this->Communicator->Reduce(sendBuffer, recvBuffer, length, operation, destProcessId);
1258 return this->Communicator->Reduce(sendBuffer, recvBuffer, operation, destProcessId);
1268 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1271 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int operation)
1273 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1277 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1280 const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType length,
int operation)
1282 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1286 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1289 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int operation)
1291 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1294 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int operation)
1296 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1300 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1303 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int operation)
1305 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1309 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1313 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1317 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1319 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1322 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1326 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1333 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1338 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1343 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1348 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1353 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1358 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1363 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1368 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1373 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1378 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1383 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1388 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1390 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1393 return this->Communicator->AllReduce(sendBuffer, recvBuffer, length, operation);
1398 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1429 virtual void TriggerRMIInternal(
1430 int remoteProcessId,
void* arg,
int argLength,
int rmiTag,
bool propagate);
1441 void ProcessRMI(
int remoteProcessId,
void* arg,
int argLength,
int rmiTag);
1475 unsigned long RMICount;
1478 vtkInternal* Internal;
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...
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...
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.
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.