Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11705 callQueueSize should be decremented in a fail-fast scenario (Esteban Gutierrez)

This commit is contained in:
Andrew Purtell 2014-08-08 18:41:18 -07:00
parent 3c03dcb1b9
commit c2bfc64719
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
View File

@ -110,7 +110,6 @@ public class CallRunner {
RequestContext.clear(); RequestContext.clear();
} }
RpcServer.CurCall.set(null); RpcServer.CurCall.set(null);
this.rpcServer.addCallSize(call.getSize() * -1);
// Set the response for undelayed calls and delayed calls with // Set the response for undelayed calls and delayed calls with
// undelayed responses. // undelayed responses.
if (!call.isDelayed() || !call.isReturnValueDelayed()) { if (!call.isDelayed() || !call.isReturnValueDelayed()) {
@ -139,6 +138,9 @@ public class CallRunner {
} catch (Exception e) { } catch (Exception e) {
RpcServer.LOG.warn(Thread.currentThread().getName() RpcServer.LOG.warn(Thread.currentThread().getName()
+ ": caught: " + StringUtils.stringifyException(e)); + ": caught: " + StringUtils.stringifyException(e));
} finally {
// regardless if succesful or not we need to reset the callQueueSize
this.rpcServer.addCallSize(call.getSize() * -1);
} }
} }