script: check_osd_request_latency

1 files changed, 46 insertions, 0 deletions

diff --git a/src/script/check_osd_request_latency.pl b/src/script/check_osd_request_latency.pl
new file mode 100755
index 00000000000..63f750fbc3a
--- /dev/null
+++ b/src/script/check_osd_request_latency.pl
@@ -0,0 +1,46 @@
+#!/usr/bin/perl
+
+use strict;
+
+my %r;      # reqid -> start
+my %lat_req;  # latency -> request
+
+sub tosec($) {
+    my $v = shift;
+    my ($h, $m, $s) = split(/:/, $v);
+    my $r = $s + 60 * ($m + (60 * $h));
+    #print "$v = $h  $m  $s = $r\n";
+    return $r;
+}
+
+while (<>) {
+    chomp;
+    my ($stamp) = /^\S+ (\S+) /;
+
+    my ($who,$tid) = /osd\d+ <.. (\D+\d+) \S+ \S+ osd_op\(\S+:(\d+)/;
+    if (defined $tid) {
+	my $req = "$who:$tid";
+	$r{$req} = $stamp unless exists $r{$req};
+	next;
+    }
+
+    my ($who,$tid) = /\d+ -- \S+ osd\d+ --> (\D+\d+) \S+ \S+ osd_op_reply\((\d+)/;
+    if (defined $tid) {
+	my $req = "$who:$tid";
+	if (exists $r{$req}) {
+	    my $len = tosec($stamp) - tosec($r{$req});
+	    
+	    #print "$req $len ($r{$req} - $stamp)\n";
+	    $lat_req{$len} = $req;
+	    
+	    delete $r{$req};
+	}
+	next;
+    }
+    
+}
+
+
+for my $len (sort {$b <=> $a} keys %lat_req) {
+    print "$len\t$lat_req{$len}\n";    
+}