55#ifndef vtkMultiProcessController_h
56#define vtkMultiProcessController_h
58#include "vtkParallelCoreModule.h"
79 void *remoteArg,
int remoteArgLength,
93 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv))=0;
100 virtual void Initialize(
int* vtkNotUsed(argc),
char*** vtkNotUsed(argv),
101 int initializedExternally)=0;
242 {(void)f; (void)arg; (void)tag; vtkErrorMacro(
"RemoveRMI Not Implemented Yet");};
266 void TriggerRMI(
int remoteProcessId,
void *arg,
int argLength,
int tag);
277 void TriggerRMI(
int remoteProcessId,
const char *arg,
int tag)
278 { this->TriggerRMI(remoteProcessId, (
void*)arg,
279 static_cast<int>(strlen(arg))+1, tag); }
285 { this->TriggerRMI(remoteProcessId, NULL, 0, tag); }
299 this->TriggerRMIOnAllChildren(
300 (
void*)arg,
static_cast<int>(strlen(arg))+1, tag);
304 this->TriggerRMIOnAllChildren(NULL, 0, tag);
333 vtkGetMacro(BreakFlag,
int);
343 vtkGetMacro(BroadcastTriggerRMI,
bool);
380 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,
445 int Receive(
char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
446 int Receive(
unsigned char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
447 int Receive(
signed char*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
448 int Receive(
float*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
449 int Receive(
double*
data,
vtkIdType maxlength,
int remoteProcessId,
int tag);
450 int Receive(
long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
451 int Receive(
unsigned long long*
data,
vtkIdType maxLength,
int remoteProcessId,
int tag);
483 return this->Communicator->Broadcast(
data,
length, srcProcessId);
486 return this->Communicator->Broadcast(
data,
length, srcProcessId);
489 return this->Communicator->Broadcast(
data,
length, srcProcessId);
492 return this->Communicator->Broadcast(
data,
length, srcProcessId);
495 return this->Communicator->Broadcast(
data,
length, srcProcessId);
498 return this->Communicator->Broadcast(
data,
length, srcProcessId);
501 return this->Communicator->Broadcast(
data,
length, srcProcessId);
504 return this->Communicator->Broadcast(
data,
length, srcProcessId);
507 return this->Communicator->Broadcast(
data,
length, srcProcessId);
510 return this->Communicator->Broadcast(
data,
length, srcProcessId);
513 return this->Communicator->Broadcast(
data,
length, srcProcessId);
516 return this->Communicator->Broadcast(
data,
length, srcProcessId);
519 return this->Communicator->Broadcast(
data,
length, srcProcessId);
522 return this->Communicator->Broadcast(
data, srcProcessId);
525 return this->Communicator->Broadcast(
data, srcProcessId);
530 return this->Communicator->Broadcast(stream, srcProcessId);
543 int Gather(
const int *sendBuffer,
int *recvBuffer,
545 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
548 int Gather(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
550 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
553 int Gather(
const short *sendBuffer,
short *recvBuffer,
555 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
558 int Gather(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
560 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
563 int Gather(
const long *sendBuffer,
long *recvBuffer,
565 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
568 int Gather(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
570 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
573 int Gather(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
575 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
578 int Gather(
const char *sendBuffer,
char *recvBuffer,
580 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
583 int Gather(
const signed char *sendBuffer,
signed char *recvBuffer,
585 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
588 int Gather(
const float *sendBuffer,
float *recvBuffer,
590 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
593 int Gather(
const double *sendBuffer,
double *recvBuffer,
595 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
598 int Gather(
const long long *sendBuffer,
long long *recvBuffer,
600 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
603 int Gather(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
605 return this->Communicator->Gather(sendBuffer, recvBuffer,
length,
610 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
630 return this->Communicator->Gather(sendBuffer, recvBuffer, destProcessId);
645 int GatherV(
const int* sendBuffer,
int* recvBuffer,
648 return this->Communicator->GatherV(sendBuffer, recvBuffer,
649 sendLength, recvLengths,
650 offsets, destProcessId);
652 int GatherV(
const unsigned int* sendBuffer,
unsigned int* recvBuffer,
655 return this->Communicator->GatherV(sendBuffer, recvBuffer,
656 sendLength, recvLengths,
657 offsets, destProcessId);
659 int GatherV(
const short* sendBuffer,
short* recvBuffer,
662 return this->Communicator->GatherV(sendBuffer, recvBuffer,
663 sendLength, recvLengths,
664 offsets, destProcessId);
666 int GatherV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
669 return this->Communicator->GatherV(sendBuffer, recvBuffer,
670 sendLength, recvLengths,
671 offsets, destProcessId);
673 int GatherV(
const long* sendBuffer,
long* recvBuffer,
676 return this->Communicator->GatherV(sendBuffer, recvBuffer,
677 sendLength, recvLengths,
678 offsets, destProcessId);
680 int GatherV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
683 return this->Communicator->GatherV(sendBuffer, recvBuffer,
684 sendLength, recvLengths,
685 offsets, destProcessId);
687 int GatherV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
690 return this->Communicator->GatherV(sendBuffer, recvBuffer,
691 sendLength, recvLengths,
692 offsets, destProcessId);
694 int GatherV(
const char* sendBuffer,
char* recvBuffer,
697 return this->Communicator->GatherV(sendBuffer, recvBuffer,
698 sendLength, recvLengths,
699 offsets, destProcessId);
701 int GatherV(
const signed char* sendBuffer,
signed char* recvBuffer,
704 return this->Communicator->GatherV(sendBuffer, recvBuffer,
705 sendLength, recvLengths,
706 offsets, destProcessId);
708 int GatherV(
const float* sendBuffer,
float* recvBuffer,
711 return this->Communicator->GatherV(sendBuffer, recvBuffer,
712 sendLength, recvLengths,
713 offsets, destProcessId);
715 int GatherV(
const double* sendBuffer,
double* recvBuffer,
718 return this->Communicator->GatherV(sendBuffer, recvBuffer,
719 sendLength, recvLengths,
720 offsets, destProcessId);
722 int GatherV(
const long long* sendBuffer,
long long* recvBuffer,
725 return this->Communicator->GatherV(sendBuffer, recvBuffer,
726 sendLength, recvLengths,
727 offsets, destProcessId);
729 int GatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
732 return this->Communicator->GatherV(sendBuffer, recvBuffer,
733 sendLength, recvLengths,
734 offsets, destProcessId);
740 return this->Communicator->GatherV(sendBuffer, recvBuffer,
741 recvLengths, offsets,
749 return this->Communicator->GatherV(sendBuffer, recvBuffer,
750 recvLengths, offsets, destProcessId);
763 return this->Communicator->GatherV(sendBuffer, recvBuffer, destProcessId);
768 return this->Communicator->GatherV(sendData, recvData, destProcessId);
780 int Scatter(
const int *sendBuffer,
int *recvBuffer,
782 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
785 int Scatter(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
787 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
790 int Scatter(
const short *sendBuffer,
short *recvBuffer,
792 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
795 int Scatter(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
797 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
800 int Scatter(
const long *sendBuffer,
long *recvBuffer,
802 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
805 int Scatter(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
807 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
810 int Scatter(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
812 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
815 int Scatter(
const char *sendBuffer,
char *recvBuffer,
817 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
820 int Scatter(
const signed char *sendBuffer,
signed char *recvBuffer,
822 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
825 int Scatter(
const float *sendBuffer,
float *recvBuffer,
827 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
830 int Scatter(
const double *sendBuffer,
double *recvBuffer,
832 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
835 int Scatter(
const long long *sendBuffer,
long long *recvBuffer,
837 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
840 int Scatter(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
842 return this->Communicator->Scatter(sendBuffer, recvBuffer,
length,
847 return this->Communicator->Scatter(sendBuffer, recvBuffer, srcProcessId);
859 int ScatterV(
const int *sendBuffer,
int *recvBuffer,
861 vtkIdType recvLength,
int srcProcessId) {
862 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
863 sendLengths, offsets, recvLength,
866 int ScatterV(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
868 vtkIdType recvLength,
int srcProcessId) {
869 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
870 sendLengths, offsets, recvLength,
873 int ScatterV(
const short *sendBuffer,
short *recvBuffer,
875 vtkIdType recvLength,
int srcProcessId) {
876 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
877 sendLengths, offsets, recvLength,
880 int ScatterV(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
882 vtkIdType recvLength,
int srcProcessId) {
883 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
884 sendLengths, offsets, recvLength,
887 int ScatterV(
const long *sendBuffer,
long *recvBuffer,
889 vtkIdType recvLength,
int srcProcessId) {
890 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
891 sendLengths, offsets, recvLength,
894 int ScatterV(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
896 vtkIdType recvLength,
int srcProcessId) {
897 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
898 sendLengths, offsets, recvLength,
901 int ScatterV(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
903 vtkIdType recvLength,
int srcProcessId) {
904 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
905 sendLengths, offsets, recvLength,
908 int ScatterV(
const char *sendBuffer,
char *recvBuffer,
910 vtkIdType recvLength,
int srcProcessId) {
911 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
912 sendLengths, offsets, recvLength,
915 int ScatterV(
const signed char *sendBuffer,
signed char *recvBuffer,
917 vtkIdType recvLength,
int srcProcessId) {
918 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
919 sendLengths, offsets, recvLength,
922 int ScatterV(
const float *sendBuffer,
float *recvBuffer,
924 vtkIdType recvLength,
int srcProcessId) {
925 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
926 sendLengths, offsets, recvLength,
929 int ScatterV(
const double *sendBuffer,
double *recvBuffer,
931 vtkIdType recvLength,
int srcProcessId) {
932 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
933 sendLengths, offsets, recvLength,
936 int ScatterV(
const long long *sendBuffer,
long long *recvBuffer,
938 vtkIdType recvLength,
int srcProcessId) {
939 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
940 sendLengths, offsets, recvLength,
943 int ScatterV(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
945 vtkIdType recvLength,
int srcProcessId) {
946 return this->Communicator->ScatterV(sendBuffer, recvBuffer,
947 sendLengths, offsets, recvLength,
957 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
960 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
963 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
966 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
969 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
973 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
977 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
980 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
983 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
986 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
990 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
993 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
996 return this->Communicator->AllGather(sendBuffer, recvBuffer,
length);
999 return this->Communicator->AllGather(sendBuffer, recvBuffer);
1010 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1011 sendLength, recvLengths,
1014 int AllGatherV(
const unsigned int* sendBuffer,
unsigned int* recvBuffer,
1017 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1018 sendLength, recvLengths,
1024 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1025 sendLength, recvLengths,
1028 int AllGatherV(
const unsigned short* sendBuffer,
unsigned short* recvBuffer,
1031 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1032 sendLength, recvLengths,
1038 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1039 sendLength, recvLengths,
1042 int AllGatherV(
const unsigned long* sendBuffer,
unsigned long* recvBuffer,
1045 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1046 sendLength, recvLengths,
1049 int AllGatherV(
const unsigned char* sendBuffer,
unsigned char* recvBuffer,
1052 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1053 sendLength, recvLengths,
1059 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1060 sendLength, recvLengths,
1063 int AllGatherV(
const signed char* sendBuffer,
signed char* recvBuffer,
1066 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1067 sendLength, recvLengths,
1073 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1074 sendLength, recvLengths,
1080 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1081 sendLength, recvLengths,
1084 int AllGatherV(
const long long* sendBuffer,
long long* recvBuffer,
1087 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1088 sendLength, recvLengths,
1091 int AllGatherV(
const unsigned long long* sendBuffer,
unsigned long long* recvBuffer,
1094 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1095 sendLength, recvLengths,
1100 return this->Communicator->AllGatherV(sendBuffer, recvBuffer,
1101 recvLengths, offsets);
1112 return this->Communicator->AllGatherV(sendBuffer, recvBuffer);
1121 int Reduce(
const int *sendBuffer,
int *recvBuffer,
1123 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1124 operation, destProcessId);
1126 int Reduce(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
1128 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1129 operation, destProcessId);
1131 int Reduce(
const short *sendBuffer,
short *recvBuffer,
1133 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1134 operation, destProcessId);
1136 int Reduce(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
1138 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1139 operation, destProcessId);
1141 int Reduce(
const long *sendBuffer,
long *recvBuffer,
1143 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1144 operation, destProcessId);
1146 int Reduce(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
1148 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1149 operation, destProcessId);
1151 int Reduce(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
1153 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1154 operation, destProcessId);
1156 int Reduce(
const char *sendBuffer,
char *recvBuffer,
1158 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1159 operation, destProcessId);
1161 int Reduce(
const signed char *sendBuffer,
signed char *recvBuffer,
1163 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1164 operation, destProcessId);
1166 int Reduce(
const float *sendBuffer,
float *recvBuffer,
1168 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1169 operation, destProcessId);
1171 int Reduce(
const double *sendBuffer,
double *recvBuffer,
1173 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1174 operation, destProcessId);
1176 int Reduce(
const long long *sendBuffer,
long long *recvBuffer,
1178 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1179 operation, destProcessId);
1181 int Reduce(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
1183 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1184 operation, destProcessId);
1187 int operation,
int destProcessId) {
1188 return this->Communicator->Reduce(sendBuffer, recvBuffer,
1189 operation, destProcessId);
1198 int Reduce(
const int *sendBuffer,
int *recvBuffer,
1200 int destProcessId) {
1201 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1202 operation, destProcessId);
1204 int Reduce(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
1206 int destProcessId) {
1207 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1208 operation, destProcessId);
1210 int Reduce(
const short *sendBuffer,
short *recvBuffer,
1212 int destProcessId) {
1213 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1214 operation, destProcessId);
1216 int Reduce(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
1218 int destProcessId) {
1219 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1220 operation, destProcessId);
1222 int Reduce(
const long *sendBuffer,
long *recvBuffer,
1224 int destProcessId) {
1225 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1226 operation, destProcessId);
1228 int Reduce(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
1230 int destProcessId) {
1231 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1232 operation, destProcessId);
1234 int Reduce(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
1236 int destProcessId) {
1237 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1238 operation, destProcessId);
1240 int Reduce(
const char *sendBuffer,
char *recvBuffer,
1242 int destProcessId) {
1243 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1244 operation, destProcessId);
1246 int Reduce(
const signed char *sendBuffer,
signed char *recvBuffer,
1248 int destProcessId) {
1249 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1250 operation, destProcessId);
1252 int Reduce(
const float *sendBuffer,
float *recvBuffer,
1254 int destProcessId) {
1255 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1256 operation, destProcessId);
1258 int Reduce(
const double *sendBuffer,
double *recvBuffer,
1260 int destProcessId) {
1261 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1262 operation, destProcessId);
1264 int Reduce(
const long long *sendBuffer,
long long *recvBuffer,
1266 int destProcessId) {
1267 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1268 operation, destProcessId);
1270 int Reduce(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
1272 int destProcessId) {
1273 return this->Communicator->Reduce(sendBuffer, recvBuffer,
length,
1274 operation, destProcessId);
1278 return this->Communicator->Reduce(sendBuffer, recvBuffer,
1279 operation, destProcessId);
1289 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1292 int AllReduce(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
1294 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1299 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1302 int AllReduce(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
1304 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1309 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1312 int AllReduce(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
1314 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1317 int AllReduce(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
1319 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1324 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1327 int AllReduce(
const signed char *sendBuffer,
signed char *recvBuffer,
1329 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1334 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1339 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1342 int AllReduce(
const long long *sendBuffer,
long long *recvBuffer,
1344 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1347 int AllReduce(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
1349 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1354 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1360 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1363 int AllReduce(
const unsigned int *sendBuffer,
unsigned int *recvBuffer,
1365 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1370 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1373 int AllReduce(
const unsigned short *sendBuffer,
unsigned short *recvBuffer,
1375 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1380 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1383 int AllReduce(
const unsigned long *sendBuffer,
unsigned long *recvBuffer,
1385 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1388 int AllReduce(
const unsigned char *sendBuffer,
unsigned char *recvBuffer,
1390 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1395 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1398 int AllReduce(
const signed char *sendBuffer,
signed char *recvBuffer,
1400 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1405 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1410 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1413 int AllReduce(
const long long *sendBuffer,
long long *recvBuffer,
1415 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1418 int AllReduce(
const unsigned long long *sendBuffer,
unsigned long long *recvBuffer,
1420 return this->Communicator->AllReduce(sendBuffer, recvBuffer,
length,
1425 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation);
1440 void* arg,
int argLength,
int rmiTag,
bool propagate);
1451 void ProcessRMI(
int remoteProcessId,
void *arg,
int argLength,
int rmiTag);
1486 unsigned long RMICount;
1489 vtkInternal *Internal;
1495 int remoteProcessId,
int tag)
1508 int remoteProcessId,
int tag)
1521 int remoteProcessId,
int tag)
1534 int remoteProcessId,
int tag)
1547 int remoteProcessId,
int tag)
1560 int remoteProcessId,
int tag)
1574 int remoteProcessId,
1589 int remoteProcessId,
1603 int remoteProcessId,
int tag)
1616 int remoteProcessId,
int tag)
1630 int remoteProcessId,
int tag)
1643 int remoteProcessId,
int tag)
1656 int remoteProcessId,
int tag)
1670 int remoteProcessId,
int tag)
1684 int remoteProcessId,
int tag)
1697 int remoteId,
int tag)
1707 int remoteProcessId,
int tag)
1720 int remoteProcessId,
int tag)
1733 int remoteProcessId,
int tag)
1746 int remoteProcessId,
int tag)
1759 int remoteProcessId,
int tag)
1772 int remoteProcessId,
int tag)
1785 int remoteProcessId,
int tag)
1798 int remoteProcessId,
int tag)
1813 int remoteProcessId,
1827 int remoteProcessId,
int tag)
1841 int remoteProcessId,
int tag)
1854 int remoteProcessId,
int tag)
1868 int remoteProcessId,
int tag)
1881 int remoteProcessId,
int tag)
1894 int remoteProcessId,
int tag)
1907 int remoteProcessId,
int tag)
1920 int remoteId,
int tag)
create and manipulate unsorted lists of objects
A custom operation to use in a reduce command.
Used to send/receive messages in a multiprocess environment.
virtual void Barrier()
Will block the processes until all other processes reach the Barrier function.
int Send(vtkDataObject *data, int remoteHandle, int tag)
This method sends a data object to a destination.
int Receive(vtkDataObject *data, int remoteHandle, int tag)
This method receives a data object from a corresponding send.
vtkDataObject * ReceiveDataObject(int remoteHandle, int tag)
The caller does not have to know the data type before this call is made.
virtual vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
abstract superclass for arrays of numeric data
general representation of visualization data
abstract class to specify dataset behavior
dynamic, self-adjusting array of vtkIdType
topologically and geometrically regular array of data
a simple class to control print indentation
Multiprocessing communication superclass.
int Gather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int destProcessId)
void TriggerBreakRMIs()
A conveniance method.
~vtkMultiProcessController()
void TriggerRMI(int remoteProcessId, const char *arg, int tag)
Convenience method when the arg is a string.
vtkDataObject * ReceiveDataObject(int remoteId, int tag)
vtkIdType GetCount()
Returns the number of words received by the most recent Receive().
int GatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllGatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Broadcast(vtkMultiProcessStream &stream, int srcProcessId)
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Gather(const short *sendBuffer, short *recvBuffer, vtkIdType length, int destProcessId)
virtual unsigned long AddRMI(vtkRMIFunctionType, void *localArg, int tag)
Register remote method invocation in the receiving process which makes the call.
int Send(const int *data, vtkIdType length, int remoteProcessId, int tag)
This method sends data to another process.
void TriggerRMIOnAllChildren(void *arg, int argLength, int tag)
This is a convenicence method to trigger an RMI call on all the "children" of the current node.
int Broadcast(long long *data, vtkIdType length, int srcProcessId)
int GetNumberOfProcesses()
int Scatter(const short *sendBuffer, short *recvBuffer, vtkIdType length, int srcProcessId)
int AllGather(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length)
int AllGatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
virtual int RemoveFirstRMI(int tag)
Remove the first RMI matching the tag.
int Gather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int destProcessId)
int Scatter(const double *sendBuffer, double *recvBuffer, vtkIdType length, int srcProcessId)
int AllGatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int GatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
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 Scatter(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int srcProcessId)
int Broadcast(vtkDataArray *data, int srcProcessId)
int GatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
static void SetGlobalController(vtkMultiProcessController *controller)
int GatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Broadcast(vtkDataObject *data, int srcProcessId)
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllGather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length)
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
static vtkMultiProcessController * GetGlobalController()
This convenience method returns the controller associated with the local process.
int AllGatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
virtual void RemoveRMI(vtkRMIFunctionType f, void *arg, int tag)
Take an RMI away.
int AllGather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length)
int ScatterV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int ProcessRMIs(int reportErrors, int dont_loop=0)
Calling this method gives control to the controller to start processing RMIs.
int ScatterV(const long *sendBuffer, long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int AllGather(const char *sendBuffer, char *recvBuffer, vtkIdType length)
int AllGatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllGatherV(const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Scatter(const long *sendBuffer, long *recvBuffer, vtkIdType length, int srcProcessId)
int Broadcast(short *data, vtkIdType length, int srcProcessId)
int Gather(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int destProcessId)
int Scatter(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int srcProcessId)
void SetMultipleMethod(int index, vtkProcessFunctionType, void *data)
Set the MultipleMethod to f() and the UserData of the for the method to be executed by the process in...
vtkOutputWindow * OutputWindow
virtual void TriggerRMIInternal(int remoteProcessId, void *arg, int argLength, int rmiTag, bool propagate)
Implementation for TriggerRMI() provides subclasses an opportunity to modify the behaviour eg.
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation, int destProcessId)
Reduce an array to the given destination process.
int AllGather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length)
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation)
void SetSingleProcessObject(vtkProcess *p)
Object-oriented flavor of SetSingleMethod().
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation)
int Scatter(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int srcProcessId)
int Gather(const float *sendBuffer, float *recvBuffer, vtkIdType length, int destProcessId)
int AllGather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length)
virtual void RemoveAllRMICallbacks(int tag)
These methods are a part of the newer API to add multiple rmi callbacks.
int Broadcast(double *data, vtkIdType length, int srcProcessId)
int Scatter(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int srcProcessId)
int AllGatherV(const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllGather(const float *sendBuffer, float *recvBuffer, vtkIdType length)
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation, int destProcessId)
static int GetBreakRMITag()
Accessor to some default tags.
int Scatter(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int srcProcessId)
virtual vtkMultiProcessController * CreateSubController(vtkProcessGroup *group)
Creates a new controller with the processes specified by the given group.
int AllReduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation)
int AllReduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Gather(const long *sendBuffer, long *recvBuffer, vtkIdType length, int destProcessId)
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
vtkCommunicator * RMICommunicator
int Gather(const int *sendBuffer, int *recvBuffer, vtkIdType length, int destProcessId)
Gather collects arrays in the process with id destProcessId.
virtual void SingleMethodExecute()=0
Execute the SingleMethod (as define by SetSingleMethod) using this->NumberOfProcesses processes.
int GatherV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation)
int Broadcast(float *data, vtkIdType length, int srcProcessId)
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation)
int Gather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int destProcessId)
int ScatterV(const double *sendBuffer, double *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int AllGatherV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int AllReduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation)
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
virtual vtkMultiProcessController * PartitionController(int localColor, int localKey)
Partitions this controller based on a coloring.
vtkCommunicator * Communicator
int AllGatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Broadcast(unsigned long long *data, vtkIdType length, int srcProcessId)
void BroadcastTriggerRMIOnAllChildren(void *arg, int argLength, int tag)
int Broadcast(long *data, vtkIdType length, int srcProcessId)
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
This special form of AllGatherV will automatically determine recvLengths and offsets to tightly pack ...
virtual vtkMultiProcessController * GetLocalController()
void TriggerRMI(int remoteProcessId, int tag)
Convenience method when there is no argument.
int Reduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int Gather(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int destProcessId)
virtual void Initialize(int *vtkNotUsed(argc), char ***vtkNotUsed(argv))=0
This method is for setting up the processes.
static int GetRMIArgTag()
int AllGather(const double *sendBuffer, double *recvBuffer, vtkIdType length)
int AllGather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer)
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation)
int Broadcast(unsigned int *data, vtkIdType length, int srcProcessId)
int AllReduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation)
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
virtual void Initialize(int *vtkNotUsed(argc), char ***vtkNotUsed(argv), int initializedExternally)=0
This method is for setting up the processes.
void Barrier()
This method can be used to synchronize processes.
int Gather(const double *sendBuffer, double *recvBuffer, vtkIdType length, int destProcessId)
void PrintSelf(ostream &os, vtkIndent indent)
Methods invoked by print to print information about the object including superclasses.
int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation)
int Broadcast(unsigned char *data, vtkIdType length, int srcProcessId)
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 long *data, vtkIdType length, int srcProcessId)
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation)
int ScatterV(const float *sendBuffer, float *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
void TriggerRMIOnAllChildren(const char *arg, int tag)
int AllGather(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length)
int BroadcastProcessRMIs(int reportErrors, int dont_loop=0)
int AllReduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllReduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int ScatterV(const char *sendBuffer, char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int ScatterV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
virtual void Finalize(int finalizedExternally)=0
This method is for cleaning up.
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation, int destProcessId)
int Reduce(const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int AllReduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation, int destProcessId)
int GatherV(const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
GatherV is the vector variant of Gather.
int Broadcast(signed char *data, vtkIdType length, int srcProcessId)
void SetNumberOfProcesses(int num)
Set the number of processes you will be using.
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdTypeArray *recvLengths, vtkIdTypeArray *offsets, int destProcessId)
virtual int RemoveRMI(unsigned long id)
Remove the RMI matching the id.
int Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllReduce(const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation)
int GetLocalProcessId()
Tells you which process [0, NumProcess) you are in.
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation)
void ProcessRMI(int remoteProcessId, void *arg, int argLength, int rmiTag)
int ScatterV(const long long *sendBuffer, long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int ScatterV(const short *sendBuffer, short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Scatter(const float *sendBuffer, float *recvBuffer, vtkIdType length, int srcProcessId)
int GatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
This special form of GatherV will automatically determine recvLengths and offsets to tightly pack the...
int AllGather(const short *sendBuffer, short *recvBuffer, vtkIdType length)
int AllGatherV(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets)
int Gather(const char *sendBuffer, char *recvBuffer, vtkIdType length, int destProcessId)
int Gather(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int destProcessId)
void SetSingleMethod(vtkProcessFunctionType, void *data)
Set the SingleMethod to f() and the UserData of the for the method to be executed by all of the proce...
int GatherV(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int GatherV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation, int destProcessId)
void TriggerRMIOnAllChildren(int tag)
int AllGatherV(const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Gather(vtkDataObject *sendBuffer, std::vector< vtkSmartPointer< vtkDataObject > > &recvBuffer, int destProcessId)
Gathers vtkDataObject (sendBuffer) from all ranks to the destProcessId.
int Reduce(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Receive(int *data, vtkIdType maxlength, int remoteProcessId, int tag)
This method receives data from a corresponding send.
int GatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int GatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int AllReduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
virtual void MultipleMethodExecute()=0
Execute the MultipleMethods (as define by calling SetMultipleMethod for each of the required this->Nu...
int AllGatherV(const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int Reduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation, int destProcessId)
void GetMultipleMethod(int index, vtkProcessFunctionType &func, void *&data)
int AllReduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
vtkMultiProcessController()
int Broadcast(char *data, vtkIdType length, int srcProcessId)
int AllGatherV(const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets)
int GatherV(const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Broadcast(unsigned short *data, vtkIdType length, int srcProcessId)
int Gather(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId)
virtual unsigned long AddRMICallback(vtkRMIFunctionType, void *localArg, int tag)
These methods are a part of the newer API to add multiple rmi callbacks.
int AllReduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int AllGather(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length)
int Gather(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int destProcessId)
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int ScatterV(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int Scatter(const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int srcProcessId)
int Reduce(const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
vtkProcessFunctionType SingleMethod
int Scatter(const signed char *sendBuffer, signed char *recvBuffer, 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 ScatterV(const int *sendBuffer, int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
ScatterV is the vector variant of Scatter.
int AllReduce(const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation)
void TriggerRMI(int remoteProcessId, void *arg, int argLength, int tag)
A method to trigger a method invocation in another process.
int GatherV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Scatter(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int srcProcessId)
int ScatterV(const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation)
virtual void CreateOutputWindow()=0
This method can be used to tell the controller to create a special output window in which all message...
int GatherV(vtkDataObject *sendData, vtkSmartPointer< vtkDataObject > *recvData, int destProcessId)
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.
virtual void Finalize()=0
This method is for cleaning up.
int ScatterV(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
int GatherV(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId)
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
int AllReduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation)
int Scatter(const char *sendBuffer, char *recvBuffer, vtkIdType length, int srcProcessId)
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 Reduce(const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId)
Reduce an array to the given destination process.
int Reduce(const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation, int destProcessId)
int Reduce(const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation, int destProcessId)
virtual bool RemoveRMICallback(unsigned long id)
Remove a callback.
int AllGather(const long *sendBuffer, long *recvBuffer, vtkIdType length)
int Reduce(const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation, int destProcessId)
int ScatterV(const signed char *sendBuffer, signed char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId)
stream used to pass data across processes using vtkMultiProcessController.
abstract base class for most VTK objects
base class for writing debug output to a console
A subgroup of processes from a communicator.
a process that can be launched by a vtkMultiProcessController
void(* vtkProcessFunctionType)(vtkMultiProcessController *controller, void *userData)
void(* vtkRMIFunctionType)(void *localArg, void *remoteArg, int remoteArgLength, int remoteProcessId)
vtkSetMacro(IgnoreDriverBugs, bool)
Updates the extensions string.
vtkBooleanMacro(IgnoreDriverBugs, bool)
Updates the extensions string.