added some anti thrash code for crossing messages
[spider.git] / perl / DXMsg.pm
index e5fa41a8f3bce122e574f0728660d31899875fe9..75b88abc8e450f3fb4934bd0dcae5e14cda262a0 100644 (file)
@@ -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;
                }