You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ji...@apache.org on 2008/04/01 22:32:06 UTC

svn commit: r643555 - in /hadoop/hbase/branches/0.1: CHANGES.txt src/java/org/apache/hadoop/hbase/HMaster.java

Author: jimk
Date: Tue Apr  1 13:32:02 2008
New Revision: 643555

URL: http://svn.apache.org/viewvc?rev=643555&view=rev
Log:
HBASE-507   Add sleep between retries

Modified:
    hadoop/hbase/branches/0.1/CHANGES.txt
    hadoop/hbase/branches/0.1/src/java/org/apache/hadoop/hbase/HMaster.java

Modified: hadoop/hbase/branches/0.1/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.1/CHANGES.txt?rev=643555&r1=643554&r2=643555&view=diff
==============================================================================
--- hadoop/hbase/branches/0.1/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.1/CHANGES.txt Tue Apr  1 13:32:02 2008
@@ -7,6 +7,7 @@
    HBASE-505   Region assignments should never time out so long as the region
                server reports that it is processing the open request
    HBASE-552   Fix bloom filter bugs (Andrzej Bialecki via Jim Kellerman)
+   HBASE-507   Add sleep between retries
 
   NEW FEATURES
    HBASE-548   Tool to online single region

Modified: hadoop/hbase/branches/0.1/src/java/org/apache/hadoop/hbase/HMaster.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.1/src/java/org/apache/hadoop/hbase/HMaster.java?rev=643555&r1=643554&r2=643555&view=diff
==============================================================================
--- hadoop/hbase/branches/0.1/src/java/org/apache/hadoop/hbase/HMaster.java (original)
+++ hadoop/hbase/branches/0.1/src/java/org/apache/hadoop/hbase/HMaster.java Tue Apr  1 13:32:02 2008
@@ -2212,6 +2212,7 @@
               throw RemoteExceptionHandler.checkIOException(e);
             }
           }
+          sleeper.sleep();
         }
         if (LOG.isDebugEnabled()) {
           LOG.debug("process server shutdown scanning root region on " +
@@ -2268,6 +2269,7 @@
             throw RemoteExceptionHandler.checkIOException(e);
           }
         }
+        sleeper.sleep();
       }
       return true;
     }
@@ -2404,8 +2406,8 @@
           if (tries == numRetries - 1) {
             throw RemoteExceptionHandler.checkIOException(e);
           }
-          continue;
         }
+        sleeper.sleep();
       }
 
       if (reassignRegion) {
@@ -2511,6 +2513,7 @@
             throw RemoteExceptionHandler.checkIOException(e);
           }
         }
+        sleeper.sleep();
       }
       return true;
     }
@@ -2556,6 +2559,7 @@
           throw RemoteExceptionHandler.checkIOException(e);
         }
       }
+      sleeper.sleep();
     }
   }
 
@@ -2802,6 +2806,7 @@
             checkFileSystem();
             throw RemoteExceptionHandler.checkIOException(e);
           }
+          sleeper.sleep();
           continue;
         }
         break;