* {
* static MPI_Request request = MPI_REQUEST_NULL;
* MPI_InitFinalize::register_request(request);
- * MPI_Wait(&request, static_cast<MPI_Status*>(MPI_STATUS_IGNORE));
+ * MPI_Wait(&request, MPI_STATUS_IGNORE);
* // [some algorithm that is not safe to be executed twice in a row.]
* MPI_IBarrier(comm, &request);
* }
status.MPI_SOURCE,
status.MPI_TAG,
comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
Assert(received_objects.find(rank) == received_objects.end(),
ExcInternalError(
}
// Wait to have sent all objects.
- const int ierr =
- MPI_Waitall(send_to.size(),
- buffer_send_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(send_to.size(),
+ buffer_send_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
return received_objects;
// buffer itself as early as possible, and so we clear the
// buffer when the Future::get() function is called.
auto wait = [request]() mutable {
- const int ierr =
- MPI_Wait(&request, static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Wait(&request, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
};
auto cleanup = [send_buffer = std::move(send_buffer)]() {
std::vector<char> temp(amount);
- const auto ierr_3 =
- MPI_Recv(temp.data(),
- amount,
- MPI_CHAR,
- status.MPI_SOURCE,
- status.MPI_TAG,
- comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const auto ierr_3 = MPI_Recv(temp.data(),
+ amount,
+ MPI_CHAR,
+ status.MPI_SOURCE,
+ status.MPI_TAG,
+ comm,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr_3);
result = combiner(result, Utilities::unpack<T>(temp, false));
const int tag_deliver = Utilities::MPI::internal::Tags::
consensus_algorithm_nbx_process_deliver;
- const int ierr =
- MPI_Recv(recv_buffer.data(),
- recv_buffer.size(),
- MPI_CHAR,
- target,
- tag_deliver,
- comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Recv(recv_buffer.data(),
+ recv_buffer.size(),
+ MPI_CHAR,
+ target,
+ tag_deliver,
+ comm,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
other_rank,
tag_request,
comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
// Allocate memory for an answer message to the current request,
{
# ifdef DEAL_II_WITH_MPI
int all_ranks_reached_barrier;
- const auto ierr =
- MPI_Test(&barrier_request,
- &all_ranks_reached_barrier,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const auto ierr = MPI_Test(&barrier_request,
+ &all_ranks_reached_barrier,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
return all_ranks_reached_barrier != 0;
# else
{
if (send_requests.size() > 0)
{
- const int ierr =
- MPI_Waitall(send_requests.size(),
- send_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(send_requests.size(),
+ send_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
- int ierr = MPI_Wait(&barrier_request,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ int ierr = MPI_Wait(&barrier_request, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
for (auto &i : request_requests)
{
- ierr =
- MPI_Wait(i.get(), static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ ierr = MPI_Wait(i.get(), MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
// above blocks until we have a message, we know that the
// following MPI_Recv call will immediately succeed.
{
- const int ierr =
- MPI_Recv(recv_buffer.data(),
- recv_buffer.size(),
- MPI_CHAR,
- other_rank,
- tag_deliver,
- comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Recv(recv_buffer.data(),
+ recv_buffer.size(),
+ MPI_CHAR,
+ other_rank,
+ tag_deliver,
+ comm,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
// send-request and receive-answer operations.
if (send_request_requests.size() > 0)
{
- const int ierr =
- MPI_Waitall(send_request_requests.size(),
- send_request_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(send_request_requests.size(),
+ send_request_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
// Then also check the send-answer requests.
if (send_answer_requests.size() > 0)
{
- const int ierr =
- MPI_Waitall(send_answer_requests.size(),
- send_answer_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(send_answer_requests.size(),
+ send_answer_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
# endif
// wait that all data packages have been sent
const int ierr =
- MPI_Waitall(send_ranks.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(send_ranks.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
#endif
}
status.MPI_SOURCE,
internal::Tags::remote_point_evaluation,
tria->get_communicator(),
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
temp_recv_map[status.MPI_SOURCE] =
// make sure all messages have been sent
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
// copy received data into output vector
status.MPI_SOURCE,
internal::Tags::remote_point_evaluation,
tria->get_communicator(),
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
const auto recv_buffer_unpacked =
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
// sort for easy access during function call
if (requests.size() > 0)
{
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
requests.resize(0);
{
AssertDimension(locally_owned_array.size(), locally_owned_size());
const int ierr =
- MPI_Waitall(n_import_targets,
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(n_import_targets, requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
const Number *read_position = temporary_storage.data();
// wait for the send operations to complete
if (requests.size() > 0 && n_ghost_targets > 0)
{
- const int ierr =
- MPI_Waitall(n_ghost_targets,
- &requests[n_import_targets],
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(n_ghost_targets,
+ &requests[n_import_targets],
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
else
if (requests.size() > 0)
{
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
if (reply_requests.size() > 0)
{
- const int ierr =
- MPI_Waitall(reply_requests.size(),
- reply_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(reply_requests.size(),
+ reply_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
status.MPI_SOURCE,
tag,
mpi_communicator,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
const auto data =
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
sort_constraints();
status.MPI_SOURCE,
tag,
mpi_communicator,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
const auto received_locally_relevant_constrain =
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
sort_constraints();
int flag = 1;
if (update_ghost_values_requests.size() > 0)
{
- const int ierr =
- MPI_Testall(update_ghost_values_requests.size(),
- update_ghost_values_requests.data(),
- &flag,
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Testall(update_ghost_values_requests.size(),
+ update_ghost_values_requests.data(),
+ &flag,
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
Assert(flag == 1,
ExcMessage(
}
if (compress_requests.size() > 0)
{
- const int ierr =
- MPI_Testall(compress_requests.size(),
- compress_requests.data(),
- &flag,
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Testall(compress_requests.size(),
+ compress_requests.data(),
+ &flag,
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
Assert(flag == 1,
ExcMessage("MPI found unfinished compress() requests "
status.MPI_SOURCE,
Utilities::MPI::internal::Tags::fine_dof_handler_view_reinit,
communicator,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr_3);
for (unsigned int i = 0; i < buffer.size();)
}
const int ierr_1 =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr_1);
}
// Write the two parts of the header on rank 0:
if (my_rank == 0)
{
- ierr =
- Utilities::MPI::LargeCount::File_write_at_c(fh,
- 0,
- &header,
- sizeof(header),
- MPI_CHAR,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ ierr = Utilities::MPI::LargeCount::File_write_at_c(
+ fh, 0, &header, sizeof(header), MPI_CHAR, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
ierr = Utilities::MPI::LargeCount::File_write_at_c(
chunk_sizes.data(),
chunk_sizes.size(),
MPI_UINT64_T,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
n_ranks * sizeof(std::uint64_t) + prefix_sum;
ierr = Utilities::MPI::LargeCount::File_write_at_all_c(
- fh,
- offset,
- my_buffer.data(),
- my_size,
- MPI_CHAR,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ fh, offset, my_buffer.data(), my_size, MPI_CHAR, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
DataOutBase::write_vtu_header(ss, vtk_flags);
header_size = ss.str().size();
// Write the header on rank 0 at the start of a file, i.e., offset 0.
- ierr =
- Utilities::MPI::LargeCount::File_write_at_c(fh,
- 0,
- ss.str().c_str(),
- header_size,
- MPI_CHAR,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ ierr = Utilities::MPI::LargeCount::File_write_at_c(
+ fh, 0, ss.str().c_str(), header_size, MPI_CHAR, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
// Locate specific offset for each processor.
const MPI_Offset offset = static_cast<MPI_Offset>(header_size) + prefix_sum;
- ierr =
- Utilities::MPI::LargeCount::File_write_at_all_c(fh,
- offset,
- ss.str().c_str(),
- ss.str().size(),
- MPI_CHAR,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ ierr = Utilities::MPI::LargeCount::File_write_at_all_c(fh,
+ offset,
+ ss.str().c_str(),
+ ss.str().size(),
+ MPI_CHAR,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
if (myrank == n_ranks - 1)
const unsigned int footer_size = ss.str().size();
// Writing footer:
- ierr =
- Utilities::MPI::LargeCount::File_write_at_c(fh,
- footer_offset,
- ss.str().c_str(),
- footer_size,
- MPI_CHAR,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ ierr = Utilities::MPI::LargeCount::File_write_at_c(fh,
+ footer_offset,
+ ss.str().c_str(),
+ footer_size,
+ MPI_CHAR,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
}
status.MPI_SOURCE,
tag,
comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
return Utilities::unpack<XDMFEntry>(buffer, false);
std::vector<unsigned int> origins(n_recv_from);
for (auto &el : origins)
{
- const int ierr =
- MPI_Recv(&el,
- 1,
- MPI_UNSIGNED,
- MPI_ANY_SOURCE,
- mpi_tag,
- mpi_comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Recv(&el,
+ 1,
+ MPI_UNSIGNED,
+ MPI_ANY_SOURCE,
+ mpi_tag,
+ mpi_comm,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
if (destinations.size() > 0)
{
- const int ierr =
- MPI_Waitall(destinations.size(),
- send_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(destinations.size(),
+ send_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
// Before exiting, wait for nonblocking communication to complete:
for (auto request : requests)
{
- const int ierr =
- MPI_Wait(request, static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Wait(request, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
# if 0
// wait for non-blocking barrier to finish. This is a noop the
// first time we lock().
- const int ierr = MPI_Wait(&request, static_cast<MPI_Status*>(MPI_STATUS_IGNORE));
+ const int ierr = MPI_Wait(&request, MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
# else
// nothing to do as blocking barrier already completed
status.MPI_SOURCE,
status.MPI_TAG,
comm,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
// process message: loop over all intervals
for (auto interval : buffer)
// 5) make sure that all messages have been sent
if (request.size() > 0)
{
- const int ierr =
- MPI_Waitall(request.size(),
- request.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(request.size(),
+ request.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
if (send_requests.size() > 0)
{
- const auto ierr =
- MPI_Waitall(send_requests.size(),
- send_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const auto ierr = MPI_Waitall(send_requests.size(),
+ send_requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
requests);
export_to_ghosted_array_finish(make_array_view(ghost_indices), requests);
int flag = 0;
- const int ierr =
- MPI_Testall(requests.size(),
- requests.data(),
- &flag,
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Testall(requests.size(),
+ requests.data(),
+ &flag,
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
Assert(flag == 1,
ExcMessage(
&buffer_size,
1,
Utilities::MPI::mpi_type_id_for_type<decltype(buffer_size)>,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
// global position in file
buffer.data(),
buffer.size(), // local buffer
MPI_CHAR,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
ierr = MPI_File_close(&fh);
&buffer_size,
1,
Utilities::MPI::mpi_type_id_for_type<decltype(buffer_size)>,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
std::uint64_t offset = 0;
buffer.data(),
buffer.size(), // local buffer
MPI_CHAR,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
ierr = MPI_File_close(&fh);
it,
mpi_tag,
this->mpi_communicator,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
if (requests.size() > 0)
{
- ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ ierr = MPI_Waitall(requests.size(),
+ requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
sizes_fixed_cumulative.data(),
sizes_fixed_cumulative.size(),
MPI_UNSIGNED,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
src_data_fixed.data(),
src_data_fixed.size(),
MPI_BYTE,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
ierr = MPI_File_close(&fh);
src_sizes_variable.data(),
src_sizes_variable.size(),
MPI_INT,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
src_data_variable.data(),
src_data_variable.size(),
MPI_BYTE,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
sizes_fixed_cumulative.data(),
sizes_fixed_cumulative.size(),
MPI_UNSIGNED,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
// Allocate sufficient memory.
size_header +
static_cast<MPI_Offset>(global_first_cell) * bytes_per_cell;
- ierr =
- Utilities::MPI::LargeCount::File_read_at_c(fh,
- my_global_file_position,
- dest_data_fixed.data(),
- dest_data_fixed.size(),
- MPI_BYTE,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ ierr = Utilities::MPI::LargeCount::File_read_at_c(fh,
+ my_global_file_position,
+ dest_data_fixed.data(),
+ dest_data_fixed.size(),
+ MPI_BYTE,
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
dest_sizes_variable.data(),
dest_sizes_variable.size(),
MPI_INT,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
dest_data_variable.data(),
dest_data_variable.size(),
MPI_BYTE,
- static_cast<MPI_Status *>(
- MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
ierr = MPI_File_close(&fh);
source,
mpi_tag,
triangulation.get_communicator(),
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
source,
mpi_tag2,
triangulation.get_communicator(),
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
}
if (requests.size() > 0)
{
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
}
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
MPI_Waitany(sm_ghost_ranks.size() + ghost_targets_data.size(),
requests.data() + sm_import_ranks.size(),
&i,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
const auto s = split(i);
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
#endif
ghost_targets_data.size(),
requests.data() + sm_ghost_ranks.size(),
&i,
- static_cast<MPI_Status *>(MPI_STATUS_IGNORE));
+ MPI_STATUS_IGNORE);
AssertThrowMPI(ierr);
const auto &s = split(i);
}
const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(requests.size(), requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
#endif
}
// * wait for all MPI_Isend to complete
if (requests.size() > 0)
{
- const int ierr =
- MPI_Waitall(requests.size(),
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ const int ierr = MPI_Waitall(requests.size(),
+ requests.data(),
+ MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
requests.clear();
}
AssertThrowMPI(ierr);
}
const int ierr =
- MPI_Waitall(2 * n_neighbors,
- n_requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(2 * n_neighbors, n_requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
recv_ops++;
}
const int ierr =
- MPI_Waitall(send_ops + recv_ops,
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(send_ops + recv_ops, requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}
recv_ops++;
}
const int ierr =
- MPI_Waitall(send_ops + recv_ops,
- requests.data(),
- static_cast<MPI_Status *>(MPI_STATUSES_IGNORE));
+ MPI_Waitall(send_ops + recv_ops, requests.data(), MPI_STATUSES_IGNORE);
AssertThrowMPI(ierr);
}