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

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-03-04 08:22:46 -0500 (Wed, 04 Mar 2009)
New Revision: 7845

Modified:
   core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java
Log:
Better retrieve state retry loop

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-04 12:26:34 UTC (rev 7844)
+++ core/branches/flat/src/main/java/org/horizon/remoting/RPCManagerImpl.java	2009-03-04 13:22:46 UTC (rev 7845)
@@ -106,19 +106,20 @@
                      currentStateTransferSource = null;
                   }
                }
+            }
 
-               if (!success) {
-                  if (log.isWarnEnabled())
-                     log.warn("Could not find available peer for state, backing off and retrying");
+            if (!success) {
+               if (log.isWarnEnabled())
+                  log.warn("Could not find available peer for state, backing off and retrying");
 
-                  try {
-                     Thread.sleep(wait *= waitTimeIncreaseFactor);
-                  }
-                  catch (InterruptedException e) {
-                     Thread.currentThread().interrupt();
-                  }
+               try {
+                  Thread.sleep(wait *= waitTimeIncreaseFactor);
                }
+               catch (InterruptedException e) {
+                  Thread.currentThread().interrupt();
+               }
             }
+
          }
       } finally {
          currentStateTransferSource = null;