aid_t rank_traced = simgrid::s4u::this_actor::get_pid();
TRACE_smpi_comm_in(rank_traced, __func__, new simgrid::instr::CpuTIData("IO - read", count * datatype->size()));
int ret = fh->seek(offset,MPI_SEEK_SET);
- if(ret!=MPI_SUCCESS)
- return ret;
- ret = simgrid::smpi::File::read(fh, buf, count, datatype, status);
+ if (ret == MPI_SUCCESS)
+ ret = simgrid::smpi::File::read(fh, buf, count, datatype, status);
TRACE_smpi_comm_out(rank_traced);
smpi_bench_begin();
return ret;
TRACE_smpi_comm_in(rank_traced, __func__,
new simgrid::instr::CpuTIData("IO - read_at_all", count * datatype->size()));
int ret = fh->seek(offset,MPI_SEEK_SET);
- if(ret!=MPI_SUCCESS)
- return ret;
- ret = fh->op_all<simgrid::smpi::File::read>(buf, count, datatype, status);
+ if (ret == MPI_SUCCESS)
+ ret = fh->op_all<simgrid::smpi::File::read>(buf, count, datatype, status);
TRACE_smpi_comm_out(rank_traced);
smpi_bench_begin();
return ret;
aid_t rank_traced = simgrid::s4u::this_actor::get_pid();
TRACE_smpi_comm_in(rank_traced, __func__, new simgrid::instr::CpuTIData("IO - write", count * datatype->size()));
int ret = fh->seek(offset,MPI_SEEK_SET);
- if(ret!=MPI_SUCCESS)
- return ret;
- ret = simgrid::smpi::File::write(fh, const_cast<void*>(buf), count, datatype, status);
+ if (ret == MPI_SUCCESS)
+ ret = simgrid::smpi::File::write(fh, const_cast<void*>(buf), count, datatype, status);
TRACE_smpi_comm_out(rank_traced);
smpi_bench_begin();
return ret;
TRACE_smpi_comm_in(rank_traced, __func__,
new simgrid::instr::CpuTIData("IO - write_at_all", count * datatype->size()));
int ret = fh->seek(offset,MPI_SEEK_SET);
- if(ret!=MPI_SUCCESS)
- return ret;
- ret = fh->op_all<simgrid::smpi::File::write>(const_cast<void*>(buf), count, datatype, status);
+ if (ret == MPI_SUCCESS)
+ ret = fh->op_all<simgrid::smpi::File::write>(const_cast<void*>(buf), count, datatype, status);
TRACE_smpi_comm_out(rank_traced);
smpi_bench_begin();
return ret;
void* bsend_buf = nullptr;
smpi_process()->bsend_buffer(&bsend_buf, &bsend_buf_size);
int size = datatype->get_extent() * count;
- if(bsend_buf==nullptr || bsend_buf_size < size + MPI_BSEND_OVERHEAD )
+ if (bsend_buf == nullptr || bsend_buf_size < size + MPI_BSEND_OVERHEAD) {
+ smpi_bench_begin();
return MPI_ERR_BUFFER;
+ }
TRACE_smpi_comm_in(my_proc_id, __func__,
new simgrid::instr::Pt2PtTIData("bsend", dst,
datatype->is_replayable() ? count : count * datatype->size(),
void* bsend_buf = nullptr;
smpi_process()->bsend_buffer(&bsend_buf, &bsend_buf_size);
int size = datatype->get_extent() * count;
- if(bsend_buf==nullptr || bsend_buf_size < size + MPI_BSEND_OVERHEAD )
+ if (bsend_buf == nullptr || bsend_buf_size < size + MPI_BSEND_OVERHEAD) {
+ smpi_bench_begin();
return MPI_ERR_BUFFER;
+ }
TRACE_smpi_comm_in(my_proc_id, __func__,
new simgrid::instr::Pt2PtTIData("ibsend", dst,
datatype->is_replayable() ? count : count * datatype->size(),