[fio.git] / stat.c

#include <stdio.h>
#include <string.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <dirent.h>
#include <libgen.h>
#include <math.h>

#include "fio.h"

static struct itimerval itimer;
static struct list_head disk_list = LIST_HEAD_INIT(disk_list);

static int get_io_ticks(struct disk_util *du, struct disk_util_stat *dus)
{
	unsigned in_flight;
	char line[256];
	FILE *f;
	char *p;

	f = fopen(du->path, "r");
	if (!f)
		return 1;

	p = fgets(line, sizeof(line), f);
	if (!p) {
		fclose(f);
		return 1;
	}

	if (sscanf(p, "%u %u %llu %u %u %u %llu %u %u %u %u\n", &dus->ios[0], &dus->merges[0], &dus->sectors[0], &dus->ticks[0], &dus->ios[1], &dus->merges[1], &dus->sectors[1], &dus->ticks[1], &in_flight, &dus->io_ticks, &dus->time_in_queue) != 11) {
		fclose(f);
		return 1;
	}

	fclose(f);
	return 0;
}

static void update_io_tick_disk(struct disk_util *du)
{
	struct disk_util_stat __dus, *dus, *ldus;
	struct timeval t;

	if (get_io_ticks(du, &__dus))
		return;

	dus = &du->dus;
	ldus = &du->last_dus;

	dus->sectors[0] += (__dus.sectors[0] - ldus->sectors[0]);
	dus->sectors[1] += (__dus.sectors[1] - ldus->sectors[1]);
	dus->ios[0] += (__dus.ios[0] - ldus->ios[0]);
	dus->ios[1] += (__dus.ios[1] - ldus->ios[1]);
	dus->merges[0] += (__dus.merges[0] - ldus->merges[0]);
	dus->merges[1] += (__dus.merges[1] - ldus->merges[1]);
	dus->ticks[0] += (__dus.ticks[0] - ldus->ticks[0]);
	dus->ticks[1] += (__dus.ticks[1] - ldus->ticks[1]);
	dus->io_ticks += (__dus.io_ticks - ldus->io_ticks);
	dus->time_in_queue += (__dus.time_in_queue - ldus->time_in_queue);

	gettimeofday(&t, NULL);
	du->msec += mtime_since(&du->time, &t);
	memcpy(&du->time, &t, sizeof(t));
	memcpy(ldus, &__dus, sizeof(__dus));
}

void update_io_ticks(void)
{
	struct list_head *entry;
	struct disk_util *du;

	list_for_each(entry, &disk_list) {
		du = list_entry(entry, struct disk_util, list);
		update_io_tick_disk(du);
	}
}

static int disk_util_exists(dev_t dev)
{
	struct list_head *entry;
	struct disk_util *du;

	list_for_each(entry, &disk_list) {
		du = list_entry(entry, struct disk_util, list);

		if (du->dev == dev)
			return 1;
	}

	return 0;
}

static void disk_util_add(dev_t dev, char *path)
{
	struct disk_util *du = malloc(sizeof(*du));

	memset(du, 0, sizeof(*du));
	INIT_LIST_HEAD(&du->list);
	sprintf(du->path, "%s/stat", path);
	du->name = strdup(basename(path));
	du->dev = dev;

	gettimeofday(&du->time, NULL);
	get_io_ticks(du, &du->last_dus);

	list_add_tail(&du->list, &disk_list);
}

static int check_dev_match(dev_t dev, char *path)
{
	unsigned int major, minor;
	char line[256], *p;
	FILE *f;

	f = fopen(path, "r");
	if (!f) {
		perror("open path");
		return 1;
	}

	p = fgets(line, sizeof(line), f);
	if (!p) {
		fclose(f);
		return 1;
	}

	if (sscanf(p, "%u:%u", &major, &minor) != 2) {
		fclose(f);
		return 1;
	}

	if (((major << 8) | minor) == dev) {
		fclose(f);
		return 0;
	}

	fclose(f);
	return 1;
}

static int find_block_dir(dev_t dev, char *path)
{
	struct dirent *dir;
	struct stat st;
	int found = 0;
	DIR *D;

	D = opendir(path);
	if (!D)
		return 0;

	while ((dir = readdir(D)) != NULL) {
		char full_path[256];

		if (!strcmp(dir->d_name, ".") || !strcmp(dir->d_name, ".."))
			continue;

		sprintf(full_path, "%s/%s", path, dir->d_name);

		if (!strcmp(dir->d_name, "dev")) {
			if (!check_dev_match(dev, full_path)) {
				found = 1;
				break;
			}
		}

		if (lstat(full_path, &st) == -1) {
			perror("stat");
			break;
		}

		if (!S_ISDIR(st.st_mode) || S_ISLNK(st.st_mode))
			continue;

		found = find_block_dir(dev, full_path);
		if (found) {
			strcpy(path, full_path);
			break;
		}
	}

	closedir(D);
	return found;
}

void init_disk_util(struct thread_data *td)
{
	struct fio_file *f;
	struct stat st;
	char foo[256], tmp[256];
	dev_t dev;
	char *p;

	if (!td->do_disk_util)
		return;

	/*
	 * Just use the same file, they are on the same device.
	 */
	f = &td->files[0];
	if (!stat(f->file_name, &st)) {
		if (S_ISBLK(st.st_mode))
			dev = st.st_rdev;
		else
			dev = st.st_dev;
	} else {
		/*
		 * must be a file, open "." in that path
		 */
		strcpy(foo, f->file_name);
		p = dirname(foo);
		if (stat(p, &st)) {
			perror("disk util stat");
			return;
		}

		dev = st.st_dev;
	}

	if (disk_util_exists(dev))
		return;
		
	sprintf(foo, "/sys/block");
	if (!find_block_dir(dev, foo))
		return;

	/*
	 * If there's a ../queue/ directory there, we are inside a partition.
	 * Check if that is the case and jump back. For loop/md/dm etc we
	 * are already in the right spot.
	 */
	sprintf(tmp, "%s/../queue", foo);
	if (!stat(tmp, &st)) {
		p = dirname(foo);
		sprintf(tmp, "%s/queue", p);
		if (stat(tmp, &st)) {
			log_err("unknown sysfs layout\n");
			return;
		}
		strcpy(tmp, p);
		sprintf(foo, "%s", tmp);
	}

	td->sysfs_root = strdup(foo);
	disk_util_add(dev, foo);
}

void disk_util_timer_arm(void)
{
	itimer.it_value.tv_sec = 0;
	itimer.it_value.tv_usec = DISK_UTIL_MSEC * 1000;
	setitimer(ITIMER_REAL, &itimer, NULL);
}

void update_rusage_stat(struct thread_data *td)
{
	if (!(td->runtime[0] + td->runtime[1]))
		return;

	getrusage(RUSAGE_SELF, &td->ru_end);

	td->usr_time += mtime_since(&td->ru_start.ru_utime, &td->ru_end.ru_utime);
	td->sys_time += mtime_since(&td->ru_start.ru_stime, &td->ru_end.ru_stime);
	td->ctx += td->ru_end.ru_nvcsw + td->ru_end.ru_nivcsw - (td->ru_start.ru_nvcsw + td->ru_start.ru_nivcsw);

	
	memcpy(&td->ru_start, &td->ru_end, sizeof(td->ru_end));
}

static int calc_lat(struct io_stat *is, unsigned long *min, unsigned long *max,
		    double *mean, double *dev)
{
	double n;

	if (is->samples == 0)
		return 0;

	*min = is->min_val;
	*max = is->max_val;

	n = (double) is->samples;
	*mean = (double) is->val / n;
	*dev = sqrt(((double) is->val_sq - (*mean * *mean) / n) / (n - 1));

	return 1;
}

static void show_group_stats(struct group_run_stats *rs, int id)
{
	fprintf(f_out, "\nRun status group %d (all jobs):\n", id);

	if (rs->max_run[DDIR_READ])
		fprintf(f_out, "   READ: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[0] >> 10, rs->agg[0], rs->min_bw[0], rs->max_bw[0], rs->min_run[0], rs->max_run[0]);
	if (rs->max_run[DDIR_WRITE])
		fprintf(f_out, "  WRITE: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[1] >> 10, rs->agg[1], rs->min_bw[1], rs->max_bw[1], rs->min_run[1], rs->max_run[1]);
}

static void show_disk_util(void)
{
	struct disk_util_stat *dus;
	struct list_head *entry, *next;
	struct disk_util *du;
	double util;

	fprintf(f_out, "\nDisk stats (read/write):\n");

	list_for_each(entry, &disk_list) {
		du = list_entry(entry, struct disk_util, list);
		dus = &du->dus;

		util = (double) 100 * du->dus.io_ticks / (double) du->msec;
		if (util > 100.0)
			util = 100.0;

		fprintf(f_out, "  %s: ios=%u/%u, merge=%u/%u, ticks=%u/%u, in_queue=%u, util=%3.2f%%\n", du->name, dus->ios[0], dus->ios[1], dus->merges[0], dus->merges[1], dus->ticks[0], dus->ticks[1], dus->time_in_queue, util);
	}

	/*
	 * now free the list
	 */
	list_for_each_safe(entry, next, &disk_list) {
		list_del(entry);
		du = list_entry(entry, struct disk_util, list);
		free(du->name);
		free(du);
	}
}

static void show_ddir_status(struct thread_data *td, struct group_run_stats *rs,
			     int ddir)
{
	char *ddir_str[] = { "read ", "write" };
	unsigned long min, max;
	unsigned long long bw;
	double mean, dev;

	if (!td->runtime[ddir])
		return;

	bw = td->io_bytes[ddir] / td->runtime[ddir];
	fprintf(f_out, "  %s: io=%6lluMiB, bw=%6lluKiB/s, runt=%6lumsec\n", ddir_str[ddir], td->io_bytes[ddir] >> 20, bw, td->runtime[ddir]);

	if (calc_lat(&td->slat_stat[ddir], &min, &max, &mean, &dev))
		fprintf(f_out, "    slat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);

	if (calc_lat(&td->clat_stat[ddir], &min, &max, &mean, &dev))
		fprintf(f_out, "    clat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);

	if (calc_lat(&td->bw_stat[ddir], &min, &max, &mean, &dev)) {
		double p_of_agg;

		p_of_agg = mean * 100 / (double) rs->agg[ddir];
		fprintf(f_out, "    bw (KiB/s) : min=%5lu, max=%5lu, per=%3.2f%%, avg=%5.02f, dev=%5.02f\n", min, max, p_of_agg, mean, dev);
	}
}

static void show_thread_status(struct thread_data *td,
			       struct group_run_stats *rs)
{
	double usr_cpu, sys_cpu;

	if (!(td->io_bytes[0] + td->io_bytes[1]) && !td->error)
		return;

	fprintf(f_out, "%s: (groupid=%d): err=%2d:\n",td->name, td->groupid, td->error);

	show_ddir_status(td, rs, td->ddir);
	if (td->io_bytes[td->ddir ^ 1])
		show_ddir_status(td, rs, td->ddir ^ 1);

	if (td->runtime[0] + td->runtime[1]) {
		double runt = td->runtime[0] + td->runtime[1];

		usr_cpu = (double) td->usr_time * 100 / runt;
		sys_cpu = (double) td->sys_time * 100 / runt;
	} else {
		usr_cpu = 0;
		sys_cpu = 0;
	}

	fprintf(f_out, "  cpu          : usr=%3.2f%%, sys=%3.2f%%, ctx=%lu\n", usr_cpu, sys_cpu, td->ctx);
}

static void show_ddir_status_terse(struct thread_data *td,
				   struct group_run_stats *rs, int ddir)
{
	unsigned long min, max;
	unsigned long long bw;
	double mean, dev;

	bw = 0;
	if (td->runtime[ddir])
		bw = td->io_bytes[ddir] / td->runtime[ddir];

	fprintf(f_out, ",%llu,%llu,%lu", td->io_bytes[ddir] >> 10, bw, td->runtime[ddir]);

	if (calc_lat(&td->slat_stat[ddir], &min, &max, &mean, &dev))
		fprintf(f_out, ",%lu,%lu,%f,%f", min, max, mean, dev);
	else
		fprintf(f_out, ",%lu,%lu,%f,%f", 0UL, 0UL, 0.0, 0.0);

	if (calc_lat(&td->clat_stat[ddir], &min, &max, &mean, &dev))
		fprintf(f_out, ",%lu,%lu,%f,%f", min, max, mean, dev);
	else
		fprintf(f_out, ",%lu,%lu,%f,%f", 0UL, 0UL, 0.0, 0.0);

	if (calc_lat(&td->bw_stat[ddir], &min, &max, &mean, &dev)) {
		double p_of_agg;

		p_of_agg = mean * 100 / (double) rs->agg[ddir];
		fprintf(f_out, ",%lu,%lu,%f%%,%f,%f", min, max, p_of_agg, mean, dev);
	} else
		fprintf(f_out, ",%lu,%lu,%f%%,%f,%f", 0UL, 0UL, 0.0, 0.0, 0.0);
		
}


static void show_thread_status_terse(struct thread_data *td,
				     struct group_run_stats *rs)
{
	double usr_cpu, sys_cpu;

	fprintf(f_out, "%s,%d,%d",td->name, td->groupid, td->error);

	show_ddir_status_terse(td, rs, 0);
	show_ddir_status_terse(td, rs, 1);

	if (td->runtime[0] + td->runtime[1]) {
		double runt = td->runtime[0] + td->runtime[1];

		usr_cpu = (double) td->usr_time * 100 / runt;
		sys_cpu = (double) td->sys_time * 100 / runt;
	} else {
		usr_cpu = 0;
		sys_cpu = 0;
	}

	fprintf(f_out, ",%f%%,%f%%,%lu\n", usr_cpu, sys_cpu, td->ctx);
}

void show_run_stats(void)
{
	struct group_run_stats *runstats, *rs;
	struct thread_data *td;
	int i;

	runstats = malloc(sizeof(struct group_run_stats) * (groupid + 1));

	for (i = 0; i < groupid + 1; i++) {
		rs = &runstats[i];

		memset(rs, 0, sizeof(*rs));
		rs->min_bw[0] = rs->min_run[0] = ~0UL;
		rs->min_bw[1] = rs->min_run[1] = ~0UL;
	}

	for_each_td(td, i) {
		unsigned long long rbw, wbw;

		if (td->error) {
			fprintf(f_out, "%s: %s\n", td->name, td->verror);
			continue;
		}

		rs = &runstats[td->groupid];

		if (td->runtime[0] < rs->min_run[0] || !rs->min_run[0])
			rs->min_run[0] = td->runtime[0];
		if (td->runtime[0] > rs->max_run[0])
			rs->max_run[0] = td->runtime[0];
		if (td->runtime[1] < rs->min_run[1] || !rs->min_run[1])
			rs->min_run[1] = td->runtime[1];
		if (td->runtime[1] > rs->max_run[1])
			rs->max_run[1] = td->runtime[1];

		rbw = wbw = 0;
		if (td->runtime[0])
			rbw = td->io_bytes[0] / (unsigned long long) td->runtime[0];
		if (td->runtime[1])
			wbw = td->io_bytes[1] / (unsigned long long) td->runtime[1];

		if (rbw < rs->min_bw[0])
			rs->min_bw[0] = rbw;
		if (wbw < rs->min_bw[1])
			rs->min_bw[1] = wbw;
		if (rbw > rs->max_bw[0])
			rs->max_bw[0] = rbw;
		if (wbw > rs->max_bw[1])
			rs->max_bw[1] = wbw;

		rs->io_kb[0] += td->io_bytes[0] >> 10;
		rs->io_kb[1] += td->io_bytes[1] >> 10;
	}

	for (i = 0; i < groupid + 1; i++) {
		rs = &runstats[i];

		if (rs->max_run[0])
			rs->agg[0] = (rs->io_kb[0]*1024) / rs->max_run[0];
		if (rs->max_run[1])
			rs->agg[1] = (rs->io_kb[1]*1024) / rs->max_run[1];
	}

	/*
	 * don't overwrite last signal output
	 */
	if (!terse_output)
		printf("\n");

	for_each_td(td, i) {
		rs = &runstats[td->groupid];

		if (terse_output)
			show_thread_status_terse(td, rs);
		else
			show_thread_status(td, rs);
	}

	if (!terse_output) {
		for (i = 0; i < groupid + 1; i++)
			show_group_stats(&runstats[i], i);

		show_disk_util();
	}
}

static inline void add_stat_sample(struct io_stat *is, unsigned long val)
{
	if (val > is->max_val)
		is->max_val = val;
	if (val < is->min_val)
		is->min_val = val;

	is->val += val;
	is->val_sq += val * val;
	is->samples++;
}

static void add_log_sample(struct thread_data *td, struct io_log *iolog,
			   unsigned long val, int ddir)
{
	if (iolog->nr_samples == iolog->max_samples) {
		int new_size = sizeof(struct io_sample) * iolog->max_samples*2;

		iolog->log = realloc(iolog->log, new_size);
		iolog->max_samples <<= 1;
	}

	iolog->log[iolog->nr_samples].val = val;
	iolog->log[iolog->nr_samples].time = mtime_since_now(&td->epoch);
	iolog->log[iolog->nr_samples].ddir = ddir;
	iolog->nr_samples++;
}

void add_clat_sample(struct thread_data *td, int ddir, unsigned long msec)
{
	add_stat_sample(&td->clat_stat[ddir], msec);

	if (td->clat_log)
		add_log_sample(td, td->clat_log, msec, ddir);
}

void add_slat_sample(struct thread_data *td, int ddir, unsigned long msec)
{
	add_stat_sample(&td->slat_stat[ddir], msec);

	if (td->slat_log)
		add_log_sample(td, td->slat_log, msec, ddir);
}

void add_bw_sample(struct thread_data *td, int ddir)
{
	unsigned long spent = mtime_since_now(&td->stat_sample_time[ddir]);
	unsigned long rate;

	if (spent < td->bw_avg_time)
		return;

	rate = (td->this_io_bytes[ddir] - td->stat_io_bytes[ddir]) / spent;
	add_stat_sample(&td->bw_stat[ddir], rate);

	if (td->bw_log)
		add_log_sample(td, td->bw_log, rate, ddir);

	gettimeofday(&td->stat_sample_time[ddir], NULL);
	td->stat_io_bytes[ddir] = td->this_io_bytes[ddir];
}
Commit	Line	Data
3c39a379 JA	1	#include <stdio.h>
	2	#include <string.h>
	3	#include <sys/time.h>
	4	#include <sys/types.h>
5c4e1dbc	5	#include <sys/stat.h>
3c39a379 JA	6	#include <dirent.h>
	7	#include <libgen.h>
	8	#include <math.h>
	9
	10	#include "fio.h"
3c39a379 JA	11
3c39a379 JA	12	static struct itimerval itimer;
5c4e1dbc	13	static struct list_head disk_list = LIST_HEAD_INIT(disk_list);
3c39a379 JA	14
	15	static int get_io_ticks(struct disk_util du, struct disk_util_stat dus)
	16	{
	17	unsigned in_flight;
	18	char line[256];
	19	FILE *f;
	20	char *p;
	21
	22	f = fopen(du->path, "r");
	23	if (!f)
	24	return 1;
	25
	26	p = fgets(line, sizeof(line), f);
	27	if (!p) {
	28	fclose(f);
	29	return 1;
	30	}
	31
	32	if (sscanf(p, "%u %u %llu %u %u %u %llu %u %u %u %u\n", &dus->ios[0], &dus->merges[0], &dus->sectors[0], &dus->ticks[0], &dus->ios[1], &dus->merges[1], &dus->sectors[1], &dus->ticks[1], &in_flight, &dus->io_ticks, &dus->time_in_queue) != 11) {
	33	fclose(f);
	34	return 1;
	35	}
	36
	37	fclose(f);
	38	return 0;
	39	}
	40
	41	static void update_io_tick_disk(struct disk_util *du)
	42	{
	43	struct disk_util_stat __dus, dus, ldus;
	44	struct timeval t;
	45
	46	if (get_io_ticks(du, &__dus))
	47	return;
	48
	49	dus = &du->dus;
	50	ldus = &du->last_dus;
	51
	52	dus->sectors[0] += (__dus.sectors[0] - ldus->sectors[0]);
	53	dus->sectors[1] += (__dus.sectors[1] - ldus->sectors[1]);
	54	dus->ios[0] += (__dus.ios[0] - ldus->ios[0]);
	55	dus->ios[1] += (__dus.ios[1] - ldus->ios[1]);
	56	dus->merges[0] += (__dus.merges[0] - ldus->merges[0]);
	57	dus->merges[1] += (__dus.merges[1] - ldus->merges[1]);
	58	dus->ticks[0] += (__dus.ticks[0] - ldus->ticks[0]);
	59	dus->ticks[1] += (__dus.ticks[1] - ldus->ticks[1]);
	60	dus->io_ticks += (__dus.io_ticks - ldus->io_ticks);
	61	dus->time_in_queue += (__dus.time_in_queue - ldus->time_in_queue);
	62
	63	gettimeofday(&t, NULL);
	64	du->msec += mtime_since(&du->time, &t);
	65	memcpy(&du->time, &t, sizeof(t));
	66	memcpy(ldus, &__dus, sizeof(__dus));
	67	}
	68
	69	void update_io_ticks(void)
	70	{
	71	struct list_head *entry;
	72	struct disk_util *du;
	73
	74	list_for_each(entry, &disk_list) {
	75	du = list_entry(entry, struct disk_util, list);
	76	update_io_tick_disk(du);
	77	}
78	}
79
80	static int disk_util_exists(dev_t dev)
81	{
82	struct list_head *entry;
83	struct disk_util *du;
84
85	list_for_each(entry, &disk_list) {
86	du = list_entry(entry, struct disk_util, list);
87
88	if (du->dev == dev)
89	return 1;
90	}
91
92	return 0;
93	}
94
95	static void disk_util_add(dev_t dev, char *path)
96	{
97	struct disk_util du = malloc(sizeof(du));
98
99	memset(du, 0, sizeof(*du));
100	INIT_LIST_HEAD(&du->list);
101	sprintf(du->path, "%s/stat", path);
102	du->name = strdup(basename(path));
103	du->dev = dev;
104
105	gettimeofday(&du->time, NULL);
106	get_io_ticks(du, &du->last_dus);
107
108	list_add_tail(&du->list, &disk_list);
109	}
110
111	static int check_dev_match(dev_t dev, char *path)
112	{
113	unsigned int major, minor;
114	char line[256], *p;
115	FILE *f;
116
117	f = fopen(path, "r");
118	if (!f) {
119	perror("open path");
120	return 1;
121	}
122
123	p = fgets(line, sizeof(line), f);
124	if (!p) {
125	fclose(f);
126	return 1;
127	}
128
129	if (sscanf(p, "%u:%u", &major, &minor) != 2) {
130	fclose(f);
131	return 1;
132	}
133
134	if (((major << 8) \| minor) == dev) {
135	fclose(f);
136	return 0;
137	}
138
139	fclose(f);
140	return 1;
141	}
142
143	static int find_block_dir(dev_t dev, char *path)
144	{
145	struct dirent *dir;
146	struct stat st;
147	int found = 0;
148	DIR *D;
149
150	D = opendir(path);
151	if (!D)
152	return 0;
153
154	while ((dir = readdir(D)) != NULL) {
155	char full_path[256];
156
157	if (!strcmp(dir->d_name, ".") \|\| !strcmp(dir->d_name, ".."))
158	continue;
3c39a379 JA	159
	160	sprintf(full_path, "%s/%s", path, dir->d_name);
	161
	162	if (!strcmp(dir->d_name, "dev")) {
	163	if (!check_dev_match(dev, full_path)) {
	164	found = 1;
	165	break;
	166	}
	167	}
	168
3307d653	169	if (lstat(full_path, &st) == -1) {
3c39a379 JA	170	perror("stat");
	171	break;
	172	}
	173
	174	if (!S_ISDIR(st.st_mode) \|\| S_ISLNK(st.st_mode))
	175	continue;
	176
	177	found = find_block_dir(dev, full_path);
	178	if (found) {
	179	strcpy(path, full_path);
	180	break;
	181	}
	182	}
	183
	184	closedir(D);
	185	return found;
	186	}
	187
	188	void init_disk_util(struct thread_data *td)
	189	{
53cdc686	190	struct fio_file *f;
3c39a379 JA	191	struct stat st;
	192	char foo[256], tmp[256];
	193	dev_t dev;
	194	char *p;
	195
	196	if (!td->do_disk_util)
	197	return;
	198
53cdc686 JA	199	/*
	200	* Just use the same file, they are on the same device.
	201	*/
	202	f = &td->files[0];
	203	if (!stat(f->file_name, &st)) {
3c39a379 JA	204	if (S_ISBLK(st.st_mode))
	205	dev = st.st_rdev;
	206	else
	207	dev = st.st_dev;
	208	} else {
	209	/*
	210	* must be a file, open "." in that path
	211	*/
53cdc686	212	strcpy(foo, f->file_name);
3c39a379 JA	213	p = dirname(foo);
	214	if (stat(p, &st)) {
	215	perror("disk util stat");
	216	return;
	217	}
	218
	219	dev = st.st_dev;
	220	}
	221
	222	if (disk_util_exists(dev))
	223	return;
	224
	225	sprintf(foo, "/sys/block");
	226	if (!find_block_dir(dev, foo))
	227	return;
	228
	229	/*
	230	* If there's a ../queue/ directory there, we are inside a partition.
	231	* Check if that is the case and jump back. For loop/md/dm etc we
	232	* are already in the right spot.
	233	*/
	234	sprintf(tmp, "%s/../queue", foo);
	235	if (!stat(tmp, &st)) {
	236	p = dirname(foo);
	237	sprintf(tmp, "%s/queue", p);
	238	if (stat(tmp, &st)) {
3b70d7e5	239	log_err("unknown sysfs layout\n");
3c39a379 JA	240	return;
3c39a379 JA	241	}
84585003 JA	242	strcpy(tmp, p);
84585003 JA	243	sprintf(foo, "%s", tmp);
3c39a379 JA	244	}
	245
	246	td->sysfs_root = strdup(foo);
	247	disk_util_add(dev, foo);
	248	}
	249
	250	void disk_util_timer_arm(void)
	251	{
	252	itimer.it_value.tv_sec = 0;
	253	itimer.it_value.tv_usec = DISK_UTIL_MSEC * 1000;
	254	setitimer(ITIMER_REAL, &itimer, NULL);
	255	}
	256
	257	void update_rusage_stat(struct thread_data *td)
	258	{
	259	if (!(td->runtime[0] + td->runtime[1]))
	260	return;
	261
	262	getrusage(RUSAGE_SELF, &td->ru_end);
	263
	264	td->usr_time += mtime_since(&td->ru_start.ru_utime, &td->ru_end.ru_utime);
	265	td->sys_time += mtime_since(&td->ru_start.ru_stime, &td->ru_end.ru_stime);
	266	td->ctx += td->ru_end.ru_nvcsw + td->ru_end.ru_nivcsw - (td->ru_start.ru_nvcsw + td->ru_start.ru_nivcsw);
	267
	268
	269	memcpy(&td->ru_start, &td->ru_end, sizeof(td->ru_end));
	270	}
	271
	272	static int calc_lat(struct io_stat is, unsigned long min, unsigned long *max,
	273	double mean, double dev)
	274	{
	275	double n;
	276
	277	if (is->samples == 0)
	278	return 0;
	279
	280	*min = is->min_val;
	281	*max = is->max_val;
	282
	283	n = (double) is->samples;
	284	*mean = (double) is->val / n;
	285	dev = sqrt(((double) is->val_sq - (mean * *mean) / n) / (n - 1));
3c39a379 JA	286
	287	return 1;
	288	}
	289
	290	static void show_group_stats(struct group_run_stats *rs, int id)
	291	{
eb8bbf48	292	fprintf(f_out, "\nRun status group %d (all jobs):\n", id);
3c39a379 JA	293
3c39a379 JA	294	if (rs->max_run[DDIR_READ])
eb8bbf48	295	fprintf(f_out, " READ: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[0] >> 10, rs->agg[0], rs->min_bw[0], rs->max_bw[0], rs->min_run[0], rs->max_run[0]);
3c39a379	296	if (rs->max_run[DDIR_WRITE])
eb8bbf48	297	fprintf(f_out, " WRITE: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[1] >> 10, rs->agg[1], rs->min_bw[1], rs->max_bw[1], rs->min_run[1], rs->max_run[1]);
3c39a379 JA	298	}
	299
	300	static void show_disk_util(void)
	301	{
	302	struct disk_util_stat *dus;
b4a6a59a	303	struct list_head entry, next;
3c39a379 JA	304	struct disk_util *du;
	305	double util;
	306
eb8bbf48	307	fprintf(f_out, "\nDisk stats (read/write):\n");
3c39a379 JA	308
	309	list_for_each(entry, &disk_list) {
	310	du = list_entry(entry, struct disk_util, list);
	311	dus = &du->dus;
	312
	313	util = (double) 100 * du->dus.io_ticks / (double) du->msec;
	314	if (util > 100.0)
	315	util = 100.0;
	316
eb8bbf48	317	fprintf(f_out, " %s: ios=%u/%u, merge=%u/%u, ticks=%u/%u, in_queue=%u, util=%3.2f%%\n", du->name, dus->ios[0], dus->ios[1], dus->merges[0], dus->merges[1], dus->ticks[0], dus->ticks[1], dus->time_in_queue, util);
3c39a379	318	}
b4a6a59a JA	319
	320	/*
	321	* now free the list
	322	*/
	323	list_for_each_safe(entry, next, &disk_list) {
	324	list_del(entry);
	325	du = list_entry(entry, struct disk_util, list);
	326	free(du->name);
	327	free(du);
	328	}
3c39a379 JA	329	}
	330
	331	static void show_ddir_status(struct thread_data td, struct group_run_stats rs,
	332	int ddir)
	333	{
	334	char *ddir_str[] = { "read ", "write" };
	335	unsigned long min, max;
	336	unsigned long long bw;
	337	double mean, dev;
	338
	339	if (!td->runtime[ddir])
	340	return;
	341
	342	bw = td->io_bytes[ddir] / td->runtime[ddir];
eb8bbf48	343	fprintf(f_out, " %s: io=%6lluMiB, bw=%6lluKiB/s, runt=%6lumsec\n", ddir_str[ddir], td->io_bytes[ddir] >> 20, bw, td->runtime[ddir]);
3c39a379 JA	344
3c39a379 JA	345	if (calc_lat(&td->slat_stat[ddir], &min, &max, &mean, &dev))
eb8bbf48	346	fprintf(f_out, " slat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
3c39a379 JA	347
3c39a379 JA	348	if (calc_lat(&td->clat_stat[ddir], &min, &max, &mean, &dev))
eb8bbf48	349	fprintf(f_out, " clat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
3c39a379 JA	350
	351	if (calc_lat(&td->bw_stat[ddir], &min, &max, &mean, &dev)) {
	352	double p_of_agg;
	353
	354	p_of_agg = mean * 100 / (double) rs->agg[ddir];
eb8bbf48	355	fprintf(f_out, " bw (KiB/s) : min=%5lu, max=%5lu, per=%3.2f%%, avg=%5.02f, dev=%5.02f\n", min, max, p_of_agg, mean, dev);
3c39a379 JA	356	}
	357	}
	358
	359	static void show_thread_status(struct thread_data *td,
	360	struct group_run_stats *rs)
	361	{
	362	double usr_cpu, sys_cpu;
	363
	364	if (!(td->io_bytes[0] + td->io_bytes[1]) && !td->error)
	365	return;
	366
eb8bbf48	367	fprintf(f_out, "%s: (groupid=%d): err=%2d:\n",td->name, td->groupid, td->error);
3c39a379 JA	368
	369	show_ddir_status(td, rs, td->ddir);
	370	if (td->io_bytes[td->ddir ^ 1])
	371	show_ddir_status(td, rs, td->ddir ^ 1);
	372
	373	if (td->runtime[0] + td->runtime[1]) {
	374	double runt = td->runtime[0] + td->runtime[1];
	375
	376	usr_cpu = (double) td->usr_time * 100 / runt;
	377	sys_cpu = (double) td->sys_time * 100 / runt;
	378	} else {
	379	usr_cpu = 0;
	380	sys_cpu = 0;
	381	}
	382
eb8bbf48	383	fprintf(f_out, " cpu : usr=%3.2f%%, sys=%3.2f%%, ctx=%lu\n", usr_cpu, sys_cpu, td->ctx);
3c39a379 JA	384	}
3c39a379 JA	385
c6ae0a5b JA	386	static void show_ddir_status_terse(struct thread_data *td,
	387	struct group_run_stats *rs, int ddir)
	388	{
	389	unsigned long min, max;
	390	unsigned long long bw;
	391	double mean, dev;
	392
	393	bw = 0;
	394	if (td->runtime[ddir])
	395	bw = td->io_bytes[ddir] / td->runtime[ddir];
	396
	397	fprintf(f_out, ",%llu,%llu,%lu", td->io_bytes[ddir] >> 10, bw, td->runtime[ddir]);
	398
	399	if (calc_lat(&td->slat_stat[ddir], &min, &max, &mean, &dev))
	400	fprintf(f_out, ",%lu,%lu,%f,%f", min, max, mean, dev);
	401	else
	402	fprintf(f_out, ",%lu,%lu,%f,%f", 0UL, 0UL, 0.0, 0.0);
	403
	404	if (calc_lat(&td->clat_stat[ddir], &min, &max, &mean, &dev))
	405	fprintf(f_out, ",%lu,%lu,%f,%f", min, max, mean, dev);
	406	else
	407	fprintf(f_out, ",%lu,%lu,%f,%f", 0UL, 0UL, 0.0, 0.0);
	408
	409	if (calc_lat(&td->bw_stat[ddir], &min, &max, &mean, &dev)) {
	410	double p_of_agg;
	411
	412	p_of_agg = mean * 100 / (double) rs->agg[ddir];
	413	fprintf(f_out, ",%lu,%lu,%f%%,%f,%f", min, max, p_of_agg, mean, dev);
	414	} else
	415	fprintf(f_out, ",%lu,%lu,%f%%,%f,%f", 0UL, 0UL, 0.0, 0.0, 0.0);
	416
	417	}
	418
	419
	420	static void show_thread_status_terse(struct thread_data *td,
	421	struct group_run_stats *rs)
	422	{
	423	double usr_cpu, sys_cpu;
	424
	425	fprintf(f_out, "%s,%d,%d",td->name, td->groupid, td->error);
	426
	427	show_ddir_status_terse(td, rs, 0);
	428	show_ddir_status_terse(td, rs, 1);
	429
	430	if (td->runtime[0] + td->runtime[1]) {
	431	double runt = td->runtime[0] + td->runtime[1];
	432
	433	usr_cpu = (double) td->usr_time * 100 / runt;
	434	sys_cpu = (double) td->sys_time * 100 / runt;
	435	} else {
	436	usr_cpu = 0;
	437	sys_cpu = 0;
	438	}
	439
	440	fprintf(f_out, ",%f%%,%f%%,%lu\n", usr_cpu, sys_cpu, td->ctx);
	441	}
	442
3c39a379 JA	443	void show_run_stats(void)
	444	{
	445	struct group_run_stats runstats, rs;
	446	struct thread_data *td;
	447	int i;
	448
	449	runstats = malloc(sizeof(struct group_run_stats) * (groupid + 1));
	450
	451	for (i = 0; i < groupid + 1; i++) {
	452	rs = &runstats[i];
	453
	454	memset(rs, 0, sizeof(*rs));
	455	rs->min_bw[0] = rs->min_run[0] = ~0UL;
	456	rs->min_bw[1] = rs->min_run[1] = ~0UL;
	457	}
	458
34572e28	459	for_each_td(td, i) {
3c39a379 JA	460	unsigned long long rbw, wbw;
3c39a379 JA	461
3c39a379	462	if (td->error) {
eb8bbf48	463	fprintf(f_out, "%s: %s\n", td->name, td->verror);
3c39a379 JA	464	continue;
	465	}
	466
	467	rs = &runstats[td->groupid];
	468
	469	if (td->runtime[0] < rs->min_run[0] \|\| !rs->min_run[0])
	470	rs->min_run[0] = td->runtime[0];
	471	if (td->runtime[0] > rs->max_run[0])
	472	rs->max_run[0] = td->runtime[0];
	473	if (td->runtime[1] < rs->min_run[1] \|\| !rs->min_run[1])
	474	rs->min_run[1] = td->runtime[1];
	475	if (td->runtime[1] > rs->max_run[1])
	476	rs->max_run[1] = td->runtime[1];
	477
	478	rbw = wbw = 0;
	479	if (td->runtime[0])
	480	rbw = td->io_bytes[0] / (unsigned long long) td->runtime[0];
	481	if (td->runtime[1])
	482	wbw = td->io_bytes[1] / (unsigned long long) td->runtime[1];
	483
	484	if (rbw < rs->min_bw[0])
	485	rs->min_bw[0] = rbw;
	486	if (wbw < rs->min_bw[1])
	487	rs->min_bw[1] = wbw;
	488	if (rbw > rs->max_bw[0])
	489	rs->max_bw[0] = rbw;
	490	if (wbw > rs->max_bw[1])
	491	rs->max_bw[1] = wbw;
	492
	493	rs->io_kb[0] += td->io_bytes[0] >> 10;
	494	rs->io_kb[1] += td->io_bytes[1] >> 10;
	495	}
	496
	497	for (i = 0; i < groupid + 1; i++) {
	498	rs = &runstats[i];
	499
	500	if (rs->max_run[0])
	501	rs->agg[0] = (rs->io_kb[0]*1024) / rs->max_run[0];
	502	if (rs->max_run[1])
	503	rs->agg[1] = (rs->io_kb[1]*1024) / rs->max_run[1];
	504	}
	505
	506	/*
	507	* don't overwrite last signal output
	508	*/
c6ae0a5b JA	509	if (!terse_output)
c6ae0a5b JA	510	printf("\n");
3c39a379	511
34572e28	512	for_each_td(td, i) {
3c39a379 JA	513	rs = &runstats[td->groupid];
3c39a379 JA	514
c6ae0a5b JA	515	if (terse_output)
	516	show_thread_status_terse(td, rs);
	517	else
	518	show_thread_status(td, rs);
3c39a379 JA	519	}
3c39a379 JA	520
c6ae0a5b JA	521	if (!terse_output) {
	522	for (i = 0; i < groupid + 1; i++)
	523	show_group_stats(&runstats[i], i);
3c39a379	524
c6ae0a5b JA	525	show_disk_util();
c6ae0a5b JA	526	}
3c39a379 JA	527	}
	528
	529	static inline void add_stat_sample(struct io_stat *is, unsigned long val)
	530	{
	531	if (val > is->max_val)
	532	is->max_val = val;
	533	if (val < is->min_val)
	534	is->min_val = val;
	535
	536	is->val += val;
	537	is->val_sq += val * val;
	538	is->samples++;
	539	}
	540
	541	static void add_log_sample(struct thread_data td, struct io_log iolog,
	542	unsigned long val, int ddir)
	543	{
	544	if (iolog->nr_samples == iolog->max_samples) {
	545	int new_size = sizeof(struct io_sample) * iolog->max_samples*2;
	546
	547	iolog->log = realloc(iolog->log, new_size);
	548	iolog->max_samples <<= 1;
	549	}
	550
	551	iolog->log[iolog->nr_samples].val = val;
	552	iolog->log[iolog->nr_samples].time = mtime_since_now(&td->epoch);
	553	iolog->log[iolog->nr_samples].ddir = ddir;
	554	iolog->nr_samples++;
	555	}
	556
	557	void add_clat_sample(struct thread_data *td, int ddir, unsigned long msec)
	558	{
	559	add_stat_sample(&td->clat_stat[ddir], msec);
	560
	561	if (td->clat_log)
	562	add_log_sample(td, td->clat_log, msec, ddir);
	563	}
	564
	565	void add_slat_sample(struct thread_data *td, int ddir, unsigned long msec)
	566	{
	567	add_stat_sample(&td->slat_stat[ddir], msec);
	568
	569	if (td->slat_log)
	570	add_log_sample(td, td->slat_log, msec, ddir);
	571	}
	572
	573	void add_bw_sample(struct thread_data *td, int ddir)
	574	{
	575	unsigned long spent = mtime_since_now(&td->stat_sample_time[ddir]);
	576	unsigned long rate;
	577
	578	if (spent < td->bw_avg_time)
	579	return;
	580
	581	rate = (td->this_io_bytes[ddir] - td->stat_io_bytes[ddir]) / spent;
	582	add_stat_sample(&td->bw_stat[ddir], rate);
	583
	584	if (td->bw_log)
	585	add_log_sample(td, td->bw_log, rate, ddir);
	586
	587	gettimeofday(&td->stat_sample_time[ddir], NULL);
	588	td->stat_io_bytes[ddir] = td->this_io_bytes[ddir];
	589	}
	590
591