X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=cmd%2Fstat%2Fmsg.pl;fp=cmd%2Fstat%2Fmsg.pl;h=da4a726248cab01d9825682e2622bdab4d53e272;hb=6624dcdf07d628e8d6a16fc6549edf40be25b7b2;hp=2b7ed7525c566c3635eb59134dd4c088af02ff46;hpb=ca8e84c32e70ea8eb1f30e716b7dbdc92f7e5083;p=spider.git diff --git a/cmd/stat/msg.pl b/cmd/stat/msg.pl index 2b7ed752..da4a7262 100644 --- a/cmd/stat/msg.pl +++ b/cmd/stat/msg.pl @@ -15,15 +15,18 @@ if (@list == 0) { push @out, "Work Queue Keys"; push @out, map { " $_" } sort keys %DXMsg::work; push @out, "Busy Queue Data"; - foreach $ref (sort {$a->call cmp $b->call} DXMsg::get_all_busy) { + foreach $ref (sort {$a->to cmp $b->to} DXMsg::get_all_busy) { my $msgno = $ref->msgno; my $stream = $ref->stream; - my $lines = scalar $ref->lines; + my $lref = $ref->lines; + my $lines = 0; + $lines = @$lref if $lref; my $count = $ref->count; + my $to = $ref->to; my $lastt = $ref->lastt ? " Last Processed: " . cldatetime($ref->lastt) : ""; my $waitt = $ref->waitt ? " Waiting since: " . cldatetime($ref->waitt) : ""; - push @out, " $call -> msg: $msgno stream: $stream Count: $count Lines: $lines$lastt$waitt"; + push @out, " $call -> $to msg: $msgno stream: $stream Count: $count Lines: $lines$lastt$waitt"; } } else { foreach my $msgno (@list) {