/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/net/ |
H A D | group.hpp | 152 void AllReduce(T& value, BinarySumOp sum_op = BinarySumOp()); 383 inline void Group::AllReduce(int& value, std::plus<int>) { in AllReduce() function in thrill::net::Group 387 inline void Group::AllReduce(int& value, common::minimum<int>) { in AllReduce() function in thrill::net::Group 391 inline void Group::AllReduce(int& value, common::maximum<int>) { in AllReduce() function in thrill::net::Group 407 inline void Group::AllReduce(unsigned int& value, std::plus<unsigned int>) { in AllReduce() function in thrill::net::Group 431 inline void Group::AllReduce(long& value, std::plus<long>) { in AllReduce() function in thrill::net::Group 435 inline void Group::AllReduce(long& value, common::minimum<long>) { in AllReduce() function in thrill::net::Group 439 inline void Group::AllReduce(long& value, common::maximum<long>) { in AllReduce() function in thrill::net::Group 479 inline void Group::AllReduce(long long& value, std::plus<long long>) { in AllReduce() function in thrill::net::Group 483 inline void Group::AllReduce(long long& value, common::minimum<long long>) { in AllReduce() function in thrill::net::Group [all …]
|
/dports/math/vtk8/VTK-8.2.0/Parallel/Core/ |
H A D | vtkMultiProcessController.h | 1281 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 1291 int AllReduce(const short *sendBuffer, short *recvBuffer, in AllReduce() function 1301 int AllReduce(const long *sendBuffer, long *recvBuffer, in AllReduce() function 1316 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 1326 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 1331 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function 1352 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 1362 int AllReduce(const short *sendBuffer, short *recvBuffer, in AllReduce() function 1372 int AllReduce(const long *sendBuffer, long *recvBuffer, in AllReduce() function 1387 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function [all …]
|
H A D | vtkCommunicator.h | 1076 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 1086 int AllReduce(const short *sendBuffer, short *recvBuffer, in AllReduce() function 1096 int AllReduce(const long *sendBuffer, long *recvBuffer, in AllReduce() function 1111 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 1121 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 1126 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function 1143 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 1153 int AllReduce(const short *sendBuffer, short *recvBuffer, in AllReduce() function 1163 int AllReduce(const long *sendBuffer, long *recvBuffer, in AllReduce() function 1178 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function [all …]
|
/dports/math/vtk9/VTK-9.1.0/Parallel/Core/ |
H A D | vtkMultiProcessController.h | 1264 int AllReduce( in AllReduce() function 1273 int AllReduce( in AllReduce() function 1282 int AllReduce( in AllReduce() function 1287 int AllReduce( in AllReduce() function 1296 int AllReduce( in AllReduce() function 1320 return this->Communicator->AllReduce(sendBuffer, recvBuffer, operation); in AllReduce() 1324 int AllReduce( in AllReduce() function 1344 int AllReduce(const long* sendBuffer, long* recvBuffer, vtkIdType length, in AllReduce() function 1359 int AllReduce(const char* sendBuffer, char* recvBuffer, vtkIdType length, in AllReduce() function 1389 int AllReduce( in AllReduce() function [all …]
|
H A D | vtkCommunicator.h | 1103 int AllReduce( in AllReduce() function 1112 int AllReduce( in AllReduce() function 1121 int AllReduce( in AllReduce() function 1126 int AllReduce( in AllReduce() function 1135 int AllReduce( in AllReduce() function 1152 int AllReduce(const unsigned long long* sendBuffer, unsigned long long* recvBuffer, in AllReduce() function 1158 int AllReduce(vtkDataArray* sendBuffer, vtkDataArray* recvBuffer, int operation); 1195 int AllReduce( in AllReduce() function 1204 int AllReduce( in AllReduce() function 1209 int AllReduce( in AllReduce() function [all …]
|
/dports/math/vtk6/VTK-6.2.0/Parallel/Core/ |
H A D | vtkMultiProcessController.h | 907 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 922 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 927 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 932 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function 938 int AllReduce(const vtkIdType *sendBuffer, vtkIdType *recvBuffer, in AllReduce() function 944 int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, in AllReduce() function 949 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 964 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 969 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 974 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function [all …]
|
H A D | vtkCommunicator.h | 689 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 704 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 709 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 714 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function 720 int AllReduce(const vtkIdType *sendBuffer, vtkIdType *recvBuffer, in AllReduce() function 726 int AllReduce(vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, 728 int AllReduce(const int *sendBuffer, int *recvBuffer, in AllReduce() function 743 int AllReduce(const char *sendBuffer, char *recvBuffer, in AllReduce() function 748 int AllReduce(const float *sendBuffer, float *recvBuffer, in AllReduce() function 753 int AllReduce(const double *sendBuffer, double *recvBuffer, in AllReduce() function [all …]
|
/dports/science/madness/madness-ebb3fd7/src/madness/external/elemental/src/core/imports/ |
H A D | mpi.cpp | 2286 void AllReduce in AllReduce() function 2361 T AllReduce( T sb, Op op, Comm comm ) in AllReduce() function 2385 T AllReduce( T sb, Comm comm ) in AllReduce() function 2386 { return AllReduce( sb, mpi::SUM, comm ); } in AllReduce() 2388 template byte AllReduce( byte sb, Comm comm ); 2389 template int AllReduce( int sb, Comm comm ); 2506 { AllReduce( buf, count, mpi::SUM, comm ); } in AllReduce() 2535 AllReduce( sbuf, rc*commSize, op, comm ); in ReduceScatter() 2556 AllReduce( sbuf, rc*commSize, op, comm ); in ReduceScatter() 2650 AllReduce( buf, rc*commSize, op, comm ); in ReduceScatter() [all …]
|
/dports/math/vtk8/VTK-8.2.0/IO/ParallelExodus/ |
H A D | vtkPExodusIIWriter.cxx | 117 c->AllReduce (&maxId, &globalMaxId, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 123 c->AllReduce (&b.Type, &globalType, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 134 c->AllReduce (&b.NodesPerElement, &globalNodes, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 160 c->AllReduce (&localContinue, &globalContinue, 1, vtkCommunicator::MIN_OP); in GlobalContinueExecuting() 173 c->AllReduce(&maxName, &globalMaxName, 1, vtkCommunicator::MAX_OP); in GetMaxNameLength()
|
/dports/math/vtk9/VTK-9.1.0/IO/ParallelExodus/ |
H A D | vtkPExodusIIWriter.cxx | 111 c->AllReduce(&maxId, &globalMaxId, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 117 c->AllReduce(&b.Type, &globalType, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 127 c->AllReduce(&b.NodesPerElement, &globalNodes, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 151 c->AllReduce(&localContinue, &globalContinue, 1, vtkCommunicator::MIN_OP); in GlobalContinueExecuting() 163 c->AllReduce(&maxName, &globalMaxName, 1, vtkCommunicator::MAX_OP); in GetMaxNameLength()
|
/dports/math/vtk9/VTK-9.1.0/Filters/ParallelImaging/ |
H A D | vtkPExtractHistogram2D.cxx | 91 if (!comm->AllReduce(myArray, recvArray, vtkCommunicator::SUM_OP)) in Learn() 143 if (!comm->AllReduce(myRange, allRange, 1, vtkCommunicator::MIN_OP) || in ComputeBinExtents() 144 !comm->AllReduce(myRange + 1, allRange + 1, 1, vtkCommunicator::MAX_OP) || in ComputeBinExtents() 145 !comm->AllReduce(myRange + 2, allRange + 2, 1, vtkCommunicator::MIN_OP) || in ComputeBinExtents() 146 !comm->AllReduce(myRange + 3, allRange + 3, 1, vtkCommunicator::MAX_OP)) in ComputeBinExtents()
|
/dports/math/vtk8/VTK-8.2.0/Filters/ParallelImaging/ |
H A D | vtkPExtractHistogram2D.cxx | 91 if (!comm->AllReduce(myArray,recvArray,vtkCommunicator::SUM_OP)) in Learn() 144 if (!comm->AllReduce(myRange,allRange,1,vtkCommunicator::MIN_OP) || in ComputeBinExtents() 145 !comm->AllReduce(myRange+1,allRange+1,1,vtkCommunicator::MAX_OP) || in ComputeBinExtents() 146 !comm->AllReduce(myRange+2,allRange+2,1,vtkCommunicator::MIN_OP) || in ComputeBinExtents() 147 !comm->AllReduce(myRange+3,allRange+3,1,vtkCommunicator::MAX_OP)) in ComputeBinExtents()
|
/dports/math/vtk6/VTK-6.2.0/Filters/ParallelImaging/ |
H A D | vtkPExtractHistogram2D.cxx | 91 if (!comm->AllReduce(myArray,recvArray,vtkCommunicator::SUM_OP)) in Learn() 144 if (!comm->AllReduce(myRange,allRange,1,vtkCommunicator::MIN_OP) || in ComputeBinExtents() 145 !comm->AllReduce(myRange+1,allRange+1,1,vtkCommunicator::MAX_OP) || in ComputeBinExtents() 146 !comm->AllReduce(myRange+2,allRange+2,1,vtkCommunicator::MIN_OP) || in ComputeBinExtents() 147 !comm->AllReduce(myRange+3,allRange+3,1,vtkCommunicator::MAX_OP)) in ComputeBinExtents()
|
/dports/math/vtk6/VTK-6.2.0/IO/ParallelExodus/ |
H A D | vtkPExodusIIWriter.cxx | 117 c->AllReduce (&maxId, &globalMaxId, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 123 c->AllReduce (&b.Type, &globalType, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 134 c->AllReduce (&b.NodesPerElement, &globalNodes, 1, vtkCommunicator::MAX_OP); in CheckBlockInfoMap() 158 c->AllReduce (&localContinue, &globalContinue, 1, vtkCommunicator::MIN_OP); in GlobalContinueExecuting()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/api/ |
H A D | merge.hpp | 279 ctx.net.AllReduce(merge_timer_.Milliseconds()) / p; in Print() 281 ctx.net.AllReduce(balancing_timer_.Milliseconds()) / p; in Print() 285 ctx.net.AllReduce(search_step_timer_.Milliseconds()) / p; in Print() 287 ctx.net.AllReduce(file_op_timer_.Milliseconds()) / p; in Print() 289 ctx.net.AllReduce(comm_timer_.Milliseconds()) / p; in Print() 291 ctx.net.AllReduce(scatter_timer_.Milliseconds()) / p; in Print() 293 result_size_ = ctx.net.AllReduce(result_size_); in Print() 368 out_pivots = context_.net.AllReduce( in SelectPivots() 406 global_ranks = context_.net.AllReduce( in GetGlobalRanks() 498 size_t global_size = context_.net.AllReduce(local_size); in MainOp() [all …]
|
/dports/math/vtk9/VTK-9.1.0/Filters/ParallelGeometry/Testing/Cxx/ |
H A D | TestPolyhedralMeshDistributedDataFilter.cxx | 50 controller->AllReduce(&localNbCells, &allNbCells, 1, vtkCommunicator::SUM_OP); in TestPolyhedralMeshDistributedDataFilter() 70 controller->AllReduce(&success, &allsuccess, 1, vtkCommunicator::MIN_OP); in TestPolyhedralMeshDistributedDataFilter() 79 controller->AllReduce(&localOutNbCells, &allOutNbCells, 1, vtkCommunicator::SUM_OP); in TestPolyhedralMeshDistributedDataFilter()
|
H A D | ParallelConnectivity.cxx | 116 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity() 130 contr->AllReduce(regionCounts.data(), globalRegionCounts.data(), in RunParallelConnectivity() 168 contr->AllReduce(regionCounts.data(), globalRegionCounts.data(), in RunParallelConnectivity() 198 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity() 212 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity()
|
/dports/math/vtk8/VTK-8.2.0/Filters/ParallelGeometry/Testing/Cxx/ |
H A D | ParallelConnectivity.cxx | 112 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity() 125 contr->AllReduce(regionCounts.data(), globalRegionCounts.data(), in RunParallelConnectivity() 163 contr->AllReduce(regionCounts.data(), globalRegionCounts.data(), in RunParallelConnectivity() 194 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity() 209 contr->AllReduce(&numberOfCells, &globalNumberOfCells, 1, vtkCommunicator::SUM_OP); in RunParallelConnectivity()
|
/dports/math/vtk9/VTK-9.1.0/IO/CGNS/ |
H A D | vtkCGNSFileSeriesReader.cxx | 374 controller->AllReduce(&child_count, &max_child_count, 1, vtkCommunicator::MAX_OP); in SyncMetadata() 378 controller->AllReduce(&ds_count, &total_ds_count, 1, vtkCommunicator::SUM_OP); in SyncMetadata() 388 this->AllReduce(cnames, controller); in SyncMetadata() 423 void AllReduce(std::set<std::string>& names, vtkMultiProcessController* controller) in AllReduce() function 433 controller->AllReduce(&slen, &maxslen, 1, vtkCommunicator::MAX_OP); in AllReduce() 481 this->Controller->AllReduce(&success, &allSuccess, 1, vtkCommunicator::MIN_OP); in RequestData()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/benchmarks/net/ |
H A D | net_benchmark.cpp | 213 group.AllReduce(time, common::maximum<size_t>()); in Test() 395 group.AllReduce(time, common::maximum<size_t>()); in Test() 461 time = ctx.net.AllReduce(time, common::maximum<size_t>()); in Test() 531 time = ctx.net.AllReduce(time, common::maximum<size_t>()); in Test() 558 class AllReduce class 576 AllReduce local = *this; in Run() 593 value = ctx.net.AllReduce(value); in Test() 601 time = ctx.net.AllReduce(time, common::maximum<size_t>()); in Test() 699 time = ctx.net.AllReduce(time, common::maximum<size_t>()); in Test() 921 return AllReduce().Run(argc - 1, argv + 1); in main()
|
/dports/math/vtk9/VTK-9.1.0/IO/Parallel/Testing/Cxx/ |
H A D | TestPOpenFOAMReaderLagrangianUncollated.cxx | 140 controller->AllReduce(&hasLagrangian, &globalHasLagrangian, 1, vtkCommunicator::LOGICAL_OR_OP); in TestPOpenFOAMReaderLagrangianUncollated() 141 controller->AllReduce(&nClouds, &nGlobalClouds, 1, vtkCommunicator::MAX_OP); in TestPOpenFOAMReaderLagrangianUncollated() 142 controller->AllReduce(&nParticles, &nGlobalParticles, 1, vtkCommunicator::SUM_OP); in TestPOpenFOAMReaderLagrangianUncollated()
|
H A D | TestPOpenFOAMReaderLagrangianSerial.cxx | 141 controller->AllReduce(&hasLagrangian, &globalHasLagrangian, 1, vtkCommunicator::LOGICAL_OR_OP); in TestPOpenFOAMReaderLagrangianSerial() 142 controller->AllReduce(&nClouds, &nGlobalClouds, 1, vtkCommunicator::MAX_OP); in TestPOpenFOAMReaderLagrangianSerial() 143 controller->AllReduce(&nParticles, &nGlobalParticles, 1, vtkCommunicator::SUM_OP); in TestPOpenFOAMReaderLagrangianSerial()
|
/dports/graphics/ospray/ospray-2.8.0/modules/mpi/common/ |
H A D | Collectives.cpp | 134 auto col = std::make_shared<AllReduce>( in allreduce() 352 AllReduce::AllReduce(const void *sendBuffer, in AllReduce() function in mpicommon::AllReduce 366 std::future<void *> AllReduce::future() in future() 371 void AllReduce::start() in start() 377 void AllReduce::onFinish() in onFinish()
|
/dports/math/vtk9/VTK-9.1.0/Filters/Parallel/ |
H A D | vtkPProjectSphereFilter.cxx | 48 controller->AllReduce(&tmp, &minDist2ToCenterLineGlobal, 1, vtkCommunicator::MAX_OP); in ComputePointsClosestToCenterLine() 66 controller->AllReduce(&localMax, &globalMax, 1, vtkCommunicator::MAX_OP); in GetZTranslation()
|
/dports/math/vtk8/VTK-8.2.0/Filters/Parallel/ |
H A D | vtkPProjectSphereFilter.cxx | 49 controller->AllReduce(&tmp, &minDist2ToCenterLineGlobal, in ComputePointsClosestToCenterLine() 69 controller->AllReduce(&localMax, &globalMax, 1, vtkCommunicator::MAX_OP); in GetZTranslation()
|