[jbosscache-commits] JBoss Cache SVN: r7832 - core/branches/flat/src/main/java/org/horizon/remoting.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-03-03 12:07:33 -0500 (Tue, 03 Mar 2009)
New Revision: 7832

Modified:
   core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java
Log:
Better waits between attempts

Modified: core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java
===================================================================
--- core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java	2009-03-03 17:02:14 UTC (rev 7831)
+++ core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java	2009-03-03 17:07:33 UTC (rev 7832)
@@ -73,6 +73,10 @@
    }
 
    public void retrieveState(String cacheName, long timeout) throws StateTransferException {
+      // TODO make these configurable
+      int initialWaitTime = 1000; // millis
+      int waitTimeIncreaseFactor = 2;
+      int numRetries = 3;
       List<Address> members = t.getMembers();
       if (members.size() < 2) {
          if (log.isDebugEnabled())
@@ -85,7 +89,7 @@
       try {
 
          outer:
-         for (int i = 0, wait = 1000; i < 5; i++) {
+         for (int i = 0, wait = initialWaitTime; i < numRetries; i++) {
             for (Address member : members) {
                if (!member.equals(t.getAddress())) {
                   try {
@@ -108,7 +112,7 @@
                      log.warn("Could not find available peer for state, backing off and retrying");
 
                   try {
-                     Thread.sleep(wait <<= 2);
+                     Thread.sleep(wait *= waitTimeIncreaseFactor);
                   }
                   catch (InterruptedException e) {
                      Thread.currentThread().interrupt();