spades::particles::MessageParticleContainer Class Reference

Main SPADES message container. More...

#include <MessageParticleContainer.H>

Inheritance diagram for spades::particles::MessageParticleContainer:

Collaboration diagram for spades::particles::MessageParticleContainer:

Public Member Functions
	MessageParticleContainer (amrex::AmrParGDB *par_gdb, int ngrow=0)
	Constructor.
	MessageParticleContainer (const amrex::Vector< amrex::Geometry > &geom, const amrex::Vector< amrex::DistributionMapping > &dmap, const amrex::Vector< amrex::BoxArray > &ba, int ngrow=0)
	Constructor.
template<typename Model >
void	initialize_messages (const Model &model)
	Initialize the messages.
void	sort () override
	Sort the messages.
void	update_undefined ()
	Update the undefined messages.
void	resolve_pairs ()
	Resolve message pairs (remove message/anti-message pairs)
amrex::Real	compute_gvt ()
	Compute the minimum time stamp of the messages.
void	garbage_collect (const amrex::Real gvt)
	Perform garbage collection.
void	write_plot_file (const std::string &plt_filename) override
	Write the particles to file.
void	read_parameters () override
	Read user parameters.
void	initialize_variable_names () override
	Initialize variable names.
Public Member Functions inherited from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >
	SpadesParticleContainer (amrex::AmrParGDB *par_gdb, int ngrow=0)
	Constructor.
	SpadesParticleContainer (const amrex::Vector< amrex::Geometry > &geom, const amrex::Vector< amrex::DistributionMapping > &dmap, const amrex::Vector< amrex::BoxArray > &ba, int ngrow=0)
	Constructor.
void	initialize_state ()
	Initialize particle states (counts and offsets)
void	clear_state ()
	Delete particle states (counts and offsets)
void	update_counts ()
	Update the particle counts and offsets.
void	count_particles ()
	Update the particle counts.
void	count_offsets ()
	Update the particle offsets.
const amrex::iMultiFab &	counts () const
	Get the particle counts.
const amrex::iMultiFab &	offsets () const
	Get the particle offsets.
amrex::Long	total_count (const int typ) const
	Get the total number of particles of typ.
amrex::Long	min_count (const int typ) const
	Get the minimum number of particles of typ.
amrex::Long	max_count (const int typ) const
	Get the maximum number of particles of typ.
void	check_sort (const amrex::MFIter &mfi)
	Check the result of the sort operation.
void	sort_impl (const CompareFunctor &compare)
	Sort the particles implementation.
void	sort_impl (const CompareFunc &compare)
void	nonencoded_sort_impl (const CompareFunctor &compare)
	Non-encoded sort the particles implementation.
void	nonencoded_sort_impl (const CompareFunc &compare)
void	encoded_sort_impl ()
	Encoded sort the particles implementation.
void	print_messages (const std::string &header)
	Print all the particles to screen.
void	reposition_particles ()
	Reposition the particles inside a cell for visualization.
int	ngrow () const
	Number of grow cells.
void	write_plot_file_impl (const std::string &plt_filename, const std::string &name)
	Write the particles to file (implementation)
void	check_sort_type (const std::string &sort_type)
	Check valid sort type.
ParticleArrays< NArrayReal, NArrayInt, ParticleType, RealVector, IntVector >	particle_arrays (ParticleTileType &pti) const

Static Public Member Functions
static std::string	identifier ()
	Class identifier name.
Static Public Member Functions inherited from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >
static std::string	identifier ()
	Class identifier name.

Additional Inherited Members
Public Types inherited from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >
using	ParticleType
using	ParticleTileType
using	IntVector
using	RealVector
Static Public Attributes inherited from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >
static constexpr int	LEV
	Level index.
Protected Attributes inherited from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >
int	m_ngrow
	Number of grow cells.
amrex::Vector< int >	m_writeflags_real
	Flags for real data to write to file.
amrex::Vector< int >	m_writeflags_int
	Flags for int data to write to file.
amrex::Vector< std::string >	m_real_data_names
	Names for real data to write to file.
amrex::Vector< std::string >	m_int_data_names
	Names for int data to write to file.
std::string	m_sort_type
	Sort type.
amrex::iMultiFab	m_counts
	Count of particles in each cell.
amrex::iMultiFab	m_offsets
	Offsets of particles in each cell.
amrex::MultiFab	m_min_timestamp
	Minimum timestamp in each cell for each type.
amrex::MultiFab	m_max_timestamp
	Maximum timestamp in each cell for each type.

Detailed Description

Main SPADES message container.

Constructor & Destructor Documentation

MessageParticleContainer() [1/2]

spades::particles::MessageParticleContainer::MessageParticleContainer ( amrex::AmrParGDB * par_gdb, int ngrow = 0 )

explicit

Constructor.

Parameters

par_gdb	[in] particle database
ngrow	[in] number of grow cells

    : SpadesParticleContainer<
          MessageTypes::NTYPES,
          0,
          0,
          MessageRealData::ncomps,
          MessageIntData::ncomps>(par_gdb, ngrow)
{}

MessageParticleContainer() [2/2]

spades::particles::MessageParticleContainer::MessageParticleContainer ( const amrex::Vector< amrex::Geometry > & geom, const amrex::Vector< amrex::DistributionMapping > & dmap, const amrex::Vector< amrex::BoxArray > & ba, int ngrow = 0 )

explicit

Constructor.

Parameters

geom	[in] geometry
dmap	[in] distribution map
ba	[in] box array
ngrow	[in] number of grow cells

    : SpadesParticleContainer<
          MessageTypes::NTYPES,
          0,
          0,
          MessageRealData::ncomps,
          MessageIntData::ncomps>(geom, dmap, ba, ngrow)
{}

Member Function Documentation

compute_gvt()

amrex::Real spades::particles::MessageParticleContainer::compute_gvt

(

)

Compute the minimum time stamp of the messages.

{
    BL_PROFILE("spades::MessageParticleContainer::compute_gvt()");
    // If this becomes a performance bottleneck it could be sped up by
    // making a vector of just the message time stamps before the min op
 
    amrex::Real gvt = constants::LARGE_NUM;
 
#ifdef AMREX_USE_OMP
#pragma omp parallel if (amrex::Gpu::notInLaunchRegion()) reduction(min : gvt)
#endif
    for (MyParIter pti(*this, LEV); pti.isValid(); ++pti) {
        const size_t np = pti.numParticles();
        const auto parrs = particle_arrays(pti.GetParticleTile());
 
        amrex::Gpu::DeviceVector<amrex::Real> ts(np, constants::LARGE_NUM);
        auto* p_ts = ts.data();
        amrex::ParallelFor(np, [=] AMREX_GPU_DEVICE(long pidx) noexcept {
            if (parrs.m_idata[CommonIntData::type_id][pidx] ==
                MessageTypes::MESSAGE) {
                p_ts[pidx] = parrs.m_rdata[CommonRealData::timestamp][pidx];
            }
        });
        gvt = std::min(amrex::Reduce::Min(np, ts.data()), gvt);
    }
    amrex::ParallelDescriptor::ReduceRealMin(gvt);
 
    return gvt;
}

Here is the call graph for this function:

garbage_collect()

void spades::particles::MessageParticleContainer::garbage_collect

(

const amrex::Real

gvt

)

Perform garbage collection.

Parameters

gvt	[in] global virtual time

{
    BL_PROFILE("spades::MessageParticleContainer::garbage_collect()");
 
#ifdef AMREX_USE_OMP
#pragma omp parallel if (amrex::Gpu::notInLaunchRegion())
#endif
    for (MyParIter pti(*this, LEV); pti.isValid(); ++pti) {
        const size_t np = pti.numParticles();
        const auto parrs = particle_arrays(pti.GetParticleTile());
 
        amrex::ParallelFor(np, [=] AMREX_GPU_DEVICE(long pidx) noexcept {
            if (((parrs.m_rdata[CommonRealData::timestamp][pidx] < gvt) &&
                 (parrs.m_idata[CommonIntData::type_id][pidx] !=
                  MessageTypes::UNDEFINED)) ||
                ((parrs.m_idata[CommonIntData::type_id][pidx] ==
                  MessageTypes::CONJUGATE) &&
                 (parrs.m_rdata[MessageRealData::creation_time][pidx] < gvt))) {
                AMREX_ASSERT(
                    parrs.m_idata[CommonIntData::type_id][pidx] !=
                    MessageTypes::MESSAGE);
                MarkMessageUndefined()(pidx, parrs);
            }
        });
    }
}

Here is the call graph for this function:

identifier()

static std::string spades::particles::MessageParticleContainer::identifier ( )

inlinestatic

Class identifier name.

Returns

class identifier

{ return "messages"; }

Here is the caller graph for this function:

initialize_messages()

template<typename Model >

void spades::particles::MessageParticleContainer::initialize_messages

(

const Model &

model

)

Initialize the messages.

Parameters

model

[in] model

{
    BL_PROFILE("spades::MessageParticleContainer::initialize_messages()");
 
    const auto& plo = Geom(LEV).ProbLoArray();
    const auto& dx = Geom(LEV).CellSizeArray();
    const auto& dom = Geom(LEV).Domain();
    const auto init_message_op = model.init_message_op();
    const auto messages_per_lp = init_message_op.m_messages_per_lp;
    const int total_messages_per_lp = 3 * messages_per_lp;
    AMREX_ALWAYS_ASSERT(total_messages_per_lp > messages_per_lp);
 
    for (amrex::MFIter mfi = MakeMFIter(LEV); mfi.isValid(); ++mfi) {
        DefineAndReturnParticleTile(LEV, mfi);
    }
 
    amrex::iMultiFab num_particles(
        ParticleBoxArray(LEV), ParticleDistributionMap(LEV), 1, 0,
        amrex::MFInfo());
    amrex::iMultiFab init_offsets(
        ParticleBoxArray(LEV), ParticleDistributionMap(LEV), 1, 0,
        amrex::MFInfo());
    num_particles.setVal(total_messages_per_lp);
    init_offsets.setVal(0);
 
    for (amrex::MFIter mfi = MakeMFIter(LEV); mfi.isValid(); ++mfi) {
        const amrex::Box& box = mfi.tilebox();
 
        const auto ncells = static_cast<int>(box.numPts());
        const int* in = num_particles[mfi].dataPtr();
        int* out = init_offsets[mfi].dataPtr();
        const auto np = amrex::Scan::PrefixSum<int>(
            ncells, [=] AMREX_GPU_DEVICE(int i) -> int { return in[i]; },
            [=] AMREX_GPU_DEVICE(int i, int const& xi) { out[i] = xi; },
            amrex::Scan::Type::exclusive, amrex::Scan::retSum);
 
        const amrex::Long pid = ParticleType::NextID();
        ParticleType::NextID(pid + np);
        AMREX_ALWAYS_ASSERT_WITH_MESSAGE(
            static_cast<amrex::Long>(pid + np) < amrex::LastParticleID,
            "Error: overflow on particle id numbers!");
 
        const auto my_proc = amrex::ParallelDescriptor::MyProc();
        const auto& offset_arr = init_offsets[mfi].const_array();
        const auto& num_particles_arr = num_particles[mfi].const_array();
        const auto index = std::make_pair(mfi.index(), mfi.LocalTileIndex());
        auto& pti = GetParticles(LEV)[index];
        pti.resize(np);
        const auto parrs = particle_arrays(pti);
        amrex::ParallelForRNG(
            box, [=] AMREX_GPU_DEVICE(
                     int i, int j, int AMREX_D_PICK(, , k),
                     amrex::RandomEngine const& engine) noexcept {
                const amrex::IntVect iv(AMREX_D_DECL(i, j, k));
                const int start = offset_arr(iv);
                for (int n = start; n < start + num_particles_arr(iv); n++) {
                    auto& p = parrs.m_aos[n];
                    p.id() = pid + n;
                    p.cpu() = my_proc;
 
                    MarkMessageUndefined()(n, parrs);
                    parrs.m_idata[MessageIntData::sender_lp][n] =
                        static_cast<int>(dom.index(iv));
                    parrs.m_idata[MessageIntData::sender_entity][n] = 0;
                    parrs.m_idata[MessageIntData::receiver_lp][n] =
                        static_cast<int>(dom.index(iv));
                    parrs.m_idata[MessageIntData::receiver_entity][n] = 0;
 
                    AMREX_D_TERM(
                        p.pos(0) = plo[0] + (iv[0] + constants::HALF) * dx[0];
                        , p.pos(1) = plo[1] + (iv[1] + constants::HALF) * dx[1];
                        ,
                        p.pos(2) = plo[2] + (iv[2] + constants::HALF) * dx[2];)
 
                    AMREX_D_TERM(parrs.m_idata[CommonIntData::i][n] = iv[0];
                                 , parrs.m_idata[CommonIntData::j][n] = iv[1];
                                 , parrs.m_idata[CommonIntData::k][n] = iv[2];)
                }
 
                for (int n = start; n < start + messages_per_lp; n++) {
                    init_message_op(parrs, n, engine);
                    parrs.m_idata[MessageIntData::pair_id][n] = -1;
                    parrs.m_idata[MessageIntData::pair_cpu][n] = -1;
                }
            });
 
        // This is necessary
        amrex::Gpu::streamSynchronize();
    }
    Redistribute();
 
    // Sanity check all initial particles
#ifdef AMREX_USE_OMP
#pragma omp parallel if (amrex::Gpu::notInLaunchRegion())
#endif
    for (MyParIter pti(*this, LEV); pti.isValid(); ++pti) {
        const size_t np = pti.numParticles();
        const auto parrs = particle_arrays(pti.GetParticleTile());
 
        amrex::ParallelFor(np, [=] AMREX_GPU_DEVICE(long pidx) noexcept {
            bool valid_type = false;
            for (int typ = 0; typ < MessageTypes::NTYPES; typ++) {
                valid_type = parrs.m_idata[CommonIntData::type_id][pidx] == typ;
                if (valid_type) {
                    break;
                }
            }
            AMREX_ASSERT(valid_type);
            AMREX_ASSERT(parrs.m_aos[pidx].id() >= 0);
        });
    }
}

Here is the call graph for this function:

initialize_variable_names()

void spades::particles::MessageParticleContainer::initialize_variable_names ( )

overridevirtual

Initialize variable names.

Implements spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >.

{
    BL_PROFILE("spades::MessageParticleContainer::initialize_variable_names()");
 
    m_real_data_names.resize(MessageRealData::ncomps, "");
    m_writeflags_real.resize(MessageRealData::ncomps, 0);
    m_int_data_names.resize(MessageIntData::ncomps, "");
    m_writeflags_int.resize(MessageIntData::ncomps, 0);
 
    m_real_data_names[CommonRealData::timestamp] = "timestamp";
    m_writeflags_real[CommonRealData::timestamp] = 1;
    m_real_data_names[MessageRealData::old_timestamp] = "old_timestamp";
    m_writeflags_real[MessageRealData::old_timestamp] = 1;
    m_real_data_names[MessageRealData::creation_time] = "creation_time";
    m_writeflags_real[MessageRealData::creation_time] = 1;
 
    AMREX_D_TERM(
        m_int_data_names[CommonIntData::i] = "i";
        m_writeflags_int[CommonIntData::i] = 1;
        , m_int_data_names[CommonIntData::j] = "j";
        m_writeflags_int[CommonIntData::j] = 1;
        , m_int_data_names[CommonIntData::k] = "k";
        m_writeflags_int[CommonIntData::k] = 1;)
    m_int_data_names[CommonIntData::type_id] = "type_id";
    m_writeflags_int[CommonIntData::type_id] = 1;
    m_int_data_names[MessageIntData::sender_lp] = "sender_lp";
    m_writeflags_int[MessageIntData::sender_lp] = 1;
    m_int_data_names[MessageIntData::sender_entity] = "sender_entity";
    m_writeflags_int[MessageIntData::sender_entity] = 1;
    m_int_data_names[MessageIntData::receiver_lp] = "receiver_lp";
    m_writeflags_int[MessageIntData::receiver_lp] = 1;
    m_int_data_names[MessageIntData::receiver_entity] = "receiver_entity";
    m_writeflags_int[MessageIntData::receiver_entity] = 1;
    m_int_data_names[MessageIntData::pair_id] = "pair_id";
    m_writeflags_int[MessageIntData::pair_id] = 0;
    m_int_data_names[MessageIntData::pair_cpu] = "pair_cpu";
    m_writeflags_int[MessageIntData::pair_cpu] = 0;
}

read_parameters()

void spades::particles::MessageParticleContainer::read_parameters ( )

overridevirtual

Read user parameters.

Reimplemented from spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >.

{
    SpadesParticleContainer::read_parameters();
}

Here is the call graph for this function:

resolve_pairs()

void spades::particles::MessageParticleContainer::resolve_pairs

(

)

Resolve message pairs (remove message/anti-message pairs)

{
    BL_PROFILE("spades::MessageParticleContainer::resolve_pairs()");
 
#ifdef AMREX_DEBUG
    const auto& dom = Geom(LEV).Domain();
#endif
 
#ifdef AMREX_USE_OMP
#pragma omp parallel if (amrex::Gpu::notInLaunchRegion())
#endif
    for (amrex::MFIter mfi = MakeMFIter(LEV); mfi.isValid(); ++mfi) {
        const amrex::Box& box = mfi.tilebox();
        const auto& cnt_arr = m_counts.const_array(mfi);
        const auto& offsets_arr = m_offsets.const_array(mfi);
        const auto index = std::make_pair(mfi.index(), mfi.LocalTileIndex());
        auto& pti = GetParticles(LEV)[index];
        const auto parrs = particle_arrays(pti);
 
        amrex::ParallelFor(
            box, [=] AMREX_GPU_DEVICE(
                     int i, int j, int AMREX_D_PICK(, , k)) noexcept {
                const amrex::IntVect iv(AMREX_D_DECL(i, j, k));
                const auto getter = Get(iv, cnt_arr, offsets_arr, parrs);
 
                for (int n = 0; n < cnt_arr(iv, MessageTypes::ANTI); n++) {
                    const auto pant_soa = getter(n, MessageTypes::ANTI);
                    AMREX_ASSERT(
                        parrs.m_idata[MessageIntData::pair_id][pant_soa] != -1);
                    AMREX_ASSERT(
                        parrs.m_idata[MessageIntData::pair_cpu][pant_soa] !=
                        -1);
                    AMREX_ASSERT(
                        parrs.m_idata[MessageIntData::receiver_lp][pant_soa] ==
                        dom.index(iv));
 
#ifdef AMREX_DEBUG
                    bool found_pair = false;
#endif
                    for (int m = 0; m < cnt_arr(iv, MessageTypes::MESSAGE);
                         m++) {
                        // This is a message that was already treated,
                        // expect it to be undefined
                        if (!getter.check(m, MessageTypes::MESSAGE)) {
                            getter.assert_different(
                                m, MessageTypes::MESSAGE,
                                MessageTypes::UNDEFINED);
                            continue;
                        }
                        const auto pmsg_soa = getter(m, MessageTypes::MESSAGE);
                        if ((parrs.m_idata[MessageIntData::pair_id][pmsg_soa] ==
                             parrs
                                 .m_idata[MessageIntData::pair_id][pant_soa]) &&
                            (parrs
                                 .m_idata[MessageIntData::pair_cpu][pmsg_soa] ==
                             parrs.m_idata[MessageIntData::pair_cpu]
                                          [pant_soa]) &&
                            (std::abs(
                                 parrs.m_rdata[CommonRealData::timestamp]
                                              [pmsg_soa] -
                                 parrs.m_rdata[CommonRealData::timestamp]
                                              [pant_soa]) < constants::EPS)) {
                            AMREX_ASSERT(
                                parrs.m_idata[MessageIntData::sender_lp]
                                             [pmsg_soa] ==
                                parrs.m_idata[MessageIntData::sender_lp]
                                             [pant_soa]);
                            AMREX_ASSERT(
                                parrs.m_idata[MessageIntData::sender_entity]
                                             [pmsg_soa] ==
                                parrs.m_idata[MessageIntData::sender_entity]
                                             [pant_soa]);
                            AMREX_ASSERT(
                                parrs.m_idata[MessageIntData::receiver_lp]
                                             [pmsg_soa] ==
                                parrs.m_idata[MessageIntData::receiver_lp]
                                             [pant_soa]);
                            AMREX_ASSERT(
                                parrs.m_idata[MessageIntData::receiver_entity]
                                             [pmsg_soa] ==
                                parrs.m_idata[MessageIntData::receiver_entity]
                                             [pant_soa]);
                            AMREX_ASSERT(
                                std::abs(
                                    parrs
                                        .m_rdata[MessageRealData::creation_time]
                                                [pmsg_soa] -
                                    parrs
                                        .m_rdata[MessageRealData::creation_time]
                                                [pant_soa]) < constants::EPS);
                            MarkMessageUndefined()(pant_soa, parrs);
                            MarkMessageUndefined()(pmsg_soa, parrs);
#ifdef AMREX_DEBUG
                            found_pair = true;
#endif
                            break;
                        }
                    }
                    AMREX_ASSERT(found_pair);
                }
            });
    }
 
    sort();
}

Here is the call graph for this function:

sort()

void spades::particles::MessageParticleContainer::sort ( )

overridevirtual

Sort the messages.

Implements spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >.

{
    BL_PROFILE("spades::MessageParticleContainer::sort()");
 
    sort_impl(CompareParticle());
}

Here is the call graph for this function:

Here is the caller graph for this function:

update_undefined()

void spades::particles::MessageParticleContainer::update_undefined

(

)

Update the undefined messages.

{
    BL_PROFILE("spades::MessageParticleContainer::update_undefined()");
 
    const auto& plo = Geom(LEV).ProbLoArray();
    const auto& dx = Geom(LEV).CellSizeArray();
    const auto& dom = Geom(LEV).Domain();
    int n_removals = 0;
 
    MessageParticleContainer pc_adds(
        m_gdb->Geom(), m_gdb->DistributionMap(), m_gdb->boxArray(), ngrow());
    for (amrex::MFIter mfi = MakeMFIter(LEV); mfi.isValid(); ++mfi) {
        pc_adds.DefineAndReturnParticleTile(LEV, mfi);
    }
 
    for (amrex::MFIter mfi = MakeMFIter(LEV); mfi.isValid(); ++mfi) {
        const amrex::Box& box = mfi.tilebox();
        const auto index = std::make_pair(mfi.index(), mfi.LocalTileIndex());
        const auto& cnt_arr = m_counts.const_array(mfi);
        const auto& offsets_arr = m_offsets.const_array(mfi);
        auto& pti = GetParticles(LEV)[index];
        const auto parrs = particle_arrays(pti);
 
        // remove particles
        const auto ncells = static_cast<int>(box.numPts());
        amrex::Gpu::DeviceVector<int> removals(ncells, 0);
        auto* p_removals = removals.data();
        amrex::ParallelFor(ncells, [=] AMREX_GPU_DEVICE(long icell) noexcept {
            const auto iv = box.atOffset(icell);
            const int msg_count = cnt_arr(iv, MessageTypes::MESSAGE);
            const int target_count = std::max(2 * msg_count, 2);
            const int current_count = cnt_arr(iv, MessageTypes::UNDEFINED);
            if (current_count > target_count) {
                p_removals[icell] = current_count - target_count;
            }
        });
 
        n_removals += amrex::Reduce::Sum(removals.size(), p_removals);
 
        amrex::ParallelFor(
            box, [=] AMREX_GPU_DEVICE(
                     int i, int j, int AMREX_D_PICK(, , k)) noexcept {
                const amrex::IntVect iv(AMREX_D_DECL(i, j, k));
                const auto idx = box.index(iv);
                const auto np = p_removals[idx];
                const auto getter = Get(iv, cnt_arr, offsets_arr, parrs);
                for (int m = 0; m < np; m++) {
                    const auto pidx = getter(m, MessageTypes::UNDEFINED);
                    parrs.m_aos[pidx].id() = -1;
                }
            });
 
        amrex::Gpu::DeviceVector<int> additions(ncells, 0);
        auto* p_additions = additions.data();
        amrex::ParallelFor(ncells, [=] AMREX_GPU_DEVICE(long icell) noexcept {
            const auto iv = box.atOffset(icell);
            const int msg_count = cnt_arr(iv, MessageTypes::MESSAGE);
            const int target_count = std::max(2 * msg_count, 2);
            const int current_count = cnt_arr(iv, MessageTypes::UNDEFINED);
            if (target_count > current_count) {
                p_additions[icell] = target_count - current_count;
            }
#ifdef AMREX_DEBUG
            if (p_removals[icell] > 0) {
                AMREX_ASSERT(p_additions[icell] == 0);
            }
            if (p_additions[icell] > 0) {
                AMREX_ASSERT(p_removals[icell] == 0);
            }
#endif
        });
 
        amrex::Gpu::DeviceVector<int> update_offsets(ncells, 0);
        auto* p_update_offsets = update_offsets.data();
        const auto np = amrex::Scan::PrefixSum<int>(
            ncells,
            [=] AMREX_GPU_DEVICE(int i) -> int { return p_additions[i]; },
            [=] AMREX_GPU_DEVICE(int i, int const& xi) {
                p_update_offsets[i] = xi;
            },
            amrex::Scan::Type::exclusive, amrex::Scan::retSum);
 
        const amrex::Long pid = ParticleType::NextID();
        ParticleType::NextID(pid + np);
        AMREX_ALWAYS_ASSERT_WITH_MESSAGE(
            static_cast<amrex::Long>(pid + np) < amrex::LastParticleID,
            "Error: overflow on particle id numbers!");
 
        auto& pti_adds = pc_adds.GetParticles(LEV)[index];
        pti_adds.resize(np);
        const auto my_proc = amrex::ParallelDescriptor::MyProc();
        const auto parrs_adds = pc_adds.particle_arrays(pti_adds);
        amrex::ParallelFor(ncells, [=] AMREX_GPU_DEVICE(long icell) noexcept {
            const int start = p_update_offsets[icell];
            const auto iv = box.atOffset(icell);
            for (int n = start; n < start + p_additions[icell]; n++) {
                auto& p = parrs_adds.m_aos[n];
                p.id() = pid + n;
                p.cpu() = my_proc;
 
                AMREX_D_TERM(
                    p.pos(0) = plo[0] + (iv[0] + constants::HALF) * dx[0];
                    , p.pos(1) = plo[1] + (iv[1] + constants::HALF) * dx[1];
                    , p.pos(2) = plo[2] + (iv[2] + constants::HALF) * dx[2];)
 
                MarkMessageUndefined()(n, parrs_adds);
                parrs_adds.m_idata[MessageIntData::sender_lp][n] =
                    static_cast<int>(dom.index(iv));
                parrs_adds.m_idata[MessageIntData::sender_entity][n] = 0;
                parrs_adds.m_idata[MessageIntData::receiver_lp][n] =
                    static_cast<int>(dom.index(iv));
                parrs_adds.m_idata[MessageIntData::receiver_entity][n] = 0;
 
                AMREX_D_TERM(
                    p.pos(0) = plo[0] + (iv[0] + constants::HALF) * dx[0];
                    , p.pos(1) = plo[1] + (iv[1] + constants::HALF) * dx[1];
                    , p.pos(2) = plo[2] + (iv[2] + constants::HALF) * dx[2];)
 
                AMREX_D_TERM(parrs_adds.m_idata[CommonIntData::i][n] = iv[0];
                             , parrs_adds.m_idata[CommonIntData::j][n] = iv[1];
                             , parrs_adds.m_idata[CommonIntData::k][n] = iv[2];)
            }
        });
 
        // This is necessary
        amrex::Gpu::streamSynchronize();
    }
 
    addParticles(pc_adds, true);
 
    amrex::ParallelAllReduce::Sum<int>(
        n_removals, amrex::ParallelContext::CommunicatorSub());
    if (n_removals > 0) {
        Redistribute(); // kind of a bummer
    }
}

Here is the call graph for this function:

write_plot_file()

void spades::particles::MessageParticleContainer::write_plot_file ( const std::string & plt_filename )

inlineoverridevirtual

Write the particles to file.

Parameters

plt_filename

[in] file name for the plot file

Implements spades::particles::SpadesParticleContainer< MessageTypes::NTYPES, 0, 0, MessageRealData::ncomps, MessageIntData::ncomps >.

    {
        write_plot_file_impl(plt_filename, identifier());
    };

Here is the call graph for this function:

---

The documentation for this class was generated from the following files:

• /home/runner/work/spades/spades/Source/MessageParticleContainer.H
• /home/runner/work/spades/spades/Source/MessageParticleContainer.cpp