[HBASE-17661] fix the queue length passed to FastPathBalancedQueueRpcExecutor

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.4.0, 2.0.0
• Hadoop Flags: Reviewed
• Assignee: Chia-Ping Tsai
• Reporter: Chia-Ping Tsai
• Created: 18/Feb/17 11:10
• Updated: 20/Feb/17 03:40
• Resolved: 19/Feb/17 21:26

Description

SimpleRpcScheduler.java

    if (callqReadShare > 0) {
      // at least 1 read handler and 1 write handler
      callExecutor = new RWQueueRpcExecutor("deafult.RWQ", Math.max(2, handlerCount),
        maxQueueLength, priority, conf, server);
    } else {
      if (RpcExecutor.isFifoQueueType(callQueueType)) {
        callExecutor = new FastPathBalancedQueueRpcExecutor("deafult.FPBQ", handlerCount,
            maxPriorityQueueLength, priority, conf, server);
    } else {
        callExecutor = new BalancedQueueRpcExecutor("deafult.BQ", handlerCount, maxQueueLength,
            priority, conf, server);
      }
    }