You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2009/08/03 01:28:20 UTC
svn commit: r800157 - in /hadoop/hbase/trunk: CHANGES.txt
src/java/org/apache/hadoop/hbase/ipc/HBaseClient.java
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;
}
}