|
@@ -265,10 +265,6 @@ int starpu_mpi_shutdown(void)
|
|
|
void *value;
|
|
|
int rank, world_size;
|
|
|
|
|
|
-#ifdef STARPU_USE_MPI_FT
|
|
|
- starpu_mpi_ft_turn_off();
|
|
|
-#endif // STARPU_USE_MPI_FT
|
|
|
-
|
|
|
/* Make sure we do not have MPI communications pending in the task graph
|
|
|
* before shutting down MPI */
|
|
|
starpu_mpi_wait_for_all(MPI_COMM_WORLD);
|
|
@@ -287,6 +283,10 @@ int starpu_mpi_shutdown(void)
|
|
|
}
|
|
|
#endif // STARPU_USE_FXT
|
|
|
|
|
|
+#ifdef STARPU_USE_MPI_FT
|
|
|
+ starpu_mpi_ft_turn_off();
|
|
|
+#endif // STARPU_USE_MPI_FT
|
|
|
+
|
|
|
_starpu_mpi_comm_amounts_display(stderr, rank);
|
|
|
_starpu_mpi_comm_amounts_shutdown();
|
|
|
_starpu_mpi_cache_shutdown(world_size);
|