From 47b36e33051c2bfd43b9a9608a1f3d7b6f4ca002 Mon Sep 17 00:00:00 2001 From: Biju Nair Date: Sun, 12 May 2019 18:47:07 -0400 Subject: [PATCH] HBASE-22402 Remove unused method parameters in RWQueueRpcExecutor --- .../org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java index 7187a71195..560e5e2849 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java @@ -131,9 +131,9 @@ public class RWQueueRpcExecutor extends RpcExecutor { public boolean dispatch(final CallRunner callTask) throws InterruptedException { RpcCall call = callTask.getRpcCall(); int queueIndex; - if (isWriteRequest(call.getHeader(), call.getParam())) { + if (isWriteRequest(call.getParam())) { queueIndex = writeBalancer.getNextQueue(); - } else if (numScanQueues > 0 && isScanRequest(call.getHeader(), call.getParam())) { + } else if (numScanQueues > 0 && isScanRequest(call.getParam())) { queueIndex = numWriteQueues + numReadQueues + scanBalancer.getNextQueue(); } else { queueIndex = numWriteQueues + readBalancer.getNextQueue(); @@ -195,7 +195,7 @@ public class RWQueueRpcExecutor extends RpcExecutor { return activeScanHandlerCount.get(); } - private boolean isWriteRequest(final RequestHeader header, final Message param) { + private boolean isWriteRequest(final Message param) { // TODO: Is there a better way to do this? if (param instanceof MultiRequest) { MultiRequest multi = (MultiRequest)param; @@ -228,7 +228,7 @@ public class RWQueueRpcExecutor extends RpcExecutor { return false; } - private boolean isScanRequest(final RequestHeader header, final Message param) { + private boolean isScanRequest(final Message param) { if (param instanceof ScanRequest) { // The first scan request will be executed as a "short read" ScanRequest request = (ScanRequest)param; -- 2.20.1 (Apple Git-117)