public class RWQueueRpcExecutor extends RpcExecutor
RpcExecutor.Handler, RpcExecutor.QueueBalancer
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CALL_QUEUE_READ_SHARE_CONF_KEY |
static java.lang.String |
CALL_QUEUE_SCAN_SHARE_CONF_KEY |
CALL_QUEUE_CODEL_DEFAULT_INTERVAL, CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD, CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY, CALL_QUEUE_CODEL_INTERVAL, CALL_QUEUE_CODEL_LIFO_THRESHOLD, CALL_QUEUE_CODEL_TARGET_DELAY, CALL_QUEUE_HANDLER_FACTOR_CONF_KEY, CALL_QUEUE_TYPE_CODEL_CONF_VALUE, CALL_QUEUE_TYPE_CONF_DEFAULT, CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE, CALL_QUEUE_TYPE_FIFO_CONF_VALUE, currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT, numCallQueues, QUEUE_MAX_CALL_DELAY_CONF_KEY, queues
Constructor and Description |
---|
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
Configuration conf,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
protected int |
computeNumCallQueues(int handlerCount,
float callQueuesHandlersFactor) |
boolean |
dispatch(CallRunner callTask)
Add the request to the executor queue
|
int |
getActiveHandlerCount() |
int |
getActiveReadHandlerCount() |
int |
getActiveScanHandlerCount() |
int |
getActiveWriteHandlerCount() |
int |
getReadQueueLength() |
int |
getScanQueueLength() |
int |
getWriteQueueLength() |
protected void |
startHandlers(int port) |
getBalancer, getCallQueueCountsSummary, getCallQueueSizeSummary, getHandler, getName, getNumGeneralCallsDropped, getNumLifoModeSwitches, getQueueLength, getQueues, initializeQueues, isCodelQueueType, isDeadlineQueueType, isFifoQueueType, onConfigurationChange, resizeQueues, start, startHandlers, stop
public static final java.lang.String CALL_QUEUE_READ_SHARE_CONF_KEY
public static final java.lang.String CALL_QUEUE_SCAN_SHARE_CONF_KEY
public RWQueueRpcExecutor(java.lang.String name, int handlerCount, int maxQueueLength, PriorityFunction priority, Configuration conf, Abortable abortable)
protected int computeNumCallQueues(int handlerCount, float callQueuesHandlersFactor)
computeNumCallQueues
in class RpcExecutor
protected void startHandlers(int port)
startHandlers
in class RpcExecutor
public boolean dispatch(CallRunner callTask) throws java.lang.InterruptedException
RpcExecutor
dispatch
in class RpcExecutor
java.lang.InterruptedException
public int getWriteQueueLength()
getWriteQueueLength
in class RpcExecutor
public int getReadQueueLength()
getReadQueueLength
in class RpcExecutor
public int getScanQueueLength()
getScanQueueLength
in class RpcExecutor
public int getActiveHandlerCount()
getActiveHandlerCount
in class RpcExecutor
public int getActiveWriteHandlerCount()
getActiveWriteHandlerCount
in class RpcExecutor
public int getActiveReadHandlerCount()
getActiveReadHandlerCount
in class RpcExecutor
public int getActiveScanHandlerCount()
getActiveScanHandlerCount
in class RpcExecutor