hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ecl...@apache.org
Subject hbase git commit: HBASE-14313 After a Connection sees ConnectionClosingException it never recovers -- ADDENDUM
Date Thu, 27 Aug 2015 22:26:03 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 430f31ff4 -> ab27fe020


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/ab27fe02
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ab27fe02
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ab27fe02

Branch: refs/heads/branch-1.2
Commit: ab27fe02006abb11aedbe66577e7369799a4ef45
Parents: 430f31f
Author: Elliott Clark <eclark@apache.org>
Authored: Wed Aug 26 22:28:38 2015 -0700
Committer: Elliott Clark <eclark@apache.org>
Committed: Thu Aug 27 15:22:19 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/ab27fe02/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();
         }


Mime
View raw message