new simgrid::instr::CollTIData(request == MPI_REQUEST_IGNORED ? "bcast" : "ibcast", root, -1.0,
count, 0,
simgrid::smpi::Datatype::encode(datatype), ""));
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // No barrier in Ibcast
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
if (comm->size() > 1) {
if (request == MPI_REQUEST_IGNORED)
simgrid::smpi::colls::bcast(buf, count, datatype, root, comm);
}
CHECK_ROOT(7)
CHECK_REQUEST(9)
- CHECK_COLLECTIVE(comm, std::string(request == MPI_REQUEST_IGNORED ? "PMPI_Gather" : "PMPI_Igather") + +" with root " +
+ CHECK_COLLECTIVE(comm, std::string(request == MPI_REQUEST_IGNORED ? "PMPI_Gather" : "PMPI_Igather") + " with root " +
std::to_string(root))
const void* real_sendbuf = sendbuf;
const SmpiBenchGuard suspend_bench;
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Igather
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
TRACE_smpi_comm_in(pid, request == MPI_REQUEST_IGNORED ? "PMPI_Gather" : "PMPI_Igather",
}
const SmpiBenchGuard suspend_bench;
+
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Igatherv
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
const void* real_sendbuf = sendbuf;
int real_sendcount = sendcount;
MPI_Datatype real_sendtype = sendtype;
CHECK_COLLECTIVE(comm, MPI_REQUEST_IGNORED ? "PMPI_Allgatherv" : "PMPI_Iallgatherv")
const SmpiBenchGuard suspend_bench;
+
if (sendbuf == MPI_IN_PLACE) {
sendbuf = static_cast<char*>(recvbuf) + recvtype->get_extent() * displs[comm->rank()];
sendcount = recvcounts[comm->rank()];
const SmpiBenchGuard suspend_bench;
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Iscatter
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
TRACE_smpi_comm_in(pid, request == MPI_REQUEST_IGNORED ? "PMPI_Scatter" : "PMPI_Iscatter",
const SmpiBenchGuard suspend_bench;
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Iscatterv
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
auto trace_sendcounts = std::make_shared<std::vector<int>>();
op->name() + " and root " + std::to_string(root))
const SmpiBenchGuard suspend_bench;
+
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Ireduce
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
TRACE_smpi_comm_in(pid, request == MPI_REQUEST_IGNORED ? "PMPI_Reduce" : "PMPI_Ireduce",
" with op " + op->name())
const SmpiBenchGuard suspend_bench;
+
std::vector<unsigned char> tmp_sendbuf;
const void* real_sendbuf = smpi_get_in_place_buf(sendbuf, recvbuf, tmp_sendbuf, count, datatype);
std::string(request == MPI_REQUEST_IGNORED ? "PMPI_Scan" : "PMPI_Iscan") + " with op " + op->name())
const SmpiBenchGuard suspend_bench;
+
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Iscan
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
std::vector<unsigned char> tmp_sendbuf;
const void* real_sendbuf = smpi_get_in_place_buf(sendbuf, recvbuf, tmp_sendbuf, count, datatype);
op->name())
const SmpiBenchGuard suspend_bench;
+
+ if (simgrid::config::get_value<bool>("smpi/barrier-collectives") &&
+ request == MPI_REQUEST_IGNORED) // no barrier in Iexscan
+ smpi_deployment_startup_barrier(smpi_process()->get_instance_id());
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
std::vector<unsigned char> tmp_sendbuf;
const void* real_sendbuf = smpi_get_in_place_buf(sendbuf, recvbuf, tmp_sendbuf, count, datatype);
" with op " + op->name())
const SmpiBenchGuard suspend_bench;
+
aid_t pid = simgrid::s4u::this_actor::get_pid();
auto trace_recvcounts = std::make_shared<std::vector<int>>();
trace_recvcounts->insert(trace_recvcounts->end(), &recvcounts[0], &recvcounts[comm->size()]);
" with op " + op->name())
const SmpiBenchGuard suspend_bench;
+
int count = comm->size();
aid_t pid = simgrid::s4u::this_actor::get_pid();
}
const SmpiBenchGuard suspend_bench;
+
int send_size = 0;
int recv_size = 0;
auto trace_sendcounts = std::make_shared<std::vector<int>>();