 |
VTK
9.0.20210227
|
Go to the documentation of this file.
49 #ifndef vtkMultiProcessController_h
50 #define vtkMultiProcessController_h
53 #include "vtkParallelCoreModule.h"
74 void* localArg,
void* remoteArg,
int remoteArgLength,
int remoteProcessId);
87 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv)) = 0;
94 virtual void Initialize(
95 int* vtkNotUsed(argc),
char*** vtkNotUsed(argv),
int initializedExternally) = 0;
102 virtual void Finalize() = 0;
109 virtual void Finalize(
int finalizedExternally) = 0;
117 void SetNumberOfProcesses(
int num);
118 int GetNumberOfProcesses();
141 virtual void SingleMethodExecute() = 0;
156 virtual void MultipleMethodExecute() = 0;
161 int GetLocalProcessId();
176 virtual void CreateOutputWindow() = 0;
222 virtual int RemoveFirstRMI(
int tag);
228 virtual int RemoveRMI(
unsigned long id);
238 vtkErrorMacro(
"RemoveRMI Not Implemented Yet");
253 virtual void RemoveAllRMICallbacks(
int tag);
258 virtual bool RemoveRMICallback(
unsigned long id);
263 void TriggerRMI(
int remoteProcessId,
void* arg,
int argLength,
int tag);
269 void TriggerBreakRMIs();
274 void TriggerRMI(
int remoteProcessId,
const char* arg,
int tag)
276 this->TriggerRMI(remoteProcessId, (
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
284 this->TriggerRMI(remoteProcessId,
nullptr, 0, tag);
296 void TriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
299 this->TriggerRMIOnAllChildren((
void*)arg, static_cast<int>(strlen(arg)) + 1, tag);
302 void BroadcastTriggerRMIOnAllChildren(
void* arg,
int argLength,
int tag);
317 int ProcessRMIs(
int reportErrors,
int dont_loop = 0);
319 int BroadcastProcessRMIs(
int reportErrors,
int dont_loop = 0);
328 vtkSetMacro(BreakFlag,
int);
329 vtkGetMacro(BreakFlag,
int);
338 vtkSetMacro(BroadcastTriggerRMI,
bool);
339 vtkGetMacro(BroadcastTriggerRMI,
bool);
340 vtkBooleanMacro(BroadcastTriggerRMI,
bool);
376 XML_WRITER_DATA_INFO = 4
432 int Receive(
int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
433 int Receive(
unsigned int*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
434 int Receive(
short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
435 int Receive(
unsigned short*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
436 int Receive(
long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
437 int Receive(
unsigned long*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
438 int Receive(
char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
439 int Receive(
unsigned char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
440 int Receive(
signed char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
441 int Receive(
float*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
442 int Receive(
double*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
443 int Receive(
long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
444 int Receive(
unsigned long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
476 return this->Communicator->Broadcast(
data,
length, srcProcessId);
480 return this->Communicator->Broadcast(
data,
length, srcProcessId);
484 return this->Communicator->Broadcast(
data,
length, srcProcessId);
488 return this->Communicator->Broadcast(
data,
length, srcProcessId);
492 return this->Communicator->Broadcast(
data,
length, srcProcessId);
496 return this->Communicator->Broadcast(
data,
length, srcProcessId);
500 return this->Communicator->Broadcast(
data,
length, srcProcessId);
504 return this->Communicator->Broadcast(
data,
length, srcProcessId);
508 return this->Communicator->Broadcast(
data,
length, srcProcessId);
512 return this->Communicator->Broadcast(
data,
length, srcProcessId);
516 return this->Communicator->Broadcast(
data,
length, srcProcessId);
520 return this->Communicator->Broadcast(
data,
length, srcProcessId);
524 return this->Communicator->Broadcast(
data,
length, srcProcessId);
528 return this->Communicator->Broadcast(
data, srcProcessId);
532 return this->Communicator->Broadcast(
data, srcProcessId);
538 return this->Communicator->Broadcast(stream, srcProcessId);
553 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
556 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int destProcessId)
558 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
562 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
567 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
571 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
574 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int destProcessId)
576 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
579 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int destProcessId)
581 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
585 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
588 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int destProcessId)
590 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
594 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
598 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
601 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int destProcessId)
603 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
608 return this->Communicator->Gather(sendBuffer, recvBuffer,
length, destProcessId);
612 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
631 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
644 std::vector<vtkMultiProcessStream>& recvBuffer,
int destProcessId)
646 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
664 return this->Communicator->GatherV(
665 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
667 int GatherV(
const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType sendLength,
670 return this->Communicator->GatherV(
671 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
676 return this->Communicator->GatherV(
677 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
679 int GatherV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType sendLength,
682 return this->Communicator->GatherV(
683 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
688 return this->Communicator->GatherV(
689 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
691 int GatherV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType sendLength,
694 return this->Communicator->GatherV(
695 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
697 int GatherV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType sendLength,
700 return this->Communicator->GatherV(
701 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
706 return this->Communicator->GatherV(
707 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
712 return this->Communicator->GatherV(
713 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
718 return this->Communicator->GatherV(
719 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
724 return this->Communicator->GatherV(
725 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
730 return this->Communicator->GatherV(
731 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
733 int GatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
736 return this->Communicator->GatherV(
737 sendBuffer, recvBuffer, sendLength, recvLengths, offsets, destProcessId);
744 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
749 return this->Communicator->GatherV(sendBuffer, recvBuffer, recvLengths, offsets, destProcessId);
761 return this->Communicator->GatherV(sendBuffer, recvBuffer, destProcessId);
765 return this->Communicator->GatherV(sendData, recvData, destProcessId);
779 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
782 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int srcProcessId)
784 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
788 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
793 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
797 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
800 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int srcProcessId)
802 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
805 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int srcProcessId)
807 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
811 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
814 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int srcProcessId)
816 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
820 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
824 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
827 const long long* sendBuffer,
long long* recvBuffer,
vtkIdType length,
int srcProcessId)
829 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
831 int Scatter(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
834 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length, srcProcessId);
838 return this->Communicator->Scatter(sendBuffer, recvBuffer, srcProcessId);
853 return this->Communicator->ScatterV(
854 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
859 return this->Communicator->ScatterV(
860 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
865 return this->Communicator->ScatterV(
866 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
868 int ScatterV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType* sendLengths,
871 return this->Communicator->ScatterV(
872 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
877 return this->Communicator->ScatterV(
878 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
880 int ScatterV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType* sendLengths,
883 return this->Communicator->ScatterV(
884 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
886 int ScatterV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType* sendLengths,
889 return this->Communicator->ScatterV(
890 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
895 return this->Communicator->ScatterV(
896 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
901 return this->Communicator->ScatterV(
902 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
907 return this->Communicator->ScatterV(
908 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
913 return this->Communicator->ScatterV(
914 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
919 return this->Communicator->ScatterV(
920 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
922 int ScatterV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
925 return this->Communicator->ScatterV(
926 sendBuffer, recvBuffer, sendLengths, offsets, recvLength, srcProcessId);
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);
976 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
980 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
983 const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
vtkIdType length)
985 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
989 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1003 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1013 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1018 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1023 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
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);
1070 int AllGatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1073 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, sendLength, recvLengths, offsets);
1078 return this->Communicator->AllGatherV(sendBuffer, recvBuffer, recvLengths, offsets);
1090 return this->Communicator->AllGatherV(sendBuffer, recvBuffer);
1100 const int* sendBuffer,
int* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1102 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1105 int operation,
int destProcessId)
1107 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1110 const short* sendBuffer,
short* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1112 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1115 int operation,
int destProcessId)
1117 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1120 const long* sendBuffer,
long* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1122 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1125 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 char* sendBuffer,
char* 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 const float* sendBuffer,
float* recvBuffer,
vtkIdType length,
int operation,
int destProcessId)
1147 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1152 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1157 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1160 int operation,
int destProcessId)
1162 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1166 return this->Communicator->Reduce(sendBuffer, recvBuffer, operation, destProcessId);
1178 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1183 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, operation, destProcessId);
1188 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length, 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, operation, destProcessId);
1253 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1256 const unsigned int* sendBuffer,
unsigned int* recvBuffer,
vtkIdType length,
int operation)
1258 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1262 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1265 const unsigned short* sendBuffer,
unsigned short* recvBuffer,
vtkIdType length,
int operation)
1267 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1271 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1274 const unsigned long* sendBuffer,
unsigned long* recvBuffer,
vtkIdType length,
int operation)
1276 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1279 const unsigned char* sendBuffer,
unsigned char* recvBuffer,
vtkIdType length,
int operation)
1281 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1285 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1288 const signed char* sendBuffer,
signed char* recvBuffer,
vtkIdType length,
int operation)
1290 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, 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);
1304 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1307 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1311 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1318 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1323 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1328 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, 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);
1375 int AllReduce(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1378 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length, operation);
1383 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1414 virtual void TriggerRMIInternal(
1415 int remoteProcessId,
void* arg,
int argLength,
int rmiTag,
bool propagate);
1426 void ProcessRMI(
int remoteProcessId,
void* arg,
int argLength,
int rmiTag);
1460 unsigned long RMICount;
1463 vtkInternal* Internal;
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdTypeArray *recvLengths, vtkIdTypeArray *offsets, int destProcessId)
int Scatter(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int srcProcessId)
void TriggerRMIOnAllChildren(const char *arg, int tag)
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation)
int Receive(vtkDataObject *data, int remoteHandle, int tag)
This method receives a data object from a corresponding send.
int Broadcast(long *data, vtkIdType length, int srcProcessId)
int AllGatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
vtkCommunicator * RMICommunicator
int AllGather(const long *sendBuffer, long *recvBuffer, vtkIdType length)
int AllGather(const vtkMultiProcessStream &sendBuffer, std::vector< vtkMultiProcessStream > &recvBuffer)
Gathers vtkMultiProcessStream (sendBuffer) from all ranks to the destProcessId.
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Scatter(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int srcProcessId)
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
vtkDataObject * ReceiveDataObject(int remoteId, int tag)
void(* vtkProcessFunctionType)(vtkMultiProcessController *controller, void *userData)
int Broadcast(long long *data, vtkIdType length, int srcProcessId)
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Receive(int *data, vtkIdType maxlength, int remoteProcessId, int tag)
This method receives data from a corresponding send.
int AllGatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Broadcast(unsigned long *data, vtkIdType length, int srcProcessId)
int GatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllGatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
Used to send/receive messages in a multiprocess environment.
vtkCommunicator * Communicator
int Gather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Scatter(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int srcProcessId)
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
vtkProcessFunctionType SingleMethod
int Scatter(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int srcProcessId)
int Broadcast(unsigned char *data, vtkIdType length, int srcProcessId)
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int GatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllGather(const double *sendBuffer, double *recvBuffer, vtkIdType length)
int ScatterV(const long *sendBuffer, long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
A custom operation to use in a reduce command.
stream used to pass data across processes using vtkMultiProcessController.
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Broadcast(unsigned long long *data, vtkIdType length, int srcProcessId)
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation, int destProcessId)
int GatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation, int destProcessId)
int AllGather(const short *sendBuffer, short *recvBuffer, vtkIdType length)
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation)
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
virtual void Barrier()
Will block the processes until all other processes reach the Barrier function.
int Gather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int destProcessId)
abstract base class for most VTK objects
int Broadcast(vtkDataArray *data, int srcProcessId)
int GatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Gather(const char *sendBuffer, char *recvBuffer, vtkIdType length, int destProcessId)
int Gather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int destProcessId)
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
This special form of GatherV will automatically determine recvLengths and offsets to tightly pack the...
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.
abstract superclass for arrays of numeric data
void TriggerRMIOnAllChildren(int tag)
int Broadcast(signed char *data, vtkIdType length, int srcProcessId)
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation, int destProcessId)
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
This special form of AllGatherV will automatically determine recvLengths and offsets to tightly pack ...
int AllGather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length)
int Broadcast(double *data, vtkIdType length, int srcProcessId)
int AllGather(const int *sendBuffer, int *recvBuffer, vtkIdType length)
Same as gather except that the result ends up on all processes.
int AllGather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length)
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 Broadcast(unsigned int *data, vtkIdType length, int srcProcessId)
int Gather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int destProcessId)
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation)
int AllGatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets)
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation, int destProcessId)
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 short *sendBuffer, unsigned short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Broadcast(float *data, vtkIdType length, int srcProcessId)
int Scatter(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int srcProcessId)
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation)
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation)
Store on/off settings for data arrays for a vtkSource.
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int AllReduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Fast, simple class for representing and operating on 3D bounds.
int AllGather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length)
int ScatterV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
create and manipulate ordered lists of objects
int GatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int ScatterV(const float *sendBuffer, float *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Broadcast(vtkDataObject *data, int srcProcessId)
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Scatter(const long *sendBuffer, long *recvBuffer, vtkIdType length, int srcProcessId)
int AllGather(const char *sendBuffer, char *recvBuffer, vtkIdType length)
int Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
Multiprocessing communication superclass.
int GatherV(vtkDataObject *sendData, vtkSmartPointer< vtkDataObject > *recvData, int destProcessId)
int Gather(const long *sendBuffer, long *recvBuffer, vtkIdType length, int destProcessId)
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation)
int Broadcast(unsigned short *data, vtkIdType length, int srcProcessId)
base class for writing debug output to a console
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
void(* vtkRMIFunctionType)(void *localArg, void *remoteArg, int remoteArgLength, int remoteProcessId)
int Scatter(const int *sendBuffer, int *recvBuffer, vtkIdType length, int srcProcessId)
Scatter takes an array in the process with id srcProcessId and distributes it.
int AllGather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
topologically and geometrically regular array of data
int Scatter(const char *sendBuffer, char *recvBuffer, vtkIdType length, int srcProcessId)
a simple class to control print indentation
int GatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
static int GetRMIArgTag()
int Scatter(const double *sendBuffer, double *recvBuffer, vtkIdType length, int srcProcessId)
int ScatterV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
void Barrier()
This method can be used to synchronize processes.
int AllGatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation)
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation)
int AllGatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
void PrintSelf(ostream &os, vtkIndent indent) override
Methods invoked by print to print information about the object including superclasses.
int Gather(const int *sendBuffer, int *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Scatter(const short *sendBuffer, short *recvBuffer, vtkIdType length, int srcProcessId)
int ScatterV(const char *sendBuffer, char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int GatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Broadcast(vtkMultiProcessStream &stream, int srcProcessId)
int GatherV(const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
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 AllGather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length)
int ScatterV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int ScatterV(const int *sendBuffer, int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int AllGatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Send(const int *data, vtkIdType length, int remoteProcessId, int tag)
This method sends data to another process.
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
abstract class to specify dataset behavior
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation)
a process that can be launched by a vtkMultiProcessController
int AllGather(const float *sendBuffer, float *recvBuffer, vtkIdType length)
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Broadcast(short *data, vtkIdType length, int srcProcessId)
A subgroup of processes from a communicator.
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Gather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int destProcessId)
dynamic, self-adjusting array of vtkIdType
int Send(vtkDataObject *data, int remoteHandle, int tag)
This method sends a data object to a destination.
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation, int destProcessId)
int ScatterV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Gather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int destProcessId)
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation)
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation)
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Gather(const float *sendBuffer, float *recvBuffer, vtkIdType length, int destProcessId)
int ScatterV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Scatter(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int srcProcessId)
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation)
int AllGather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length)
virtual vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
int AllGatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
vtkOutputWindow * OutputWindow
int AllGather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length)
int ScatterV(const double *sendBuffer, double *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Gather(const short *sendBuffer, short *recvBuffer, vtkIdType length, int destProcessId)
static int GetBreakRMITag()
Accessor to some default tags.
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation)
int GatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
virtual void RemoveRMI(vtkRMIFunctionType f, void *arg, int tag)
Take an RMI away.
int Scatter(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int srcProcessId)
int Scatter(const float *sendBuffer, float *recvBuffer, vtkIdType length, int srcProcessId)
int Gather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int destProcessId)
int Gather(const double *sendBuffer, double *recvBuffer, vtkIdType length, int destProcessId)
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
void TriggerRMI(int remoteProcessId, int tag)
Convenience method when there is no argument.
int Gather(vtkDataObject *sendBuffer, std::vector< vtkSmartPointer< vtkDataObject >> &recvBuffer, int destProcessId)
Gathers vtkDataObject (sendBuffer) from all ranks to the destProcessId.
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int GatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
general representation of visualization data
int Broadcast(char *data, vtkIdType length, int srcProcessId)
int Scatter(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int srcProcessId)
int GatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation, int destProcessId)
int ScatterV(const short *sendBuffer, short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation, int destProcessId)
void TriggerRMI(int remoteProcessId, const char *arg, int tag)
Convenience method when the arg is a string.
int AllGatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Gather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int destProcessId)
int AllGatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllGather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length)
int ScatterV(const long long *sendBuffer, long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int GatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation)
vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
int Gather(const vtkMultiProcessStream &sendBuffer, std::vector< vtkMultiProcessStream > &recvBuffer, int destProcessId)
Gathers vtkMultiProcessStream (sendBuffer) from all ranks to the destProcessId.
int GatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)