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:54 UTC
[1/2] hbase git commit: HBASE-14313 After a Connection sees
ConnectionClosingException on a connection it never recovers
Repository: hbase
Updated Branches:
refs/heads/branch-1 b8c7a08a9 -> ab47cb956
HBASE-14313 After a Connection sees ConnectionClosingException on a connection it never recovers
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/886542bd
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/886542bd
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/886542bd
Branch: refs/heads/branch-1
Commit: 886542bd1b3ebbff333d40920ac56e245feee357
Parents: b8c7a08
Author: Elliott Clark <ec...@apache.org>
Authored: Tue Aug 25 18:39:31 2015 -0700
Committer: Elliott Clark <ec...@apache.org>
Committed: Thu Aug 27 15:24:10 2015 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/886542bd/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 5ece8ae..6647615 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,7 @@ 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
- shouldCloseConnection.set(true);
+ markClosed(e);
writeException = e;
interrupt();
}
[2/2] hbase git commit: HBASE-14313 After a Connection sees
ConnectionClosingException it never recovers -- ADDENDUM
Posted by ec...@apache.org.
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();
}