Home
last modified time | relevance | path

Searched refs:AllReduce (Results 1 – 25 of 209) sorted by relevance

123456789

/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/net/
H A Dgroup.hpp152 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 DvtkMultiProcessController.h1281 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 DvtkCommunicator.h1076 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 DvtkMultiProcessController.h1264 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 DvtkCommunicator.h1103 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 DvtkMultiProcessController.h907 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 DvtkCommunicator.h689 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 Dmpi.cpp2286 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 DvtkPExodusIIWriter.cxx117 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 DvtkPExodusIIWriter.cxx111 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 DvtkPExtractHistogram2D.cxx91 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 DvtkPExtractHistogram2D.cxx91 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 DvtkPExtractHistogram2D.cxx91 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 DvtkPExodusIIWriter.cxx117 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 Dmerge.hpp279 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 DTestPolyhedralMeshDistributedDataFilter.cxx50 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 DParallelConnectivity.cxx116 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 DParallelConnectivity.cxx112 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 DvtkCGNSFileSeriesReader.cxx374 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 Dnet_benchmark.cpp213 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 DTestPOpenFOAMReaderLagrangianUncollated.cxx140 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 DTestPOpenFOAMReaderLagrangianSerial.cxx141 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 DCollectives.cpp134 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 DvtkPProjectSphereFilter.cxx48 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 DvtkPProjectSphereFilter.cxx49 controller->AllReduce(&tmp, &minDist2ToCenterLineGlobal, in ComputePointsClosestToCenterLine()
69 controller->AllReduce(&localMax, &globalMax, 1, vtkCommunicator::MAX_OP); in GetZTranslation()

123456789