@@ -784,8 +784,9 @@ int _starpu_mpi_barrier(MPI_Comm comm)
return 0;
}
-int _starpu_mpi_wait_for_all()
+int _starpu_mpi_wait_for_all(MPI_Comm comm)
{
+ (void) comm;
_STARPU_MPI_LOG_IN();
/* First wait for *both* all tasks and MPI requests to finish, in case
@@ -281,8 +281,9 @@ int _starpu_mpi_barrier(MPI_Comm comm)
return ret;
STARPU_PTHREAD_MUTEX_LOCK(&mpi_wait_for_all_running_mutex);
@@ -435,7 +435,7 @@ void starpu_mpi_data_migrate(MPI_Comm comm, starpu_data_handle_t data, int new_r
return;
-int starpu_mpi_wait_for_all(MPI_Comm comm STARPU_ATTRIBUTE_UNUSED)
+int starpu_mpi_wait_for_all(MPI_Comm comm)
- return _starpu_mpi_wait_for_all();
+ return _starpu_mpi_wait_for_all(comm);
@@ -331,7 +331,7 @@ void _starpu_mpi_wait_for_initialization();
void _starpu_mpi_data_flush(starpu_data_handle_t data_handle);
int _starpu_mpi_barrier(MPI_Comm comm);
-int _starpu_mpi_wait_for_all();
+int _starpu_mpi_wait_for_all(MPI_Comm comm);
/*
* Specific functions to backend implementation