[blktrace.git] / iowatcher / blkparse.h

/*
 * Copyright (C) 2012 Fusion-io
 *
 *  This program is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU General Public
 *  License v2 as published by the Free Software Foundation.
 *
 *  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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 *
 *  Parts of this file were imported from Jens Axboe's blktrace sources (also GPL)
 */
#ifndef __IOWATCH_BLKPARSE__
#define __IOWATCH_BLKPARSE__
#define MINORBITS 20
#define MINORMASK ((1 << MINORBITS) - 1)
#define SECONDS(x)              ((unsigned long long)(x) / 1000000000)
#define NANO_SECONDS(x)         ((unsigned long long)(x) % 1000000000)
#define DOUBLE_TO_NANO_ULL(d)   ((unsigned long long)((d) * 1000000000))
#define CHECK_MAGIC(t)          (((t)->magic & 0xffffff00) == BLK_IO_TRACE_MAGIC)

struct dev_info {
	u32 device;
	u64 min;
	u64 max;
	u64 map;
};

#define MAX_DEVICES_PER_TRACE 64

struct trace {
	int fd;
	u64 len;
	char *start;
	char *cur;
	struct blk_io_trace *io;
	u64 start_timestamp;
	struct timespec abs_start_time;

	/*
	 * flags for the things we find in the stream
	 * we prefer different events for different things
	 */
	int found_issue;
	int found_completion;
	int found_queue;

	char *mpstat_start;
	char *mpstat_cur;
	u64 mpstat_len;
	int mpstat_fd;
	int mpstat_seconds;
	int mpstat_num_cpus;

	char *fio_start;
	char *fio_cur;
	u64 fio_len;
	int fio_fd;
	int fio_seconds;
	int num_devices;
	struct dev_info devices[MAX_DEVICES_PER_TRACE];
};

struct trace_file {
	struct list_head list;
	char *filename;
	char *label;
	struct trace *trace;
	unsigned int stop_seconds;	/* Time when trace stops */
	unsigned int min_seconds;	/* Beginning of the interval we should plot */
	unsigned int max_seconds;	/* End of the interval we should plot */
	u64 min_offset;
	u64 max_offset;

	char *reads_color;
	char *writes_color;
	char *line_color;

	struct graph_line_data *tput_writes_gld;
	struct graph_line_data *tput_reads_gld;
	struct graph_line_data *iop_gld;
	struct graph_line_data *latency_gld;
	struct graph_line_data *queue_depth_gld;

	int fio_trace;
	struct graph_line_data *fio_gld;

	/* Number of entries in gdd_writes / gdd_reads */
	int io_plots;

	/* Allocated array size for gdd_writes / gdd_reads */
	int io_plots_allocated;
	struct graph_dot_data **gdd_writes;
	struct graph_dot_data **gdd_reads;

	unsigned int mpstat_min_seconds;
	unsigned int mpstat_max_seconds;
	unsigned int mpstat_stop_seconds;
	struct graph_line_data **mpstat_gld;
};

static inline unsigned int MAJOR(unsigned int dev)
{
	return dev >> MINORBITS;
}

static inline unsigned int MINOR(unsigned int dev)
{
	return dev & MINORMASK;
}

void init_io_hash_table(void);
void init_process_hash_table(void);
struct trace *open_trace(char *filename);
u64 find_last_time(struct trace *trace);
void find_extreme_offsets(struct trace *trace, u64 *min_ret, u64 *max_ret,
			  u64 *max_bank_ret, u64 *max_offset_ret);
int filter_outliers(struct trace *trace, u64 min_offset, u64 max_offset,
		    u64 *yzoom_min, u64 *yzoom_max);
int action_char_to_num(char action);
void add_iop(struct trace *trace, struct graph_line_data *gld);
void check_record(struct trace *trace);
void add_completed_io(struct trace *trace,
		      struct graph_line_data *latency_gld);
void add_io(struct trace *trace, struct trace_file *tf);
void add_tput(struct trace *trace, struct graph_line_data *writes_gld,
	      struct graph_line_data *reads_gld);
void add_pending_io(struct trace *trace, struct graph_line_data *gld);
int next_record(struct trace *trace);
u64 get_record_time(struct trace *trace);
void first_record(struct trace *trace);
#endif
Commit	Line	Data
9e066e23 CM	1	/*
	2	* Copyright (C) 2012 Fusion-io
	3	*
	4	* This program is free software; you can redistribute it and/or
	5	* modify it under the terms of the GNU General Public
	6	* License v2 as published by the Free Software Foundation.
	7	*
	8	* This program is distributed in the hope that it will be useful,
	9	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	10	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	11	* GNU General Public License for more details.
	12	*
	13	* You should have received a copy of the GNU General Public License
	14	* along with this program; if not, write to the Free Software
660b0411	15	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
9e066e23 CM	16	*
	17	* Parts of this file were imported from Jens Axboe's blktrace sources (also GPL)
	18	*/
	19	#ifndef __IOWATCH_BLKPARSE__
	20	#define __IOWATCH_BLKPARSE__
	21	#define MINORBITS 20
	22	#define MINORMASK ((1 << MINORBITS) - 1)
	23	#define SECONDS(x) ((unsigned long long)(x) / 1000000000)
	24	#define NANO_SECONDS(x) ((unsigned long long)(x) % 1000000000)
	25	#define DOUBLE_TO_NANO_ULL(d) ((unsigned long long)((d) * 1000000000))
	26	#define CHECK_MAGIC(t) (((t)->magic & 0xffffff00) == BLK_IO_TRACE_MAGIC)
	27
2203e914 CM	28	struct dev_info {
	29	u32 device;
	30	u64 min;
	31	u64 max;
	32	u64 map;
	33	};
	34
	35	#define MAX_DEVICES_PER_TRACE 64
	36
9e066e23 CM	37	struct trace {
	38	int fd;
	39	u64 len;
	40	char *start;
	41	char *cur;
	42	struct blk_io_trace *io;
	43	u64 start_timestamp;
	44	struct timespec abs_start_time;
	45
	46	/*
	47	* flags for the things we find in the stream
	48	* we prefer different events for different things
	49	*/
	50	int found_issue;
	51	int found_completion;
	52	int found_queue;
e199d546 CM	53
	54	char *mpstat_start;
	55	char *mpstat_cur;
	56	u64 mpstat_len;
	57	int mpstat_fd;
	58	int mpstat_seconds;
	59	int mpstat_num_cpus;
24e48e03 CM	60
	61	char *fio_start;
	62	char *fio_cur;
	63	u64 fio_len;
	64	int fio_fd;
	65	int fio_seconds;
2203e914 CM	66	int num_devices;
2203e914 CM	67	struct dev_info devices[MAX_DEVICES_PER_TRACE];
9e066e23 CM	68	};
9e066e23 CM	69
0a43b43f JK	70	struct trace_file {
	71	struct list_head list;
	72	char *filename;
	73	char *label;
	74	struct trace *trace;
22dd439a JK	75	unsigned int stop_seconds; /* Time when trace stops */
	76	unsigned int min_seconds; /* Beginning of the interval we should plot */
	77	unsigned int max_seconds; /* End of the interval we should plot */
0a43b43f JK	78	u64 min_offset;
	79	u64 max_offset;
	80
2203e914 CM	81	char *reads_color;
2203e914 CM	82	char *writes_color;
0a43b43f JK	83	char *line_color;
0a43b43f JK	84
2203e914 CM	85	struct graph_line_data *tput_writes_gld;
2203e914 CM	86	struct graph_line_data *tput_reads_gld;
0a43b43f JK	87	struct graph_line_data *iop_gld;
	88	struct graph_line_data *latency_gld;
	89	struct graph_line_data *queue_depth_gld;
24e48e03 CM	90
	91	int fio_trace;
	92	struct graph_line_data *fio_gld;
	93
0a43b43f JK	94	/* Number of entries in gdd_writes / gdd_reads */
0a43b43f JK	95	int io_plots;
24e48e03	96
0a43b43f JK	97	/* Allocated array size for gdd_writes / gdd_reads */
	98	int io_plots_allocated;
	99	struct graph_dot_data **gdd_writes;
	100	struct graph_dot_data **gdd_reads;
	101
22dd439a JK	102	unsigned int mpstat_min_seconds;
	103	unsigned int mpstat_max_seconds;
	104	unsigned int mpstat_stop_seconds;
0a43b43f JK	105	struct graph_line_data **mpstat_gld;
	106	};
	107
9e066e23 CM	108	static inline unsigned int MAJOR(unsigned int dev)
	109	{
	110	return dev >> MINORBITS;
	111	}
	112
	113	static inline unsigned int MINOR(unsigned int dev)
	114	{
	115	return dev & MINORMASK;
	116	}
	117
	118	void init_io_hash_table(void);
0a43b43f	119	void init_process_hash_table(void);
9e066e23 CM	120	struct trace open_trace(char filename);
9e066e23 CM	121	u64 find_last_time(struct trace *trace);
9b9fa04b JK	122	void find_extreme_offsets(struct trace trace, u64 min_ret, u64 *max_ret,
	123	u64 max_bank_ret, u64 max_offset_ret);
	124	int filter_outliers(struct trace *trace, u64 min_offset, u64 max_offset,
9e066e23	125	u64 yzoom_min, u64 yzoom_max);
f2e40ddd	126	int action_char_to_num(char action);
9e066e23 CM	127	void add_iop(struct trace trace, struct graph_line_data gld);
	128	void check_record(struct trace *trace);
	129	void add_completed_io(struct trace *trace,
	130	struct graph_line_data *latency_gld);
0a43b43f	131	void add_io(struct trace trace, struct trace_file tf);
2203e914 CM	132	void add_tput(struct trace trace, struct graph_line_data writes_gld,
2203e914 CM	133	struct graph_line_data *reads_gld);
9e066e23 CM	134	void add_pending_io(struct trace trace, struct graph_line_data gld);
9e066e23 CM	135	int next_record(struct trace *trace);
6a079b02	136	u64 get_record_time(struct trace *trace);
9e066e23 CM	137	void first_record(struct trace *trace);
9e066e23 CM	138	#endif