2 * block queue tracing application
4 * Copyright (C) 2006 Alan D. Brunelle <Alan.Brunelle@hp.com>
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.
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.
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
25 #include <sys/types.h>
36 int data_is_native = -1;
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 ),
49 TRACE_TO_STRING( BLK_TC_PC )
51 #define N_TRACES (sizeof(traces) / sizeof(struct trace_info))
58 #define ACT_TO_STRING(f) {.val = f, .string = #f}
59 static struct act_info acts[] = {
60 ACT_TO_STRING( __BLK_TA_QUEUE ),
61 ACT_TO_STRING( __BLK_TA_QUEUE ),
62 ACT_TO_STRING( __BLK_TA_BACKMERGE ),
63 ACT_TO_STRING( __BLK_TA_FRONTMERGE ),
64 ACT_TO_STRING( __BLK_TA_GETRQ ),
65 ACT_TO_STRING( __BLK_TA_SLEEPRQ ),
66 ACT_TO_STRING( __BLK_TA_REQUEUE ),
67 ACT_TO_STRING( __BLK_TA_ISSUE ),
68 ACT_TO_STRING( __BLK_TA_COMPLETE ),
69 ACT_TO_STRING( __BLK_TA_PLUG ),
70 ACT_TO_STRING( __BLK_TA_UNPLUG_IO ),
71 ACT_TO_STRING( __BLK_TA_UNPLUG_TIMER ),
72 ACT_TO_STRING( __BLK_TA_INSERT ),
73 ACT_TO_STRING( __BLK_TA_SPLIT ),
74 ACT_TO_STRING( __BLK_TA_BOUNCE ),
75 ACT_TO_STRING( __BLK_TA_REMAP )
77 #define N_ACTS (sizeof(acts) / sizeof(struct act_info))
79 static char *act_to_str(__u32 action)
81 static char buf[1024];
83 unsigned int act = action & 0xffff;
84 unsigned int trace = (action >> BLK_TC_SHIFT) & 0xffff;
87 sprintf(buf, "%s ", acts[act].string);
88 for (i = 0; i < N_TRACES; i++)
89 if (trace & (1 << i)) {
91 sprintf(buf2, "| %s ", traces[i].string);
96 sprintf(buf, "Invalid action=%08x", action);
101 static void dump_trace(FILE *ofp, char *prefix, struct blk_io_trace *bit)
103 fprintf(ofp, " Dump %s\n", prefix);
104 fprintf(ofp, " %8s: %08x\n", "magic", bit->magic);
105 fprintf(ofp, " %8s: %u\n", "sequence", bit->sequence);
106 fprintf(ofp, " %8s: %llu\n", "time", (unsigned long long) bit->time);
107 fprintf(ofp, " %8s: %llu\n", "sector", (unsigned long long) bit->sector);
108 fprintf(ofp, " %8s: %u\n", "bytes", bit->bytes);
109 fprintf(ofp, " %8s: %s\n", "action", act_to_str(bit->action));
110 fprintf(ofp, " %8s: %u\n", "bytes", bit->bytes);
111 fprintf(ofp, " %8s: %u\n", "cpu", bit->cpu);
112 fprintf(ofp, " %8s: %u\n", "error", bit->error);
113 fprintf(ofp, " %8s: %u\n", "pdu_len", bit->pdu_len);
114 fprintf(ofp, " %8s: (%u,%u)\n\n", "device", MAJOR(bit->device),
118 static int process(FILE *ofp, char *file, unsigned int cpu)
120 # define SWAP_BITS() do { \
122 struct blk_io_trace *tmp = bit_save; \
128 bit = malloc(sizeof(struct blk_io_trace)); \
132 # define INC_BAD(str) do { \
134 fprintf(ofp, " ----------------\n"); \
135 if (bit_save) dump_trace(ofp,"seq-1",bit_save); \
136 dump_trace(ofp, str, bit); \
142 __u32 save_device = 0, save_sequence = 0;
144 struct blk_io_trace *bit_save = NULL;
145 struct blk_io_trace *bit = malloc(sizeof(struct blk_io_trace));
146 unsigned int ngood = 0;
147 unsigned int nbad = 0;
148 unsigned int nbad_trace = 0, nbad_pdu = 0, nbad_cpu = 0;
149 unsigned int nbad_seq = 0, nbad_dev = 0, nbad_time = 0;
151 ifp = fopen(file, "r");
152 while ((n = fread(bit, sizeof(struct blk_io_trace), 1, ifp)) == 1) {
153 if (data_is_native == -1)
154 check_data_endianness(bit->magic);
158 if (!CHECK_MAGIC(bit)) {
159 INC_BAD("bad trace");
163 if ((bit->magic & 0xff) != SUPPORTED_VERSION) {
164 fprintf(stderr, "unsupported trace version\n");
171 pdu_buf = malloc(bit->pdu_len);
172 n = fread(pdu_buf, bit->pdu_len, 1, ifp);
181 if (bit->cpu != cpu) {
188 * skip notify traces, they don't have valid sequences
190 if (bit->action & BLK_TC_ACT(BLK_TC_NOTIFY))
194 if (bit->sequence <= save_sequence) {
199 else if (bit->time <= save_time) {
200 INC_BAD("time regression");
204 else if (bit->device != save_device) {
211 save_sequence = bit->sequence;
212 save_time = bit->time;
213 save_device = bit->device;
219 if (n == 0 && !feof(ifp))
220 fprintf(stderr,"%s: fread failed %d/%s\n",
221 file, errno, strerror(errno));
224 fprintf(ofp, " ---------------------\n");
225 fprintf(ofp, " Summary for cpu %d:\n", cpu);
226 fprintf(ofp, " %10d valid + %10d invalid (%5.1f%%) processed\n\n",
228 ngood ? 100.0 * (float)ngood / (float)(ngood + nbad) : 0.0);
232 fprintf(ofp, "%8s %d traces\n", "", nbad_trace);
234 fprintf(ofp, "%8s %d pdu\n", "", nbad_pdu);
236 fprintf(ofp, "%8s %d cpu\n", "", nbad_cpu);
238 fprintf(ofp, "%8s %d seq\n", "", nbad_seq);
240 fprintf(ofp, "%8s %d dev\n", "", nbad_dev);
242 fprintf(ofp, "%8s %d time\n", "", nbad_time);
249 int main(int argc, char *argv[])
255 char *ofname = malloc(1024);
256 char *fname = malloc(1024);
259 fprintf(stderr,"FATAL: Need device name(s)\n");
260 fprintf(stderr,"Usage: blkrawverify <dev> [<dev>...]\n");
264 for (i = 1; i < argc; i++) {
266 sprintf(ofname, "%s.verify.out", devname);
267 ofp = fopen(ofname, "w");
269 fprintf(stderr,"Failed to open %s (%s), skipping %s\n",
270 ofname, strerror(errno), devname);
274 fprintf(ofp, "\n---------------\n" );
275 fprintf(ofp, "Verifying %s\n", devname);
276 printf("Verifying %s\n", devname); fflush(stdout);
277 for (cpu = 0; ; cpu++) {
278 sprintf(fname, "%s.blktrace.%d", devname, cpu);
279 if (stat(fname, &st) < 0)
281 printf(" CPU %d ", cpu); fflush(stdout);
282 nbad = process(ofp, fname, cpu);
284 printf("-- %d bad", nbad);
288 fprintf(stdout, "Wrote output to %s\n", ofname);