|
@@ -19,9 +19,6 @@
|
|
|
#include <stdio.h>
|
|
|
#include <starpu_mpi_private.h>
|
|
|
|
|
|
-/* measure the amount of data transfers between each pair of MPI nodes */
|
|
|
-static size_t *comm_cache_amount;
|
|
|
-static int world_size;
|
|
|
static int stats_enabled=0;
|
|
|
|
|
|
void _starpu_mpi_cache_stats_init(MPI_Comm comm)
|
|
@@ -35,16 +32,11 @@ void _starpu_mpi_cache_stats_init(MPI_Comm comm)
|
|
|
|
|
|
_STARPU_DISP("Warning: StarPU is executed with STARPU_MPI_CACHE_STATS=1, which slows down a bit\n");
|
|
|
|
|
|
- starpu_mpi_comm_size(comm, &world_size);
|
|
|
- _STARPU_MPI_DEBUG(1, "allocating for %d nodes\n", world_size);
|
|
|
-
|
|
|
- _STARPU_MPI_CALLOC(comm_cache_amount, world_size, sizeof(size_t));
|
|
|
}
|
|
|
|
|
|
void _starpu_mpi_cache_stats_shutdown()
|
|
|
{
|
|
|
if (stats_enabled == 0) return;
|
|
|
- free(comm_cache_amount);
|
|
|
}
|
|
|
|
|
|
void _starpu_mpi_cache_stats_update(unsigned dst, starpu_data_handle_t data_handle, int count)
|
|
@@ -63,7 +55,5 @@ void _starpu_mpi_cache_stats_update(unsigned dst, starpu_data_handle_t data_hand
|
|
|
{
|
|
|
_STARPU_MPI_MSG("[communication cache] - %10ld from %d\n", (long)size, dst);
|
|
|
}
|
|
|
-
|
|
|
- comm_cache_amount[dst] += count * size;
|
|
|
}
|
|
|
|