|
@@ -130,52 +130,3 @@ void _starpu_display_alloc_cache_stats(void)
|
|
|
}
|
|
|
fprintf(stderr, "#---------------------\n");
|
|
|
}
|
|
|
-
|
|
|
-/* measure the amount of data transfers between each pair of nodes */
|
|
|
-static size_t comm_amount[STARPU_MAXNODES][STARPU_MAXNODES];
|
|
|
-
|
|
|
-void _starpu_comm_amounts_inc(unsigned src STARPU_ATTRIBUTE_UNUSED, unsigned dst STARPU_ATTRIBUTE_UNUSED, size_t size STARPU_ATTRIBUTE_UNUSED)
|
|
|
-{
|
|
|
- if (!starpu_enable_stats())
|
|
|
- return;
|
|
|
-
|
|
|
- STARPU_HG_DISABLE_CHECKING(comm_amount[src][dst]);
|
|
|
- comm_amount[src][dst] += size;
|
|
|
-}
|
|
|
-
|
|
|
-void _starpu_display_comm_amounts(void)
|
|
|
-{
|
|
|
-#ifdef STARPU_DEVEL
|
|
|
-# warning TODO. The information displayed here seems to be similar to the one displayed by starpu_profiling_bus_helper_display_summary()
|
|
|
-#endif
|
|
|
-
|
|
|
- if (!starpu_enable_stats())
|
|
|
- return;
|
|
|
-
|
|
|
- unsigned src, dst;
|
|
|
- size_t sum = 0;
|
|
|
-
|
|
|
- fprintf(stderr, "\n#---------------------\n");
|
|
|
- fprintf(stderr, "Data transfer stats:\n");
|
|
|
-
|
|
|
- for (dst = 0; dst < STARPU_MAXNODES; dst++)
|
|
|
- for (src = 0; src < STARPU_MAXNODES; src++)
|
|
|
- {
|
|
|
- sum += comm_amount[src][dst];
|
|
|
- sum += comm_amount[dst][src];
|
|
|
- }
|
|
|
-
|
|
|
- fprintf(stderr, "TOTAL transfers %f MB\n", (float)sum/1024/1024);
|
|
|
-
|
|
|
- for (dst = 0; dst < STARPU_MAXNODES; dst++)
|
|
|
- for (src = dst + 1; src < STARPU_MAXNODES; src++)
|
|
|
- {
|
|
|
- if (comm_amount[src][dst])
|
|
|
- fprintf(stderr, "\t%d <-> %d\t%f MB\n\t\t%d -> %d\t%f MB\n\t\t%d -> %d\t%f MB\n",
|
|
|
- src, dst, ((float)comm_amount[src][dst] + (float)comm_amount[dst][src])/(1024*1024),
|
|
|
- src, dst, ((float)comm_amount[src][dst])/(1024*1024),
|
|
|
- dst, src, ((float)comm_amount[dst][src])/(1024*1024));
|
|
|
- }
|
|
|
- fprintf(stderr, "#---------------------\n");
|
|
|
-}
|
|
|
-
|