X-Git-Url: http://www.dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXMsg.pm;h=f136b16e7b23750192b817f27055caf0592e8fef;hb=77fd72a34c14013dcb9430408e83cb30581f7cc2;hp=2cdb6a8028a15bb2d11e4ae27a1755b1e23e15d1;hpb=6624dcdf07d628e8d6a16fc6549edf40be25b7b2;p=spider.git diff --git a/perl/DXMsg.pm b/perl/DXMsg.pm index 2cdb6a80..f136b16e 100644 --- a/perl/DXMsg.pm +++ b/perl/DXMsg.pm @@ -165,10 +165,11 @@ sub process # first look for any messages in the busy queue # and cancel them this should both resolve timed out incoming messages # and crossing of message between nodes, incoming messages have priority + if (exists $busy{$fromnode}) { my $ref = $busy{$fromnode}; my $tonode = $ref->{tonode}; - dbg("Busy, stopping msgno: $ref->{msgno} -> $fromnode") if isdbg('msg'); + dbg("Busy, stopping msgno: $ref->{msgno} $fromnode->$tonode") if isdbg('msg'); $ref->stop_msg($self->call); }