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:55 UTC
[2/2] hbase git commit: HBASE-14313 After a Connection sees
ConnectionClosingException it never recovers -- ADDENDUM
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/ab47cb95
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ab47cb95
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ab47cb95
Branch: refs/heads/branch-1
Commit: ab47cb956992463e632d1e13fbeef31c038b184c
Parents: 886542b
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:24:15 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/ab47cb95/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();
}