Skip to content

Commit

Permalink
Add: MultiFab::sum_unique (AMReX-Codes#2909)
Browse files Browse the repository at this point in the history
This provides a new method to sum values in a `MultiFab`.
For non-cell-centered data, `MultiFab::sum` double counts box
boundary values that are owned by multiple boxes. This provides
a function that does not double count these and provides a
quick way to get only the sum of physically unique values.

Co-authored-by: Weiqun Zhang <WeiqunZhang@lbl.gov>
  • Loading branch information
ax3l and WeiqunZhang authored Aug 10, 2022
1 parent 3f715d2 commit 1bda173
Show file tree
Hide file tree
Showing 2 changed files with 60 additions and 0 deletions.
7 changes: 7 additions & 0 deletions Src/Base/AMReX_MultiFab.H
Original file line number Diff line number Diff line change
Expand Up @@ -232,6 +232,13 @@ public:
*/
Real sum (int comp = 0, bool local = false) const;
/**
* \brief Same as sum with local=false, but for non-cell-centered data, this
* skips non-unique points that are owned by multiple boxes.
*/
Real sum_unique (int comp = 0,
bool local = false,
const Periodicity& period = Periodicity::NonPeriodic()) const;
/**
* \brief Adds the scalar value val to the value of each cell in the
* specified subregion of the MultiFab. The subregion consists
* of the num_comp components starting at component comp.
Expand Down
53 changes: 53 additions & 0 deletions Src/Base/AMReX_MultiFab.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
#include <AMReX_BLProfiler.H>
#include <AMReX_iMultiFab.H>
#include <AMReX_FabArrayUtility.H>
#include <AMReX_REAL.H>

#ifdef AMREX_MEM_PROFILING
#include <AMReX_MemProfiler.H>
Expand Down Expand Up @@ -1586,6 +1587,58 @@ MultiFab::sum (int comp, bool local) const
return sm;
}

Real
MultiFab::sum_unique (int comp,
bool local,
const Periodicity& period) const
{
BL_PROFILE("MultiFab::sum_unique()");

// no duplicatly distributed points if cell centered
if (ixType().cellCentered())
return this->sum(comp, local);

// Owner is the grid with the lowest grid number containing the data
std::unique_ptr<iMultiFab> owner_mask = OwnerMask(period);

Real sm = Real(0.0);
#ifdef AMREX_USE_GPU
if (Gpu::inLaunchRegion()) {
auto const& ma = this->const_arrays();
auto const& msk = owner_mask->const_arrays();
sm = ParReduce(TypeList<ReduceOpSum>{}, TypeList<Real>{}, *this, IntVect(0),
[=] AMREX_GPU_DEVICE (int box_no, int i, int j, int k) noexcept
-> GpuTuple<Real>
{
return msk[box_no](i,j,k) ? ma[box_no](i,j,k,comp) : 0.0_rt;
});
} else
#endif
{
#ifdef AMREX_USE_OMP
#pragma omp parallel if (!system::regtest_reduction) reduction(+:sm)
#endif
for (MFIter mfi(*this,true); mfi.isValid(); ++mfi)
{
Box const& bx = mfi.tilebox();
Array4<Real const> const& a = this->const_array(mfi);
Array4<int const> const& msk = owner_mask->const_array(mfi);
Real tmp = 0.0_rt;
AMREX_LOOP_3D(bx, i, j, k,
{
tmp += msk(i,j,k) ? a(i,j,k,comp) : 0.0_rt;
});
sm += tmp; // Do it this way so that it does not break regression tests.
}
}

if (!local) {
ParallelAllReduce::Sum(sm, ParallelContext::CommunicatorSub());
}

return sm;
}

void
MultiFab::minus (const MultiFab& mf, int strt_comp, int num_comp, int nghost)
{
Expand Down

0 comments on commit 1bda173

Please sign in to comment.