merge b_md onto HEAD. as best as I can remember:

[fs/lustre-release.git] / lustre / utils / llanalyze

diff --git a/lustre/utils/llanalyze b/lustre/utils/llanalyze
index e3e21d6..3061b26 100644 (file)
--- a/lustre/utils/llanalyze
+++ b/lustre/utils/llanalyze
@@ -1,13 +1,19 @@
 #!/usr/bin/perl
 
 use Getopt::Long;
+use Term::ANSIColor;
+
 GetOptions("pid=i" => \$pid, 
            "trace!" => \$trace, 
+           "silent!" => \$silent, 
+           "rpctrace!" => \$rpctrace, 
            "nodlm!" => \$nodlm,
+           "noclass!" => \$noclass,
            "nonet!" => \$nonet);
 
 print "pid: $pid, nodlm $nodlm nonet $nonet trace $trace\n";
 
+
 $subsys->{UNDEFINED} = 0;
 $subsys->{MDC} = 1;
 $subsys->{MDS} = 2;
@@ -51,8 +57,7 @@ $masks->{DLMTRACE} = 1 << 16; #
 $masks->{ERROR} = 1 << 17; # /* CERROR} = ...) == CDEBUG} = D_ERROR, ...) */
 $masks->{EMERG} = 1 << 18; # /* CEMERG} = ...) == CDEBUG} = D_EMERG, ...) */
 $masks->{HA} = 1 << 19; # /* recovery and failover */
-
-
+$masks->{RPCTRACE} = 1 << 19; # /* recovery and failover */
 
 sub extractpid
 {
@@ -86,6 +91,122 @@ sub getmask
     return hex($mask);
 }
 
+sub setcolor
+{
+    my $linemask = shift;
+    if ($linemask == $masks->{TRACE}) {
+        print color("yellow on_black");
+    }
+    if ($linemask == $masks->{DLMTRACE}) {
+        print color("magenta on_black");
+    }
+    if ($linemask == $masks->{DLM}) {
+        print color("magenta on_black");
+    }
+    if ($linemask == $masks->{DENTRY}) {
+        print color("red on_black");
+    }
+}
+
+sub study_lock
+{
+    $_ = shift;
+    my $rc;
+
+    $rc = /completion callback handler START ns: (.*) lock: (.*) lrc: (.*) mode/;
+    if ($rc) {
+        $completion_callbacks{$1}->{$2} = $3;
+#         print color("white");
+#         print "---CP CB START: $1 $2 $3\n";
+#         print color("reset");
+    }
+    $rc = /callback handler finished.* ns: (.*) lock: (.*) lrc: (.*) mode/;
+    if ($rc) {
+#         print color("white");
+#         print "---CP CB END: $1 $2 $3 deleting $completion_callbacks{$1}->{$2}\n";
+#         print color("reset");
+        delete $completion_callbacks{$1}->{$2};
+    }
+
+    if ($rc) {
+        $rc = /client blocking AST callback handler START ns: (.*) lock: (.*) lrc: (.*) mode/;
+        $blocking_callbacks{$1}->{$2} = $3;
+#         print color("white");
+#         print "---BL CB START: $1 $2\n";
+#         print color("reset");
+    }
+    $rc = /client blocking callback handler END ns: (.*) lock: (.*) lrc: (.*) mode/;
+    if ($rc) {
+#         print color("white");
+#         print "---BL CB END: $1 $2 $3 deleting $blocking_callbacks{$1}->{$2}\n";
+#         print color("reset");
+        delete $blocking_callbacks{$1}->{$2};
+    }
+
+    $rc = /ldlm_lock_addref.*ns: (.*) lock: (.*) lrc: (.*) mode/;
+#     print color("white");
+#     print "------>addref ns: $1 lock: $2 lrc: $3\n" if ($rc);
+#     print color("reset");
+    $locks{$1}->{$2} = {$3} if ($rc);
+    $rc = /ldlm_lock_decref.*ns: (.*) lock: (.*) lrc: (.*) mode/;
+#     print color("white");
+#     print "------>decref ns: $1 lock: $2 lrc: $3\n" if ($rc);
+#     print color("reset");
+    $locks{$1}->{$2} = {$3} if ($rc);
+}
+
+sub hanging_locks 
+{
+    my $found; 
+    my $ns;
+
+    foreach (keys %completion_callbacks) {
+        $ns = $_;
+        $found = 0;
+        foreach (keys %{$completion_callbacks{$ns}}) {
+            if (!$found) {
+                print "Unfinished completions in ns $ns: \n";
+                $found =1;
+            }
+            print "  lock: $_ lrc: $completion_callbacks{$ns}->{$_}\n";
+        }
+    }
+    foreach (keys %blocking_callbacks) {
+        $ns = $_;
+        $found = 0;
+        foreach (keys %{$blocking_callbacks{$ns}}) {
+            if (!$found) {
+                print "Unfinished blocking in ns $ns: \n";
+                $found =1;
+            }
+            printf("  lock: $_ lrc: %s\n", $blocking_callbacks{$ns}->{$_});
+        }
+    }
+
+}
+
+sub study_intent 
+{
+    $_ = shift;
+    my $rc;
+
+    $rc = /D_IT UP dentry (.*) fsdata/;
+    delete $it{$1} if ($rc);
+    $rc = /D_IT DOWN dentry (.*) fsdata/;
+    $it{$1} = "yes"  if ($rc);
+}
+
+sub unmatched_intents { 
+    my $found;
+    foreach (keys %it) {
+        if (!$found) {
+            print "Unmatched intents: \n";
+            $found =1;
+        }
+        print "  $_\n";
+    }
+}
+
 while (<STDIN>) {
     $linepid = extractpid($_);
     $linemask = getmask($_);
@@ -97,10 +218,24 @@ while (<STDIN>) {
         chop $prefix->{$linepid};
         chop $prefix->{$linepid};
     }
+
+    if ($linemask == $masks->{DENTRY}) {
+        study_intent($_);
+    }
+    if ($linemask == $masks->{DLMTRACE}) {
+        study_lock($_);
+    }
+
     if ( !$pid || $linepid == $pid) {
+        next if ($rpctrace && $linemask != $masks->{RPCTRACE});
         next if ($trace && $linemask != $masks->{TRACE});
+
+
         next if ($nodlm && 
                  (  $linesubsys == $subsys->{LDLM}));
+        next if ($noclass && 
+                 (  $linesubsys == $subsys->{CLASS}));
+
         next if ($nonet && 
                  (  $linesubsys == $subsys->{RPC} ||
                     $linesubsys == $subsys->{NET} ||
@@ -109,14 +244,21 @@ while (<STDIN>) {
                     $linesubsys == $subsys->{QSWNAL} ||
                     $linesubsys == $subsys->{GMNAL}));
 
-#        printf "sub/mask: %s - %s\n", getsubsys($_), getmask($_);
 
-        printf "%s%s", $prefix->{$linepid}, $_;
-        last if $count++ > 100;
+#        printf "sub/mask: %s - %s\n", getsubsys($_), getmask($_);
+        if (!$silent) { 
+            setcolor($linemask);
+            printf("%s%s", $prefix->{$linepid}, $_);
+            print color("reset");
+        }
+            #        last if $count++ > 100;
     }
     if (entering($_)) {
         $prefix->{$linepid} .= '  ';
     } 
 }
 
+
+unmatched_intents();
+hanging_locks();
 # printf "argv %s pid %d\n", $ARGV[0], extractpid($ARGV[0]);