From: minima <minima>
Date: Tue, 2 Oct 2001 14:12:26 +0000 (+0000)
Subject: fix this for the new interface
X-Git-Tag: R_1_49~84
X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=commitdiff_plain;h=bdaffbb7128f585525f07419d6025ce7663816bf;p=spider.git

fix this for the new interface
---

diff --git a/cmd/stat/msg.pl b/cmd/stat/msg.pl
index 57eccca4..dfacd062 100644
--- a/cmd/stat/msg.pl
+++ b/cmd/stat/msg.pl
@@ -15,20 +15,24 @@ if (@list == 0) {
 	push @out, "Work Queue Keys";
 	push @out, map { " $_" } sort DXMsg::get_all_fwq();
 	push @out, "Busy Queue Data";
-	foreach $ref (sort {$a->to cmp $b->to} DXMsg::get_all_busy) {
-		my $msgno = $ref->msgno;
-		my $stream = $ref->stream;
-		my $lref = $ref->lines;
-		my $lines = 0;
-		$lines = @$lref if $lref;
-		my $count = $ref->count;
-		my $to = $ref->to;
-		my $from = $ref->from;
-		my $tonode = $ref->tonode;
-		my $lastt = $ref->lastt ? " Last Processed: " . cldatetime($ref->lastt) : "";
-		my $waitt = $ref->waitt ? " Waiting since: " . cldatetime($ref->waitt) : "";
-		
-		push @out, " $tonode: $from -> $to msg: $msgno stream: $stream Count: $count Lines: $lines$lastt$waitt";
+	foreach my $key (sort DXMsg::get_all_busy()) {
+		$ref = DXMsg::get_busy($key);
+		if ($ref) {
+			my $msgno = $ref->msgno;
+			my $stream = $ref->stream;
+			my $lref = $ref->lines;
+			my $lines = 0;
+			$lines = @$lref if $lref;
+			my $count = $ref->count;
+			my $to = $ref->to;
+			my $from = $ref->from;
+			my $tonode = $ref->tonode;
+			my $lastt = $ref->lastt ? " Last Processed: " . cldatetime($ref->lastt) : "";
+			my $waitt = $ref->waitt ? " Waiting since: " . cldatetime($ref->waitt) : "";
+			push @out, " $key/$tonode: $from -> $to msg: $msgno stream: $stream Count: $count Lines: $lines$lastt$waitt"
+		} else {
+			push @out, " dangling ref for $key";
+		}
 	}
 } else {
 	foreach my $msgno (@list) {