HBASE-14313 After a Connection sees ConnectionClosingException it never recovers -- ADDENDUM

This commit is contained in:
Elliott Clark 2015-08-26 22:28:38 -07:00
parent fbd6ecb762
commit cc1542828d
1 changed files with 3 additions and 1 deletions

View File

@ -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();
}