From: djk <djk>
Date: Tue, 29 Jun 1999 20:56:55 +0000 (+0000)
Subject: added some anti thrash code for crossing messages
X-Git-Tag: R_1_31~24
X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=commitdiff_plain;h=dfe257a9a1412fc920c081aadc333f3c64c7b539;p=spider.git

added some anti thrash code for crossing messages
---

diff --git a/Changes b/Changes
index 68be4279..409c46ef 100644
--- a/Changes
+++ b/Changes
@@ -1,5 +1,8 @@
 29Jun99=======================================================================
 1. fixed merge command that I broke.
+2. added some randomness in waittimes for aborted outgoing messages 
+3. made the queueing of messages asymetrical. Both of these to try to 
+minimise thrashing.
 28Jun99=======================================================================
 1. console.pl now works with history and editting.
 2. added scrolling to stuff sent by the cluster.
diff --git a/perl/DXMsg.pm b/perl/DXMsg.pm
index e5fa41a8..75b88abc 100644
--- a/perl/DXMsg.pm
+++ b/perl/DXMsg.pm
@@ -134,7 +134,7 @@ sub process
 				$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;
 		}