Function doHandShakeLocal

Src/Particle/AMReX_ParticleMPIUtil.cpp:50–94

    }

    Long doHandShakeLocal(const std::map<int, Vector<char> >& not_ours,
                          const Vector<int>& neighbor_procs, Vector<Long>& Snds, Vector<Long>& Rcvs)
    {

        Long NumSnds = 0;
        for (const auto& kv : not_ours)
        {
            NumSnds       += kv.second.size();
            Snds[kv.first] = kv.second.size();
        }

        const int SeqNum = ParallelDescriptor::SeqNum();

        const int num_rcvs = static_cast<int>(neighbor_procs.size());
        Vector<MPI_Status>  stats(num_rcvs);
        Vector<MPI_Request> rreqs(num_rcvs);

        // Post receives
        for (int i = 0; i < num_rcvs; ++i) {
            const int Who = neighbor_procs[i];
            const Long Cnt = 1;

            AMREX_ASSERT(Who >= 0 && Who < ParallelContext::NProcsSub());

            rreqs[i] = ParallelDescriptor::Arecv(&Rcvs[Who], Cnt, Who, SeqNum,
                                                 ParallelContext::CommunicatorSub()).req();
        }

        // Send.
        for (int i = 0; i < num_rcvs; ++i) {
            const int Who = neighbor_procs[i];
            const Long Cnt = 1;

            AMREX_ASSERT(Who >= 0 && Who < ParallelContext::NProcsSub());

            ParallelDescriptor::Send(&Snds[Who], Cnt, Who, SeqNum,
                                     ParallelContext::CommunicatorSub());
        }

        if (num_rcvs > 0) {
            ParallelDescriptor::Waitall(rreqs, stats);
        }

        return NumSnds;
    }
#endif  // AMREX_USE_MPI

}