[blktrace.git] / btt / devs.c

/*
 * blktrace output analysis: generate a timeline & gather statistics
 *
 * Copyright (C) 2006 Alan D. Brunelle <Alan.Brunelle@hp.com>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 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 General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 */
#include <stdio.h>
#include "globals.h"

#define N_DEV_HASH	128
#define DEV_HASH(dev)	((MAJOR(dev) ^ MINOR(dev)) & (N_DEV_HASH - 1))
struct list_head	dev_heads[N_DEV_HASH];

static inline void *dip_rb_mkhds(void)
{
	size_t len = N_IOP_TYPES * sizeof(struct rb_root);
	return memset(malloc(len), 0, len);
}

static void __destroy(struct rb_node *n)
{
	if (n) {
		struct io *iop = rb_entry(n, struct io, rb_node);

		__destroy(n->rb_left);
		__destroy(n->rb_right);
		io_release(iop);
	}
}

static void __destroy_heads(struct rb_root *roots)
{
	int i;

	for (i = 0; i < N_IOP_TYPES; i++)
		__destroy(roots[i].rb_node);

	free(roots);
}

void init_dev_heads(void)
{
	int i;
	for (i = 0; i < N_DEV_HASH; i++)
		INIT_LIST_HEAD(&dev_heads[i]);
}

struct d_info *__dip_find(__u32 device)
{
	struct d_info *dip;
	struct list_head *p;

	__list_for_each(p, &dev_heads[DEV_HASH(device)]) {
		dip = list_entry(p, struct d_info, hash_head);
		if (device == dip->device)
			return dip;
	}

	return NULL;
}

void dip_exit(void)
{
	struct d_info *dip;
	struct list_head *p, *q;

	list_for_each_safe(p, q, &all_devs) {
		dip = list_entry(p, struct d_info, all_head);

		__destroy_heads(dip->heads);
		region_exit(&dip->regions);
		seeki_exit(dip->seek_handle);
		seeki_exit(dip->q2q_handle);
		aqd_exit(dip->aqd_handle);
		plat_exit(dip->q2d_plat_handle);
		plat_exit(dip->q2c_plat_handle);
		plat_exit(dip->d2c_plat_handle);
		bno_dump_exit(dip->bno_dump_handle);
		unplug_hist_exit(dip->unplug_hist_handle);
		if (output_all_data)
			q2d_release(dip->q2d_priv);
		if (dip->pit_fp)
			fclose(dip->pit_fp);
		free(dip);
	}
}

static inline char *mkhandle(char *str, __u32 device, char *post)
{
	int mjr = device >> MINORBITS;
	int mnr = device & ((1 << MINORBITS) - 1);

	sprintf(str, "%03d,%03d%s", mjr, mnr, post);
	return str;
}

static inline FILE *open_pit(char *str)
{
	FILE *fp = fopen(str, "w");

	if (fp == NULL)
		perror(str);

	return fp;
}

struct d_info *dip_add(__u32 device, struct io *iop)
{
	struct d_info *dip = __dip_find(device);

	if (dip == NULL) {
		char str[256];

		dip = malloc(sizeof(struct d_info));
		memset(dip, 0, sizeof(*dip));
		dip->heads = dip_rb_mkhds();
		region_init(&dip->regions);
		dip->device = device;
		dip->last_q = (__u64)-1;
		dip->map = dev_map_find(device);
		dip->bno_dump_handle = bno_dump_init(device);
		dip->unplug_hist_handle = unplug_hist_init(device);
		dip->seek_handle = seeki_init(mkhandle(str, device, "_d2d"));
		dip->q2q_handle = seeki_init(mkhandle(str, device, "_q2q"));
		dip->aqd_handle = aqd_init(mkhandle(str, device, "_aqd"));
		dip->q2d_plat_handle =
				plat_init(mkhandle(str, device, "_q2d_plat"));
		dip->q2c_plat_handle =
				plat_init(mkhandle(str, device, "_q2c_plat"));
		dip->d2c_plat_handle =
				plat_init(mkhandle(str, device, "_d2c_plat"));
		latency_init(dip);
		list_add_tail(&dip->hash_head, &dev_heads[DEV_HASH(device)]);
		list_add_tail(&dip->all_head, &all_devs);
		dip->start_time = BIT_TIME(iop->t.time);
		dip->pre_culling = 1;
		if (output_all_data)
			dip->q2d_priv = q2d_init();
		n_devs++;
		if (per_io_trees)
			dip->pit_fp = open_pit(mkhandle(per_io_trees,
							  device, "_pit.dat"));
	}

	if (dip->pre_culling) {
		if (iop->type == IOP_Q || iop->type == IOP_A)
			dip->pre_culling = 0;
		else
			return NULL;
	}

	iop->linked = dip_rb_ins(dip, iop);
	dip->end_time = BIT_TIME(iop->t.time);

	return dip;
}

void dip_rem(struct io *iop)
{
	if (iop->linked) {
		dip_rb_rem(iop);
		iop->linked = 0;
	}
}

void dip_foreach(struct io *iop, enum iop_type type,
		 void (*fnc)(struct io *iop, struct io *this), int rm_after)
{
	if (rm_after) {
		LIST_HEAD(head);
		struct io *this;
		struct list_head *p, *q;

		dip_rb_fe(iop->dip, type, iop, fnc, &head);
		list_for_each_safe(p, q, &head) {
			this = list_entry(p, struct io, f_head);
			list_del(&this->f_head);
			io_release(this);
		}
	}
	else
		dip_rb_fe(iop->dip, type, iop, fnc, NULL);
}

void dip_foreach_list(struct io *iop, enum iop_type type, struct list_head *hd)
{
	dip_rb_fe(iop->dip, type, iop, NULL, hd);
}

struct io *dip_find_sec(struct d_info *dip, enum iop_type type, __u64 sec)
{
	return dip_rb_find_sec(dip, type, sec);
}

void dip_foreach_out(void (*func)(struct d_info *, void *), void *arg)
{
	if (devices == NULL) {
		struct list_head *p;
		__list_for_each(p, &all_devs)
			func(list_entry(p, struct d_info, all_head), arg);
	}
	else {
		int i;
		struct d_info *dip;
		unsigned int mjr, mnr;
		char *p = devices;

		while (p && ((i = sscanf(p, "%u,%u", &mjr, &mnr)) == 2)) {
			dip = __dip_find((__u32)((mjr << MINORBITS) | mnr));
			func(dip, arg);
			p = strchr(p, ';');
			if (p) p++;
		}
	}
}

void dip_plug(__u32 dev, double cur_time)
{
	struct d_info *dip = __dip_find(dev);

	if (!dip || dip->is_plugged) return;

	dip->is_plugged = 1;
	dip->last_plug = cur_time;
}

void dip_unplug(__u32 dev, double cur_time, __u64 nios_up)
{
	struct d_info *dip = __dip_find(dev);

	if (dip && dip->is_plugged) {
		dip->nplugs++;
		dip->plugged_time += (cur_time - dip->last_plug);
		dip->is_plugged = 0;
		dip->nios_up += nios_up;
	}
}

void dip_unplug_tm(__u32 dev, __u64 nios_up)
{
	struct d_info *dip = __dip_find(dev);

	if (dip && dip->is_plugged) {
		dip->n_timer_unplugs++;
		dip->nios_upt += nios_up;
		dip->nplugs_t++;
	}
}
Commit	Line	Data
63eba147 JA	1	/*
	2	* blktrace output analysis: generate a timeline & gather statistics
	3	*
	4	* Copyright (C) 2006 Alan D. Brunelle <Alan.Brunelle@hp.com>
	5	*
	6	* This program is free software; you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License as published by
	8	* the Free Software Foundation; either version 2 of the License, or
	9	* (at your option) any later version.
	10	*
	11	* This program is distributed in the hope that it will be useful,
	12	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	14	* GNU General Public License for more details.
	15	*
	16	* You should have received a copy of the GNU General Public License
	17	* along with this program; if not, write to the Free Software
	18	* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	19	*
	20	*/
	21	#include <stdio.h>
63eba147 JA	22	#include "globals.h"
	23
	24	#define N_DEV_HASH 128
	25	#define DEV_HASH(dev) ((MAJOR(dev) ^ MINOR(dev)) & (N_DEV_HASH - 1))
6eb42155	26	struct list_head dev_heads[N_DEV_HASH];
63eba147	27
69040794 AB	28	static inline void *dip_rb_mkhds(void)
	29	{
	30	size_t len = N_IOP_TYPES * sizeof(struct rb_root);
	31	return memset(malloc(len), 0, len);
	32	}
	33
	34	static void __destroy(struct rb_node *n)
	35	{
	36	if (n) {
	37	struct io *iop = rb_entry(n, struct io, rb_node);
	38
	39	__destroy(n->rb_left);
	40	__destroy(n->rb_right);
	41	io_release(iop);
	42	}
	43	}
	44
	45	static void __destroy_heads(struct rb_root *roots)
	46	{
	47	int i;
	48
	49	for (i = 0; i < N_IOP_TYPES; i++)
	50	__destroy(roots[i].rb_node);
	51
	52	free(roots);
	53	}
	54
6eb42155	55	void init_dev_heads(void)
63eba147 JA	56	{
63eba147 JA	57	int i;
63eba147 JA	58	for (i = 0; i < N_DEV_HASH; i++)
	59	INIT_LIST_HEAD(&dev_heads[i]);
	60	}
	61
	62	struct d_info *__dip_find(__u32 device)
	63	{
63eba147	64	struct d_info *dip;
d76c5b81	65	struct list_head *p;
63eba147	66
63eba147 JA	67	__list_for_each(p, &dev_heads[DEV_HASH(device)]) {
	68	dip = list_entry(p, struct d_info, hash_head);
	69	if (device == dip->device)
	70	return dip;
	71	}
	72
	73	return NULL;
	74	}
	75
69040794 AB	76	void dip_exit(void)
	77	{
	78	struct d_info *dip;
	79	struct list_head p, q;
	80
	81	list_for_each_safe(p, q, &all_devs) {
	82	dip = list_entry(p, struct d_info, all_head);
	83
	84	__destroy_heads(dip->heads);
	85	region_exit(&dip->regions);
	86	seeki_exit(dip->seek_handle);
4c48f14e	87	seeki_exit(dip->q2q_handle);
2baef508	88	aqd_exit(dip->aqd_handle);
e47ada10	89	plat_exit(dip->q2d_plat_handle);
2baef508 AB	90	plat_exit(dip->q2c_plat_handle);
2baef508 AB	91	plat_exit(dip->d2c_plat_handle);
69040794	92	bno_dump_exit(dip->bno_dump_handle);
fc16a815	93	unplug_hist_exit(dip->unplug_hist_handle);
951ea56c AB	94	if (output_all_data)
951ea56c AB	95	q2d_release(dip->q2d_priv);
a22df989 AB	96	if (dip->pit_fp)
a22df989 AB	97	fclose(dip->pit_fp);
69040794 AB	98	free(dip);
	99	}
	100	}
	101
4c48f14e AB	102	static inline char mkhandle(char str, __u32 device, char *post)
	103	{
	104	int mjr = device >> MINORBITS;
	105	int mnr = device & ((1 << MINORBITS) - 1);
	106
	107	sprintf(str, "%03d,%03d%s", mjr, mnr, post);
	108	return str;
	109	}
	110
a22df989 AB	111	static inline FILE open_pit(char str)
	112	{
	113	FILE *fp = fopen(str, "w");
	114
	115	if (fp == NULL)
	116	perror(str);
	117
	118	return fp;
	119	}
	120
095181f2	121	struct d_info dip_add(__u32 device, struct io iop)
63eba147 JA	122	{
	123	struct d_info *dip = __dip_find(device);
	124
	125	if (dip == NULL) {
4c48f14e AB	126	char str[256];
4c48f14e AB	127
6eb42155	128	dip = malloc(sizeof(struct d_info));
2fa934ce	129	memset(dip, 0, sizeof(*dip));
6eb42155	130	dip->heads = dip_rb_mkhds();
69040794	131	region_init(&dip->regions);
63eba147 JA	132	dip->device = device;
63eba147 JA	133	dip->last_q = (__u64)-1;
63eba147	134	dip->map = dev_map_find(device);
69040794	135	dip->bno_dump_handle = bno_dump_init(device);
fc16a815	136	dip->unplug_hist_handle = unplug_hist_init(device);
4c48f14e AB	137	dip->seek_handle = seeki_init(mkhandle(str, device, "_d2d"));
4c48f14e AB	138	dip->q2q_handle = seeki_init(mkhandle(str, device, "_q2q"));
4ae2c3c6	139	dip->aqd_handle = aqd_init(mkhandle(str, device, "_aqd"));
e47ada10 AB	140	dip->q2d_plat_handle =
e47ada10 AB	141	plat_init(mkhandle(str, device, "_q2d_plat"));
2baef508 AB	142	dip->q2c_plat_handle =
	143	plat_init(mkhandle(str, device, "_q2c_plat"));
	144	dip->d2c_plat_handle =
	145	plat_init(mkhandle(str, device, "_d2c_plat"));
b2ecdd0f	146	latency_init(dip);
63eba147	147	list_add_tail(&dip->hash_head, &dev_heads[DEV_HASH(device)]);
6eb42155	148	list_add_tail(&dip->all_head, &all_devs);
b2822cea	149	dip->start_time = BIT_TIME(iop->t.time);
11997716	150	dip->pre_culling = 1;
951ea56c AB	151	if (output_all_data)
951ea56c AB	152	dip->q2d_priv = q2d_init();
63eba147	153	n_devs++;
a22df989 AB	154	if (per_io_trees)
	155	dip->pit_fp = open_pit(mkhandle(per_io_trees,
	156	device, "_pit.dat"));
63eba147 JA	157	}
63eba147 JA	158
11997716 AB	159	if (dip->pre_culling) {
	160	if (iop->type == IOP_Q \|\| iop->type == IOP_A)
	161	dip->pre_culling = 0;
	162	else
	163	return NULL;
	164	}
	165
095181f2	166	iop->linked = dip_rb_ins(dip, iop);
b2822cea	167	dip->end_time = BIT_TIME(iop->t.time);
c8b0b334	168
63eba147 JA	169	return dip;
63eba147 JA	170	}
6eb42155 ADB	171
	172	void dip_rem(struct io *iop)
	173	{
d76c5b81 AB	174	if (iop->linked) {
	175	dip_rb_rem(iop);
	176	iop->linked = 0;
	177	}
6eb42155 ADB	178	}
6eb42155 ADB	179
8b10aae0	180	void dip_foreach(struct io *iop, enum iop_type type,
6eb42155 ADB	181	void (fnc)(struct io iop, struct io *this), int rm_after)
	182	{
	183	if (rm_after) {
	184	LIST_HEAD(head);
	185	struct io *this;
	186	struct list_head p, q;
	187
	188	dip_rb_fe(iop->dip, type, iop, fnc, &head);
	189	list_for_each_safe(p, q, &head) {
	190	this = list_entry(p, struct io, f_head);
8b10aae0	191	list_del(&this->f_head);
6eb42155 ADB	192	io_release(this);
	193	}
	194	}
	195	else
	196	dip_rb_fe(iop->dip, type, iop, fnc, NULL);
	197	}
	198
095181f2 JA	199	void dip_foreach_list(struct io iop, enum iop_type type, struct list_head hd)
	200	{
	201	dip_rb_fe(iop->dip, type, iop, NULL, hd);
	202	}
	203
6eb42155 ADB	204	struct io dip_find_sec(struct d_info dip, enum iop_type type, __u64 sec)
	205	{
	206	return dip_rb_find_sec(dip, type, sec);
	207	}
	208
	209	void dip_foreach_out(void (func)(struct d_info , void ), void arg)
	210	{
	211	if (devices == NULL) {
	212	struct list_head *p;
	213	__list_for_each(p, &all_devs)
	214	func(list_entry(p, struct d_info, all_head), arg);
	215	}
	216	else {
	217	int i;
	218	struct d_info *dip;
	219	unsigned int mjr, mnr;
	220	char *p = devices;
	221
	222	while (p && ((i = sscanf(p, "%u,%u", &mjr, &mnr)) == 2)) {
	223	dip = __dip_find((__u32)((mjr << MINORBITS) \| mnr));
6eb42155	224	func(dip, arg);
6eb42155 ADB	225	p = strchr(p, ';');
	226	if (p) p++;
	227	}
	228	}
	229	}
b2822cea AB	230
	231	void dip_plug(__u32 dev, double cur_time)
	232	{
	233	struct d_info *dip = __dip_find(dev);
	234
	235	if (!dip \|\| dip->is_plugged) return;
	236
	237	dip->is_plugged = 1;
	238	dip->last_plug = cur_time;
	239	}
	240
b70a6642	241	void dip_unplug(__u32 dev, double cur_time, __u64 nios_up)
b2822cea AB	242	{
	243	struct d_info *dip = __dip_find(dev);
	244
00a47cd1 AB	245	if (dip && dip->is_plugged) {
	246	dip->nplugs++;
	247	dip->plugged_time += (cur_time - dip->last_plug);
	248	dip->is_plugged = 0;
b70a6642	249	dip->nios_up += nios_up;
00a47cd1 AB	250	}
00a47cd1 AB	251	}
b2822cea	252
b70a6642	253	void dip_unplug_tm(__u32 dev, __u64 nios_up)
00a47cd1 AB	254	{
00a47cd1 AB	255	struct d_info *dip = __dip_find(dev);
b2822cea	256
b70a6642	257	if (dip && dip->is_plugged) {
00a47cd1	258	dip->n_timer_unplugs++;
b70a6642 AB	259	dip->nios_upt += nios_up;
	260	dip->nplugs_t++;
	261	}
b2822cea	262	}