projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
rejigged and made certain things clearer
[spider.git]
/
cmd
/
stat
/
msg.pl
diff --git
a/cmd/stat/msg.pl
b/cmd/stat/msg.pl
index 2b7ed7525c566c3635eb59134dd4c088af02ff46..2b937d81f1db2633e5bb51310a5fde04afe1c6fe 100644
(file)
--- a/
cmd/stat/msg.pl
+++ b/
cmd/stat/msg.pl
@@
-15,15
+15,19
@@
if (@list == 0) {
push @out, "Work Queue Keys";
push @out, map { " $_" } sort keys %DXMsg::work;
push @out, "Busy Queue Data";
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 $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 $count = $ref->count;
+ my $to = $ref->to;
+ my $from = $ref->from;
my $lastt = $ref->lastt ? " Last Processed: " . cldatetime($ref->lastt) : "";
my $waitt = $ref->waitt ? " Waiting since: " . cldatetime($ref->waitt) : "";
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, "
$from -> $to
msg: $msgno stream: $stream Count: $count Lines: $lines$lastt$waitt";
}
} else {
foreach my $msgno (@list) {
}
} else {
foreach my $msgno (@list) {