diff mbox series

[RFC,blktrace-tools,06/10] blkparse-fmt.c: add extension support

Message ID 20190501043317.5507-7-chaitanya.kulkarni@wdc.com (mailing list archive)
State New, archived
Headers show
Series blktrace: add blktrace extension support | expand

Commit Message

Chaitanya Kulkarni May 1, 2019, 4:33 a.m. UTC 
This patch adds support for blkparse format to use the blktrace
extension. Here we update the blkparse format processing and add
extension support for handling the priorities.

By default for any command blkparse format only prints the sector
in and bytes transfer if trace has bytes associated with it.
For zone reset command we need to print the sectors even though
it doesn't have bytes associated with it.

1. Using blktrace with blkparse with these changes from command line :-

prio mask F=00001111 -> IDLE BEST REAL NONE

Will produce a following output for the write zeroes command
issued with the blkdiscard -z options (where write-zeroes is
enabled on the null_blk, please see the later patches) :-
#for prio in 0 1 2 3;
> do
> 	echo "$prio"
> 	ionice -c ${prio} blkdiscard -z -o 0 -l 4096 /dev/nullb0
> done

252,0    7        1     0.000000000 11683  Q WZS NONE 0 0 + 8 [blkdiscard]
252,0    7        2     0.000017726 11683  G WZS NONE 0 0 + 8 [blkdiscard]
252,0    7        5     0.000036753 11683  I WZS NONE 0 0 + 8 [blkdiscard]
252,0    7        6     0.000084833   590  D WZS NONE 0 0 + 8 [kworker/7:1H]
252,0    7        7     0.000123823    46  C WZS NONE 0 0 + 8 [0]
252,0    5        1     0.457135696 11685  Q WZS REAL 4 0 + 8 [blkdiscard]
252,0    5        2     0.457149696 11685  G WZS REAL 4 0 + 8 [blkdiscard]
252,0    5        5     0.457168205 11685  I WZS REAL 4 0 + 8 [blkdiscard]
252,0    5        6     0.457213155   526  D WZS REAL 4 0 + 8 [kworker/5:1H]
252,0    5        7     0.457250408    36  C WZS REAL 4 0 + 8 [0]
252,0    7        8     0.715223985 11686  Q WZS BEST 4 0 + 8 [blkdiscard]
252,0    7        9     0.715238045 11686  G WZS BEST 4 0 + 8 [blkdiscard]
252,0    7       12     0.715255462 11686  I WZS BEST 4 0 + 8 [blkdiscard]
252,0    7       13     0.715297718   590  D WZS BEST 4 0 + 8 [kworker/7:1H]
252,0    7       14     0.715330957    46  C WZS BEST 4 0 + 8 [0]
252,0    8        1     0.949218847 11687  Q WZS IDLE 7 0 + 8 [blkdiscard]
252,0    8        2     0.949232970 11687  G WZS IDLE 7 0 + 8 [blkdiscard]
252,0    8        5     0.949250266 11687  I WZS IDLE 7 0 + 8 [blkdiscard]
252,0    8        6     0.949294703   519  D WZS IDLE 7 0 + 8 [kworker/8:1H]
252,0    8        7     0.949330943    51  C WZS IDLE 7 0 + 8 [0]

2. Using blktrace with blkparse with these changes from command line :-

prio mask B=00001011 -> IDEL 0 REAL NONE

Will produce a following output for the write zeroes command
issued with the blkdiscard -z options (where write-zeroes is
enabled on the null_blk, please see the later patches) :-
#for prio in 0 1 2 3;
> do
> 	echo "$prio"
> 	ionice -c ${prio} blkdiscard -z -o 0 -l 4096 /dev/nullb0
> done

252,0    0        1     0.000000000 11584  Q WZS NONE 0 0 + 8 [blkdiscard]
252,0    0        2     0.000031548 11584  G WZS NONE 0 0 + 8 [blkdiscard]
252,0    0        5     0.000054369 11584  I WZS NONE 0 0 + 8 [blkdiscard]
252,0    0        6     0.000109033   517  D WZS NONE 0 0 + 8 [kworker/0:1H]
252,0    0        7     0.000151984     9  C WZS NONE 0 0 + 8 [0]
252,0    0        9     0.656430970 11586  G WZS REAL 4 0 + 8 [blkdiscard]
252,0    0       12     0.656448477 11586  I WZS REAL 4 0 + 8 [blkdiscard]
252,0    0       13     0.656488270   517  D WZS REAL 4 0 + 8 [kworker/0:1H]
252,0    0       14     0.656521240     9  C WZS REAL 4 0 + 8 [0]
252,0    0       15    10.598584665 11587  Q WZS 0 + 8 [blkdiscard]
252,0    0       16    10.598600772 11587  G WZS 0 + 8 [blkdiscard]
252,0    0       19    10.598619039 11587  I WZS 0 + 8 [blkdiscard]
252,0    0       20    10.598670130   517  D WZS 0 + 8 [kworker/0:1H]
252,0    0       21    10.598693597     9  C WZS 0 + 8 [0]
252,0    0       22    10.604513117 11588  Q WZS IDLE 7 0 + 8 [blkdiscard]
252,0    0       23    10.604523031 11588  G WZS IDLE 7 0 + 8 [blkdiscard]
252,0    0       26    10.604535549 11588  I WZS IDLE 7 0 + 8 [blkdiscard]
252,0    0       27    10.604563234   517  D WZS IDLE 7 0 + 8 [kworker/0:1H]
252,0    0       28    10.604586205     9  C WZS IDLE 7 0 + 8 [0]

Signed-off-by: Chaitanya Kulkarni <chaitanya.kulkarni@wdc.com>
---
 blkparse_fmt.c | 76 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)
diff mbox series

Patch

diff --git a/blkparse_fmt.c b/blkparse_fmt.c
index c42e6d7..2935680 100644
--- a/blkparse_fmt.c
+++ b/blkparse_fmt.c
@@ -5,6 +5,7 @@ 
 #include <stdio.h>
 #include <string.h>
 #include <stdlib.h>
+#include <stdint.h>
 #include <unistd.h>
 #include <ctype.h>
 #include <time.h>
@@ -15,6 +16,11 @@ 
 
 #define HEADER		"%D %2c %8s %5T.%9t %5p %2a %3d "
 
+#ifdef CONFIG_BLKTRACE_EXT
+extern uint32_t blkparse_prio_mask;
+extern int bparse_track_prio;
+#endif /* CONFIG_BLKTRACE_EXT */
+
 static char *override_format[256];
 
 static inline int valid_spec(int spec)
@@ -52,6 +58,17 @@  int add_format_spec(char *option)
 
 static inline void fill_rwbs(char *rwbs, struct blk_io_trace *t)
 {
+#ifdef CONFIG_BLKTRACE_EXT
+	uint64_t w = t->action & BLK_TC_ACT(BLK_TC_WRITE);
+	uint64_t a = t->action & BLK_TC_ACT(BLK_TC_AHEAD);
+	uint64_t s = t->action & BLK_TC_ACT(BLK_TC_SYNC);
+	uint64_t m = t->action & BLK_TC_ACT(BLK_TC_META);
+	uint64_t d = t->action & BLK_TC_ACT(BLK_TC_DISCARD);
+	uint64_t f = t->action & BLK_TC_ACT(BLK_TC_FLUSH);
+	uint64_t u = t->action & BLK_TC_ACT(BLK_TC_FUA);
+	uint64_t z = t->action & BLK_TC_ACT(BLK_TC_WRITE_ZEROES);
+	uint64_t r = t->action & BLK_TC_ACT(BLK_TC_ZONE_RESET);
+#else
 	int w = t->action & BLK_TC_ACT(BLK_TC_WRITE);
 	int a = t->action & BLK_TC_ACT(BLK_TC_AHEAD);
 	int s = t->action & BLK_TC_ACT(BLK_TC_SYNC);
@@ -59,6 +76,7 @@  static inline void fill_rwbs(char *rwbs, struct blk_io_trace *t)
 	int d = t->action & BLK_TC_ACT(BLK_TC_DISCARD);
 	int f = t->action & BLK_TC_ACT(BLK_TC_FLUSH);
 	int u = t->action & BLK_TC_ACT(BLK_TC_FUA);
+#endif /* CONFIG_BLKTRACE_EXT */
 	int i = 0;
 
 	if (f)
@@ -66,6 +84,15 @@  static inline void fill_rwbs(char *rwbs, struct blk_io_trace *t)
 
 	if (d)
 		rwbs[i++] = 'D';
+#ifdef CONFIG_BLKTRACE_EXT
+	else if (z) {
+		rwbs[i++] = 'W'; /* write-zeroes */
+		rwbs[i++] = 'Z';
+	} else if (r) {
+		rwbs[i++] = 'Z'; /* zone-reset */
+		rwbs[i++] = 'R';
+	}
+#endif /* CONFIG_BLKTRACE_EXT */
 	else if (w)
 		rwbs[i++] = 'W';
 	else if (t->bytes)
@@ -311,6 +338,35 @@  static void process_default(char *act, struct per_cpu_info *pci,
 		MAJOR(t->device), MINOR(t->device), pci->cpu, t->sequence,
 		(int) SECONDS(t->time), (unsigned long) NANO_SECONDS(t->time),
 		t->pid, act, rwbs);
+#ifdef CONFIG_BLKTRACE_EXT
+	/* XXX: optimize the print format somthing like NN/RT/BT/ID */
+	if (bparse_track_prio) {
+		switch (IOPRIO_PRIO_CLASS(t->ioprio)) {
+		case IOPRIO_CLASS_NONE:
+			if (blkparse_prio_mask & 0x1)
+				fprintf(ofp, "NONE %1lu ",
+						IOPRIO_PRIO_DATA(t->ioprio));
+			break;
+		case IOPRIO_CLASS_RT:
+			if (blkparse_prio_mask & 0x2)
+				fprintf(ofp, "REAL %1lu ",
+						IOPRIO_PRIO_DATA(t->ioprio));
+			break;
+		case IOPRIO_CLASS_BE:
+			if (blkparse_prio_mask & 0x4)
+				fprintf(ofp, "BEST %1lu ",
+						IOPRIO_PRIO_DATA(t->ioprio));
+			break;
+		case IOPRIO_CLASS_IDLE:
+			if (blkparse_prio_mask & 0x8)
+				fprintf(ofp, "IDLE %1lu ",
+						IOPRIO_PRIO_DATA(t->ioprio));
+			break;
+		default:
+			fprintf(ofp, "ERRR   ");
+		}
+	}
+#endif /* CONFIG_BLKTRACE_EXT */
 
 	name = find_process_name(t->pid);
 
@@ -324,7 +380,11 @@  static void process_default(char *act, struct per_cpu_info *pci,
 			fprintf(ofp, "[%d]\n", t->error);
 		} else {
 			if (elapsed != -1ULL) {
+#ifdef CONFIG_BLKTRACE_EXT
+				if (t_sec(t) || t->sector) /* needed for ZR */
+#else
 				if (t_sec(t))
+#endif /* CONFIG_BLKTRACE_EXT */
 					fprintf(ofp, "%llu + %u (%8llu) [%d]\n",
 						(unsigned long long) t->sector,
 						t_sec(t), elapsed, t->error);
@@ -333,7 +393,11 @@  static void process_default(char *act, struct per_cpu_info *pci,
 						(unsigned long long) t->sector,
 						elapsed, t->error);
 			} else {
+#ifdef CONFIG_BLKTRACE_EXT
+				if (t_sec(t) || t->sector) /* needed for ZR */
+#else
 				if (t_sec(t))
+#endif /* CONFIG_BLKTRACE_EXT */
 					fprintf(ofp, "%llu + %u [%d]\n",
 						(unsigned long long) t->sector,
 						t_sec(t), t->error);
@@ -358,7 +422,11 @@  static void process_default(char *act, struct per_cpu_info *pci,
 			fprintf(ofp, "[%s]\n", name);
 		} else {
 			if (elapsed != -1ULL) {
+#ifdef CONFIG_BLKTRACE_EXT
 				if (t_sec(t))
+#else
+				if (t_sec(t) || t->sector) /* needed for ZR */
+#endif /* CONFIG_BLKTRACE_EXT */
 					fprintf(ofp, "%llu + %u (%8llu) [%s]\n",
 						(unsigned long long) t->sector,
 						t_sec(t), elapsed, name);
@@ -366,7 +434,11 @@  static void process_default(char *act, struct per_cpu_info *pci,
 					fprintf(ofp, "(%8llu) [%s]\n", elapsed,
 						name);
 			} else {
+#ifdef CONFIG_BLKTRACE_EXT
+				if (t_sec(t) || t->sector) /* needed for ZR */
+#else
 				if (t_sec(t))
+#endif /* CONFIG_BLKTRACE_EXT */
 					fprintf(ofp, "%llu + %u [%s]\n",
 						(unsigned long long) t->sector,
 						t_sec(t), name);
@@ -380,7 +452,11 @@  static void process_default(char *act, struct per_cpu_info *pci,
 	case 'F':	/* Front merge */
 	case 'G':	/* Get request */
 	case 'S':	/* Sleep request */
+#ifdef CONFIG_BLKTRACE_EXT
+		if (t_sec(t) || t->sector) /* needed for ZR */
+#else
 		if (t_sec(t))
+#endif /* CONFIG_BLKTRACE_EXT */
 			fprintf(ofp, "%llu + %u [%s]\n",
 				(unsigned long long) t->sector, t_sec(t), name);
 		else