starpu-max/src/datawizard/datastats.c

/*
 * StarPU
 * Copyright (C) INRIA 2008-2009 (see AUTHORS file)
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation; either version 2.1 of the License, or (at
 * your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 *
 * See the GNU Lesser General Public License in COPYING.LGPL for more details.
 */

#include <stdio.h>
#include <datawizard/datastats.h>
#include <common/config.h>
#include <starpu.h>

/* measure the cache hit ratio for each node */

#ifdef DATA_STATS
static unsigned hit_cnt[16];
static unsigned miss_cnt[16];
#endif

inline void msi_cache_hit(unsigned node __attribute__ ((unused)))
{
#ifdef DATA_STATS
	hit_cnt[node]++;
#endif
}

inline void msi_cache_miss(unsigned node __attribute__ ((unused)))
{
#ifdef DATA_STATS
	miss_cnt[node]++;
#endif
}

void display_msi_stats(void)
{
#ifdef DATA_STATS
	fprintf(stderr, "MSI cache stats :\n");
	unsigned node;
	for (node = 0; node < 4; node++) 
	{
		if (hit_cnt[node]+miss_cnt[node]) 
		{
			fprintf(stderr, "memory node %d\n", node);
			fprintf(stderr, "\thit : %u (%2.2f \%%)\n", hit_cnt[node], (100.0f*hit_cnt[node])/(hit_cnt[node]+miss_cnt[node]));
			fprintf(stderr, "\tmiss : %u (%2.2f \%%)\n", miss_cnt[node], (100.0f*miss_cnt[node])/(hit_cnt[node]+miss_cnt[node]));
		}
	}
#endif
}

/* measure the efficiency of our allocation cache */

#ifdef DATA_STATS
static unsigned alloc_cnt[16];
static unsigned alloc_cache_hit_cnt[16];
#endif

inline void allocation_cache_hit(unsigned node __attribute__ ((unused)))
{
#ifdef DATA_STATS
	alloc_cache_hit_cnt[node]++;
#endif
}

inline void data_allocation_inc_stats(unsigned node __attribute__ ((unused)))
{
#ifdef DATA_STATS
	alloc_cnt[node]++;
#endif
}

void display_alloc_cache_stats(void)
{
#ifdef DATA_STATS
	fprintf(stderr, "Allocation cache stats:\n");
	unsigned node;
	for (node = 0; node < 4; node++) 
	{
		if (alloc_cnt[node]) 
		{
			fprintf(stderr, "memory node %d\n", node);
			fprintf(stderr, "\ttotal alloc : %u\n", alloc_cnt[node]);
			fprintf(stderr, "\tcached alloc: %u (%2.2f \%%)\n", 
				alloc_cache_hit_cnt[node], (100.0f*alloc_cache_hit_cnt[node])/(alloc_cnt[node]));
		}
	}
#endif
}

/* measure the amount of data transfers between each pair of nodes */
#ifdef DATA_STATS

static size_t comm_ammount[8][8];

void display_comm_ammounts(void)
{
	unsigned src, dst;

	for (dst = 0; dst < 8; dst++)
	for (src = 0; src < 8; src++)
	{
		if (comm_ammount[src][dst])
			fprintf(stderr, "Total comm from %d to %d \t%dMB\n", src, dst, ((unsigned)comm_ammount[src][dst])/(1024*1024));
	}
}

inline void update_comm_ammount(uint32_t src_node, uint32_t dst_node, size_t size)
{
	comm_ammount[src_node][dst_node] += size;
}

#else

inline void display_comm_ammounts(void)
{
}

#endif