ForkMaster/netgen
1
0
Fork 0
mirror of https://github.com/NGSolve/netgen.git synced 2024-12-25 05:20:34 +05:00
Code Issues Packages Projects Releases Wiki Activity

timer in MPI wrappes

Browse Source
This commit is contained in:
Joachim Schöberl 2020-08-04 16:29:59 +02:00
parent 4682e6915c
commit 254257d406
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
libsrc/core/mpi_wrapper.hpp
View File

@ -8,6 +8,7 @@
#include "array.hpp" #include "array.hpp"
#include "exception.hpp" #include "exception.hpp"
#include "profiler.hpp"
namespace ngcore namespace ngcore
{ {
@ -122,6 +123,7 @@ namespace ngcore
int Rank() const { return rank; } int Rank() const { return rank; }
int Size() const { return size; } int Size() const { return size; }
void Barrier() const { void Barrier() const {
static Timer t("MPI - Barrier"); RegionTimer reg(t);
if (size > 1) MPI_Barrier (comm); if (size > 1) MPI_Barrier (comm);
} }
@ -200,6 +202,7 @@ namespace ngcore
template <typename T, typename T2 = decltype(GetMPIType<T>())> template <typename T, typename T2 = decltype(GetMPIType<T>())>
T Reduce (T d, const MPI_Op & op, int root = 0) const T Reduce (T d, const MPI_Op & op, int root = 0) const
{ {
static Timer t("MPI - Reduce"); RegionTimer reg(t);
if (size == 1) return d; if (size == 1) return d;
T global_d; T global_d;
@ -210,6 +213,7 @@ namespace ngcore
template <typename T, typename T2 = decltype(GetMPIType<T>())> template <typename T, typename T2 = decltype(GetMPIType<T>())>
T AllReduce (T d, const MPI_Op & op) const T AllReduce (T d, const MPI_Op & op) const
{ {
static Timer t("MPI - AllReduce"); RegionTimer reg(t);
if (size == 1) return d; if (size == 1) return d;
T global_d; T global_d;
@ -272,6 +276,7 @@ namespace ngcore
NETGEN_INLINE void MyMPI_WaitAll (FlatArray<MPI_Request> requests) NETGEN_INLINE void MyMPI_WaitAll (FlatArray<MPI_Request> requests)
{ {
static Timer t("MPI - WaitAll"); RegionTimer reg(t);
if (!requests.Size()) return; if (!requests.Size()) return;
MPI_Waitall (requests.Size(), requests.Data(), MPI_STATUSES_IGNORE); MPI_Waitall (requests.Size(), requests.Data(), MPI_STATUSES_IGNORE);
} }