You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ec...@apache.org on 2015/08/28 00:25:47 UTC
hbase git commit: HBASE-14313 After a Connection sees
ConnectionClosingException it never recovers -- ADDENDUM
Repository: hbase
Updated Branches:
refs/heads/master fbd6ecb76 -> cc1542828
HBASE-14313 After a Connection sees ConnectionClosingException it never recovers -- ADDENDUM
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cc154282
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cc154282
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cc154282
Branch: refs/heads/master
Commit: cc1542828de93b8d54cc14497fd5937989ea1b6d
Parents: fbd6ecb
Author: Elliott Clark <ec...@apache.org>
Authored: Wed Aug 26 22:28:38 2015 -0700
Committer: Elliott Clark <ec...@apache.org>
Committed: Thu Aug 27 15:23:43 2015 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/cc154282/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java
index 6647615..c11273e 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java
@@ -939,7 +939,9 @@ public class RpcClientImpl extends AbstractRpcClient {
} catch (IOException e) {
// We set the value inside the synchronized block, this way the next in line
// won't even try to write
- markClosed(e);
+ if (markClosed(e)) {
+ close();
+ }
writeException = e;
interrupt();
}