[blktrace.git] / blkrawverify.c

/*
 * block queue tracing application
 *
 * 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 <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>

#include "blktrace.h"

struct trace_info {
	int bit_field;
	char *string;
};

int data_is_native = -1;

#define TRACE_TO_STRING(f)	{.bit_field = f, .string = #f}
static struct trace_info traces[] = {
	TRACE_TO_STRING( BLK_TC_READ ),
	TRACE_TO_STRING( BLK_TC_WRITE ),
	TRACE_TO_STRING( BLK_TC_BARRIER ),
	TRACE_TO_STRING( BLK_TC_SYNC ),
	TRACE_TO_STRING( BLK_TC_QUEUE ),
	TRACE_TO_STRING( BLK_TC_REQUEUE ),
	TRACE_TO_STRING( BLK_TC_ISSUE ),
	TRACE_TO_STRING( BLK_TC_COMPLETE ),
	TRACE_TO_STRING( BLK_TC_FS ),
	TRACE_TO_STRING( BLK_TC_PC ),
	TRACE_TO_STRING( BLK_TC_AHEAD ),
	TRACE_TO_STRING( BLK_TC_META ),
	TRACE_TO_STRING( BLK_TC_DISCARD ),
};
#define N_TRACES (sizeof(traces) / sizeof(struct trace_info))

struct act_info {
	__u32 val;
	char *string;
};

#define ACT_TO_STRING(f)	{.val = f, .string = #f}
static struct act_info acts[] = {
	ACT_TO_STRING( __BLK_TA_QUEUE ),
	ACT_TO_STRING( __BLK_TA_QUEUE ),
	ACT_TO_STRING( __BLK_TA_BACKMERGE ),
	ACT_TO_STRING( __BLK_TA_FRONTMERGE ),
	ACT_TO_STRING( __BLK_TA_GETRQ ),
	ACT_TO_STRING( __BLK_TA_SLEEPRQ ),
	ACT_TO_STRING( __BLK_TA_REQUEUE ),
	ACT_TO_STRING( __BLK_TA_ISSUE ),
	ACT_TO_STRING( __BLK_TA_COMPLETE ),
	ACT_TO_STRING( __BLK_TA_PLUG ),
	ACT_TO_STRING( __BLK_TA_UNPLUG_IO ),
	ACT_TO_STRING( __BLK_TA_UNPLUG_TIMER ),
	ACT_TO_STRING( __BLK_TA_INSERT ),
	ACT_TO_STRING( __BLK_TA_SPLIT ),
	ACT_TO_STRING( __BLK_TA_BOUNCE ),
	ACT_TO_STRING( __BLK_TA_REMAP )
};
#define N_ACTS (sizeof(acts) / sizeof(struct act_info))

static char *act_to_str(__u32 action)
{
	static char buf[1024];
	unsigned int i;
	unsigned int act = action & 0xffff;
	unsigned int trace = (action >> BLK_TC_SHIFT) & 0xffff;

	if (act <= N_ACTS) {
		sprintf(buf, "%s ", acts[act].string);
		for (i = 0; i < N_TRACES; i++)
			if (trace & (1 << i)) {
				char buf2[1024];
				sprintf(buf2, "| %s ", traces[i].string);
				strcat(buf, buf2);
			}
	}
	else
		sprintf(buf, "Invalid action=%08x", action);

	return buf;
}

static void dump_trace(FILE *ofp, char *prefix, struct blk_io_trace *bit)
{
	fprintf(ofp, "    Dump %s\n", prefix);
	fprintf(ofp, "        %8s: %08x\n", "magic", bit->magic);
	fprintf(ofp, "        %8s: %u\n", "sequence", bit->sequence);
	fprintf(ofp, "        %8s: %llu\n", "time", (unsigned long long) bit->time);
	fprintf(ofp, "        %8s: %llu\n", "sector", (unsigned long long) bit->sector);
	fprintf(ofp, "        %8s: %u\n", "bytes", bit->bytes);
	fprintf(ofp, "        %8s: %s\n", "action", act_to_str(bit->action));
	fprintf(ofp, "        %8s: %u\n", "bytes", bit->bytes);
	fprintf(ofp, "        %8s: %u\n", "cpu", bit->cpu);
	fprintf(ofp, "        %8s: %u\n", "error", bit->error);
	fprintf(ofp, "        %8s: %u\n", "pdu_len", bit->pdu_len);
	fprintf(ofp, "        %8s: (%u,%u)\n\n", "device", MAJOR(bit->device),
						           MINOR(bit->device));
}

static int process(FILE **fp, char *devname, char *file, unsigned int cpu)
{
#	define SWAP_BITS() do {						\
		if (bit_save) {						\
			struct blk_io_trace *tmp = bit_save;		\
			bit_save = bit;					\
			bit = tmp;					\
		}							\
		else {							\
			bit_save = bit;					\
			bit = malloc(sizeof(struct blk_io_trace));	\
		}							\
	} while (0)

#	define INC_BAD(str) do {					\
		nbad++;							\
		fprintf(ofp, "    ----------------\n");			\
		if (bit_save) dump_trace(ofp,"seq-1",bit_save);		\
		dump_trace(ofp, str, bit);				\
		SWAP_BITS();						\
	} while (0)

	size_t n;
	FILE *ifp, *ofp;
	__u32 save_device = 0, save_sequence = 0;
	__u64 save_time = 0;
	struct blk_io_trace *bit_save = NULL;
	struct blk_io_trace *bit = malloc(sizeof(struct blk_io_trace));
	unsigned int ngood = 0;
	unsigned int nbad = 0;
	unsigned int nbad_trace = 0, nbad_pdu = 0, nbad_cpu = 0;
	unsigned int nbad_seq = 0, nbad_dev = 0, nbad_time = 0;
	char ofname[1024];

	ifp = fopen(file, "r");
	if (!ifp)
		return 0;

	sprintf(ofname, "%s.verify.out", devname);

	if (!*fp) {
		*fp = fopen(ofname, "w");
		if (*fp == NULL) {
			fprintf(stderr,"Failed to open %s (%s), skipping\n",
				ofname, strerror(errno));
			fclose(ifp);
			return 0;
		}
		fprintf(*fp, "\n---------------\n" );
		fprintf(*fp, "Verifying %s\n", devname);
	}

	ofp = *fp;
	while ((n = fread(bit, sizeof(struct blk_io_trace), 1, ifp)) == 1) {
		if (ferror(ifp)) {
			clearerr(ifp);
			perror("fread");
			break;
		}
		if (data_is_native == -1)
			check_data_endianness(bit->magic);

		trace_to_cpu(bit);

		if (!CHECK_MAGIC(bit)) {
			INC_BAD("bad trace");
			continue;
		}

		if ((bit->magic & 0xff) != SUPPORTED_VERSION) {
			fprintf(stderr, "unsupported trace version\n");
			break;
		}

		if (bit->pdu_len) {
			char *pdu_buf;

			pdu_buf = malloc(bit->pdu_len);
			n = fread(pdu_buf, bit->pdu_len, 1, ifp);
			if (n == 0) {
				INC_BAD("bad pdu");
				nbad_seq++;
				break;
			}
			free(pdu_buf);
		}

		if (bit->cpu != cpu) {
			INC_BAD("bad cpu");
			nbad_cpu++;
			continue;
		}

		/*
		 * skip notify traces, they don't have valid sequences
		 */
		if (bit->action & BLK_TC_ACT(BLK_TC_NOTIFY))
			continue;

		if (ngood) {
			if (bit->sequence <= save_sequence) {
				INC_BAD("bad seq");
				nbad_seq++;
				continue;
			}
			else if (bit->time <= save_time) {
				INC_BAD("time regression");
				nbad_time++;
				continue;
			}
			else if (bit->device != save_device) {
				INC_BAD("bad dev");
				nbad_dev++;
				continue;
			}
		}

		save_sequence = bit->sequence;
		save_time = bit->time;
		save_device = bit->device;

		ngood++;
		SWAP_BITS();
	}

	if (n == 0 && !feof(ifp))
		fprintf(stderr,"%s: fread failed %d/%s\n",
		        file, errno, strerror(errno));
	fclose(ifp);

	fprintf(ofp, "    ---------------------\n");
	fprintf(ofp, "    Summary for cpu %d:\n", cpu);
	fprintf(ofp, "    %10d valid + %10d invalid (%5.1f%%) processed\n\n",
		ngood, nbad,
		ngood ? 100.0 * (float)ngood / (float)(ngood + nbad) : 0.0);

	if (nbad) {
		if (nbad_trace)
			fprintf(ofp, "%8s %d traces\n", "", nbad_trace);
		if (nbad_trace)
			fprintf(ofp, "%8s %d pdu\n", "", nbad_pdu);
		if (nbad_cpu)
			fprintf(ofp, "%8s %d cpu\n", "", nbad_cpu);
		if (nbad_seq)
			fprintf(ofp, "%8s %d seq\n", "", nbad_seq);
		if (nbad_dev)
			fprintf(ofp, "%8s %d dev\n", "", nbad_dev);
		if (nbad_time)
			fprintf(ofp, "%8s %d time\n", "", nbad_time);
		fprintf(ofp,"\n");
	}

	return nbad;
}

int main(int argc, char *argv[])
{
	char *devname;
	struct stat st;
	int i, cpu, nbad, rval = 0;
	FILE *ofp;
	char *ofname = malloc(1024);
	char *fname = malloc(1024);

	if (argc < 2) {
		fprintf(stderr,"FATAL: Need device name(s)\n");
		fprintf(stderr,"Usage: blkrawverify <dev> [<dev>...]\n");
		exit(1);
	}

	for (i = 1; i < argc; i++) {
		devname = argv[i];
		sprintf(ofname, "%s.verify.out", devname);
		ofp = NULL;

		printf("Verifying %s\n", devname); fflush(stdout);
		for (cpu = 0; ; cpu++) {
			sprintf(fname, "%s.blktrace.%d", devname, cpu);
			if (stat(fname, &st) < 0)
				break;
			printf("    CPU %d ", cpu); fflush(stdout);
			nbad = process(&ofp, devname, fname, cpu);
			if (nbad) {
				printf("-- %d bad", nbad);
				rval = 1;
			}
			printf("\n");
		}
		if (ofp) {
			fclose(ofp);
			fprintf(stdout, "Wrote output to %s\n", ofname);
		}
	}

	return rval;
}
Commit	Line	Data
f17c879d AB	1	/*
	2	* block queue tracing application
	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>
	22	#include <stdlib.h>
	23	#include <string.h>
	24	#include <errno.h>
	25	#include <sys/types.h>
	26	#include <sys/stat.h>
	27	#include <unistd.h>
	28
	29	#include "blktrace.h"
	30
	31	struct trace_info {
	32	int bit_field;
	33	char *string;
	34	};
	35
86368eb5	36	int data_is_native = -1;
017d1660	37
f17c879d AB	38	#define TRACE_TO_STRING(f) {.bit_field = f, .string = #f}
	39	static struct trace_info traces[] = {
	40	TRACE_TO_STRING( BLK_TC_READ ),
	41	TRACE_TO_STRING( BLK_TC_WRITE ),
	42	TRACE_TO_STRING( BLK_TC_BARRIER ),
	43	TRACE_TO_STRING( BLK_TC_SYNC ),
	44	TRACE_TO_STRING( BLK_TC_QUEUE ),
	45	TRACE_TO_STRING( BLK_TC_REQUEUE ),
	46	TRACE_TO_STRING( BLK_TC_ISSUE ),
	47	TRACE_TO_STRING( BLK_TC_COMPLETE ),
	48	TRACE_TO_STRING( BLK_TC_FS ),
f86990ed NS	49	TRACE_TO_STRING( BLK_TC_PC ),
f86990ed NS	50	TRACE_TO_STRING( BLK_TC_AHEAD ),
711e4d25	51	TRACE_TO_STRING( BLK_TC_META ),
37081bf5	52	TRACE_TO_STRING( BLK_TC_DISCARD ),
f17c879d AB	53	};
	54	#define N_TRACES (sizeof(traces) / sizeof(struct trace_info))
	55
	56	struct act_info {
	57	__u32 val;
	58	char *string;
	59	};
	60
	61	#define ACT_TO_STRING(f) {.val = f, .string = #f}
	62	static struct act_info acts[] = {
	63	ACT_TO_STRING( __BLK_TA_QUEUE ),
	64	ACT_TO_STRING( __BLK_TA_QUEUE ),
	65	ACT_TO_STRING( __BLK_TA_BACKMERGE ),
	66	ACT_TO_STRING( __BLK_TA_FRONTMERGE ),
	67	ACT_TO_STRING( __BLK_TA_GETRQ ),
	68	ACT_TO_STRING( __BLK_TA_SLEEPRQ ),
	69	ACT_TO_STRING( __BLK_TA_REQUEUE ),
	70	ACT_TO_STRING( __BLK_TA_ISSUE ),
	71	ACT_TO_STRING( __BLK_TA_COMPLETE ),
	72	ACT_TO_STRING( __BLK_TA_PLUG ),
	73	ACT_TO_STRING( __BLK_TA_UNPLUG_IO ),
	74	ACT_TO_STRING( __BLK_TA_UNPLUG_TIMER ),
	75	ACT_TO_STRING( __BLK_TA_INSERT ),
	76	ACT_TO_STRING( __BLK_TA_SPLIT ),
	77	ACT_TO_STRING( __BLK_TA_BOUNCE ),
	78	ACT_TO_STRING( __BLK_TA_REMAP )
	79	};
	80	#define N_ACTS (sizeof(acts) / sizeof(struct act_info))
	81
	82	static char *act_to_str(__u32 action)
	83	{
	84	static char buf[1024];
5be4bdaf JA	85	unsigned int i;
	86	unsigned int act = action & 0xffff;
	87	unsigned int trace = (action >> BLK_TC_SHIFT) & 0xffff;
f17c879d AB	88
	89	if (act <= N_ACTS) {
	90	sprintf(buf, "%s ", acts[act].string);
	91	for (i = 0; i < N_TRACES; i++)
	92	if (trace & (1 << i)) {
	93	char buf2[1024];
	94	sprintf(buf2, "\| %s ", traces[i].string);
	95	strcat(buf, buf2);
	96	}
	97	}
	98	else
	99	sprintf(buf, "Invalid action=%08x", action);
	100
	101	return buf;
	102	}
	103
	104	static void dump_trace(FILE ofp, char prefix, struct blk_io_trace *bit)
	105	{
	106	fprintf(ofp, " Dump %s\n", prefix);
	107	fprintf(ofp, " %8s: %08x\n", "magic", bit->magic);
	108	fprintf(ofp, " %8s: %u\n", "sequence", bit->sequence);
c0cb7fab JA	109	fprintf(ofp, " %8s: %llu\n", "time", (unsigned long long) bit->time);
c0cb7fab JA	110	fprintf(ofp, " %8s: %llu\n", "sector", (unsigned long long) bit->sector);
f17c879d AB	111	fprintf(ofp, " %8s: %u\n", "bytes", bit->bytes);
	112	fprintf(ofp, " %8s: %s\n", "action", act_to_str(bit->action));
	113	fprintf(ofp, " %8s: %u\n", "bytes", bit->bytes);
	114	fprintf(ofp, " %8s: %u\n", "cpu", bit->cpu);
	115	fprintf(ofp, " %8s: %u\n", "error", bit->error);
	116	fprintf(ofp, " %8s: %u\n", "pdu_len", bit->pdu_len);
	117	fprintf(ofp, " %8s: (%u,%u)\n\n", "device", MAJOR(bit->device),
	118	MINOR(bit->device));
	119	}
	120
05831aca	121	static int process(FILE *fp, char devname, char *file, unsigned int cpu)
f17c879d AB	122	{
	123	# define SWAP_BITS() do { \
	124	if (bit_save) { \
	125	struct blk_io_trace *tmp = bit_save; \
	126	bit_save = bit; \
	127	bit = tmp; \
	128	} \
	129	else { \
	130	bit_save = bit; \
	131	bit = malloc(sizeof(struct blk_io_trace)); \
	132	} \
	133	} while (0)
	134
	135	# define INC_BAD(str) do { \
	136	nbad++; \
	137	fprintf(ofp, " ----------------\n"); \
	138	if (bit_save) dump_trace(ofp,"seq-1",bit_save); \
	139	dump_trace(ofp, str, bit); \
	140	SWAP_BITS(); \
	141	} while (0)
	142
	143	size_t n;
05831aca	144	FILE ifp, ofp;
f17c879d AB	145	__u32 save_device = 0, save_sequence = 0;
	146	__u64 save_time = 0;
	147	struct blk_io_trace *bit_save = NULL;
	148	struct blk_io_trace *bit = malloc(sizeof(struct blk_io_trace));
	149	unsigned int ngood = 0;
	150	unsigned int nbad = 0;
	151	unsigned int nbad_trace = 0, nbad_pdu = 0, nbad_cpu = 0;
	152	unsigned int nbad_seq = 0, nbad_dev = 0, nbad_time = 0;
05831aca	153	char ofname[1024];
f17c879d AB	154
f17c879d AB	155	ifp = fopen(file, "r");
05831aca JA	156	if (!ifp)
	157	return 0;
	158
	159	sprintf(ofname, "%s.verify.out", devname);
	160
	161	if (!*fp) {
	162	*fp = fopen(ofname, "w");
	163	if (*fp == NULL) {
	164	fprintf(stderr,"Failed to open %s (%s), skipping\n",
	165	ofname, strerror(errno));
	166	fclose(ifp);
	167	return 0;
	168	}
	169	fprintf(*fp, "\n---------------\n" );
	170	fprintf(*fp, "Verifying %s\n", devname);
	171	}
	172
	173	ofp = *fp;
f17c879d	174	while ((n = fread(bit, sizeof(struct blk_io_trace), 1, ifp)) == 1) {
1452478f JA	175	if (ferror(ifp)) {
	176	clearerr(ifp);
	177	perror("fread");
	178	break;
	179	}
4ff24a34 JA	180	if (data_is_native == -1)
	181	check_data_endianness(bit->magic);
	182
f17c879d	183	trace_to_cpu(bit);
4ba99bfc JA	184
4ba99bfc JA	185	if (!CHECK_MAGIC(bit)) {
f17c879d AB	186	INC_BAD("bad trace");
	187	continue;
	188	}
	189
4ba99bfc JA	190	if ((bit->magic & 0xff) != SUPPORTED_VERSION) {
	191	fprintf(stderr, "unsupported trace version\n");
	192	break;
	193	}
	194
f17c879d AB	195	if (bit->pdu_len) {
	196	char *pdu_buf;
	197
	198	pdu_buf = malloc(bit->pdu_len);
	199	n = fread(pdu_buf, bit->pdu_len, 1, ifp);
5be4bdaf	200	if (n == 0) {
f17c879d AB	201	INC_BAD("bad pdu");
	202	nbad_seq++;
	203	break;
	204	}
	205	free(pdu_buf);
	206	}
	207
	208	if (bit->cpu != cpu) {
	209	INC_BAD("bad cpu");
	210	nbad_cpu++;
	211	continue;
	212	}
	213
bfc70ad5 JA	214	/*
	215	* skip notify traces, they don't have valid sequences
	216	*/
	217	if (bit->action & BLK_TC_ACT(BLK_TC_NOTIFY))
	218	continue;
	219
f17c879d AB	220	if (ngood) {
	221	if (bit->sequence <= save_sequence) {
	222	INC_BAD("bad seq");
	223	nbad_seq++;
	224	continue;
	225	}
	226	else if (bit->time <= save_time) {
	227	INC_BAD("time regression");
	228	nbad_time++;
	229	continue;
	230	}
	231	else if (bit->device != save_device) {
	232	INC_BAD("bad dev");
	233	nbad_dev++;
	234	continue;
	235	}
	236	}
	237
	238	save_sequence = bit->sequence;
	239	save_time = bit->time;
	240	save_device = bit->device;
	241
	242	ngood++;
	243	SWAP_BITS();
	244	}
	245
05e2c559	246	if (n == 0 && !feof(ifp))
f17c879d AB	247	fprintf(stderr,"%s: fread failed %d/%s\n",
	248	file, errno, strerror(errno));
	249	fclose(ifp);
	250
	251	fprintf(ofp, " ---------------------\n");
	252	fprintf(ofp, " Summary for cpu %d:\n", cpu);
	253	fprintf(ofp, " %10d valid + %10d invalid (%5.1f%%) processed\n\n",
	254	ngood, nbad,
	255	ngood ? 100.0 * (float)ngood / (float)(ngood + nbad) : 0.0);
	256
	257	if (nbad) {
	258	if (nbad_trace)
	259	fprintf(ofp, "%8s %d traces\n", "", nbad_trace);
	260	if (nbad_trace)
	261	fprintf(ofp, "%8s %d pdu\n", "", nbad_pdu);
	262	if (nbad_cpu)
	263	fprintf(ofp, "%8s %d cpu\n", "", nbad_cpu);
	264	if (nbad_seq)
	265	fprintf(ofp, "%8s %d seq\n", "", nbad_seq);
	266	if (nbad_dev)
	267	fprintf(ofp, "%8s %d dev\n", "", nbad_dev);
	268	if (nbad_time)
	269	fprintf(ofp, "%8s %d time\n", "", nbad_time);
	270	fprintf(ofp,"\n");
	271	}
	272
	273	return nbad;
	274	}
	275
	276	int main(int argc, char *argv[])
	277	{
	278	char *devname;
	279	struct stat st;
2b9df5a1	280	int i, cpu, nbad, rval = 0;
f17c879d AB	281	FILE *ofp;
	282	char *ofname = malloc(1024);
	283	char *fname = malloc(1024);
	284
	285	if (argc < 2) {
	286	fprintf(stderr,"FATAL: Need device name(s)\n");
	287	fprintf(stderr,"Usage: blkrawverify <dev> [<dev>...]\n");
	288	exit(1);
	289	}
	290
	291	for (i = 1; i < argc; i++) {
	292	devname = argv[i];
	293	sprintf(ofname, "%s.verify.out", devname);
05831aca	294	ofp = NULL;
f17c879d	295
f17c879d AB	296	printf("Verifying %s\n", devname); fflush(stdout);
	297	for (cpu = 0; ; cpu++) {
	298	sprintf(fname, "%s.blktrace.%d", devname, cpu);
	299	if (stat(fname, &st) < 0)
	300	break;
	301	printf(" CPU %d ", cpu); fflush(stdout);
05831aca	302	nbad = process(&ofp, devname, fname, cpu);
2b9df5a1	303	if (nbad) {
f17c879d	304	printf("-- %d bad", nbad);
2b9df5a1 AB	305	rval = 1;
2b9df5a1 AB	306	}
f17c879d AB	307	printf("\n");
f17c879d AB	308	}
05831aca JA	309	if (ofp) {
	310	fclose(ofp);
	311	fprintf(stdout, "Wrote output to %s\n", ofname);
	312	}
f17c879d AB	313	}
f17c879d AB	314
2b9df5a1	315	return rval;
f17c879d	316	}