hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r800157 - in /hadoop/hbase/trunk: CHANGES.txt src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java
Date Sun, 02 Aug 2009 23:28:20 GMT
Author: stack
Date: Sun Aug  2 23:28:20 2009
New Revision: 800157

URL: http://svn.apache.org/viewvc?rev=800157&view=rev
Log:
HBASE-1604 HBaseClient.getConnection() may return a broken connection without throwing an
exception

Modified:
    hadoop/hbase/trunk/CHANGES.txt
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java

Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=800157&r1=800156&r2=800157&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Sun Aug  2 23:28:20 2009
@@ -310,6 +310,8 @@
                (Doğacan Güney via Stack)
    HBASE-1732  Flag to disable regionserver restart
    HBASE-1727  HTD and HCD versions need update
+   HBASE-1604  HBaseClient.getConnection() may return a broken connection
+               without throwing an exception (Eugene Kirpichov via Stack)
 
   IMPROVEMENTS
    HBASE-1089  Add count of regions on filesystem to master UI; add percentage

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java?rev=800157&r1=800156&r2=800157&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java Sun Aug  2 23:28:20
2009
@@ -286,7 +286,7 @@
      * a header to the server and starts
      * the connection thread that waits for responses.
      */
-    protected synchronized void setupIOstreams() {
+    protected synchronized void setupIOstreams() throws IOException {
       if (socket != null || shouldCloseConnection.get()) {
         return;
       }
@@ -328,6 +328,8 @@
       } catch (IOException e) {
         markClosed(e);
         close();
+
+        throw e;
       }
     }
 



Mime
View raw message