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

HBASE-17746 TestSimpleRpcScheduler.testCoDelScheduling is broken 

Signed-off-by: Guanghao Zhang <zghao@apache.org>
This commit is contained in:
Chia-Ping Tsai 2017-03-10 18:42:27 +08:00 committed by Guanghao Zhang
parent 4b541d6380
commit 31bc94ae60
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
View File

@ -85,7 +85,7 @@ public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObs
callExecutor = new RWQueueRpcExecutor("deafult.RWQ", Math.max(2, handlerCount), callExecutor = new RWQueueRpcExecutor("deafult.RWQ", Math.max(2, handlerCount),
maxQueueLength, priority, conf, server); maxQueueLength, priority, conf, server);
} else { } else {
if (RpcExecutor.isFifoQueueType(callQueueType)) { if (RpcExecutor.isFifoQueueType(callQueueType) || RpcExecutor.isCodelQueueType(callQueueType)) {
callExecutor = new FastPathBalancedQueueRpcExecutor("deafult.FPBQ", handlerCount, callExecutor = new FastPathBalancedQueueRpcExecutor("deafult.FPBQ", handlerCount,
maxQueueLength, priority, conf, server); maxQueueLength, priority, conf, server);
} else { } else {

3
hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java
View File

@ -434,8 +434,7 @@ public class TestSimpleRpcScheduler {/*
@Test @Test
public void testCoDelScheduling() throws Exception { public void testCoDelScheduling() throws Exception {
CoDelEnvironmentEdge envEdge = new CoDelEnvironmentEdge(); CoDelEnvironmentEdge envEdge = new CoDelEnvironmentEdge();
envEdge.threadNamePrefixs.add("RpcServer.CodelFPBQ.default.handler"); envEdge.threadNamePrefixs.add("RpcServer.deafult.FPBQ.Codel.handler");
envEdge.threadNamePrefixs.add("RpcServer.CodelRWQ.default.handler");
Configuration schedConf = HBaseConfiguration.create(); Configuration schedConf = HBaseConfiguration.create();
schedConf.setInt(RpcScheduler.IPC_SERVER_MAX_CALLQUEUE_LENGTH, 250); schedConf.setInt(RpcScheduler.IPC_SERVER_MAX_CALLQUEUE_LENGTH, 250);
schedConf.set(RpcExecutor.CALL_QUEUE_TYPE_CONF_KEY, schedConf.set(RpcExecutor.CALL_QUEUE_TYPE_CONF_KEY,