X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXMsg.pm;h=75b88abc8e450f3fb4934bd0dcae5e14cda262a0;hb=dfe257a9a1412fc920c081aadc333f3c64c7b539;hp=146392f44f970a83eb269167c1590a29b71cb414;hpb=3eb722692c2c1e9de84752391d5b6330e062c7e6;p=spider.git

diff --git a/perl/DXMsg.pm b/perl/DXMsg.pm
index 146392f4..75b88abc 100644
--- a/perl/DXMsg.pm
+++ b/perl/DXMsg.pm
@@ -130,11 +130,11 @@ sub process
 		for (keys %busy) {
 			my $node = $_;
 			my $ref = $busy{$_};
-			if ($main::systime > $ref->{lastt} + $timeout) {
+			if (exists $ref->{lastt} && $main::systime > $ref->{lastt} + $timeout) {
 				$ref->stop_msg($node);
 
 				# delay any outgoing messages that fail
-				$ref->{waitt} = $main::systime + $waittime if $node ne $main::mycall;
+				$ref->{waitt} = $main::systime + $waittime + rand(120) if $node ne $main::mycall;
 			}
 		}
 		
@@ -273,7 +273,7 @@ sub process
 			} else {
 				$self->send(DXProt::pc42($f[2], $f[1], $f[3]));	# unknown stream
 			}
-			queue_msg(0);
+			# queue_msg(0);
 			last SWITCH;
 		}