From 68bc9fd4fbaf86e994542135b2739177774ddcd0 Mon Sep 17 00:00:00 2001 From: Esteban Gutierrez Date: Fri, 15 May 2015 00:57:15 -0700 Subject: [PATCH] HBASE-13694 CallQueueSize is incorrectly decremented until the response is sent --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java index fd4de3a..2af92c2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java @@ -116,6 +116,7 @@ public class CallRunner { traceScope.close(); } RpcServer.CurCall.set(null); + this.rpcServer.addCallSize(call.getSize() * -1); } // Set the response for undelayed calls and delayed calls with // undelayed responses. @@ -146,8 +147,6 @@ public class CallRunner { RpcServer.LOG.warn(Thread.currentThread().getName() + ": caught: " + StringUtils.stringifyException(e)); } finally { - // regardless if successful or not we need to reset the callQueueSize - this.rpcServer.addCallSize(call.getSize() * -1); cleanup(); } } -- 2.4.0