[jbosscache-commits] JBoss Cache SVN: r7966 - core/trunk/src/main/java/org/jboss/cache.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-04-02 05:55:56 -0400 (Thu, 02 Apr 2009)
New Revision: 7966

Modified:
   core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java
Log:
Added degree of randomization in wait times between state transfer retries

Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java	2009-04-02 09:46:44 UTC (rev 7965)
+++ core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java	2009-04-02 09:55:56 UTC (rev 7966)
@@ -76,6 +76,7 @@
 import java.util.HashSet;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Random;
 import java.util.Set;
 import java.util.Vector;
 import java.util.concurrent.TimeUnit;
@@ -393,8 +394,9 @@
          return;
       }
       boolean success = false;
-      int numRetries = 2; // should be 5
-      int initwait = 100; // should be 1000
+      int numRetries = 5;
+      int initwait = (1 + new Random().nextInt(10)) * 100;
+      int waitIncreaseFactor = 2;
 
       outer:
       for (int i = 0, wait = initwait; i < numRetries; i++)
@@ -424,7 +426,7 @@
 
          if (!success)
          {
-            wait <<= 2;
+            wait *= waitIncreaseFactor;
             if (log.isWarnEnabled())
             {
                log.warn("Could not find available peer for state, backing off and retrying after " + wait + " millis.  Retries left: " + (numRetries - 1 - i));