@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class SimpleRpcScheduler extends RpcScheduler implements ConfigurationObserver
RpcScheduler.Context
Modifier and Type | Field and Description |
---|---|
static int |
CALL_QUEUE_CODEL_DEFAULT_INTERVAL |
static double |
CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD |
static int |
CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY |
static java.lang.String |
CALL_QUEUE_CODEL_INTERVAL |
static java.lang.String |
CALL_QUEUE_CODEL_LIFO_THRESHOLD |
static java.lang.String |
CALL_QUEUE_CODEL_TARGET_DELAY |
static java.lang.String |
CALL_QUEUE_HANDLER_FACTOR_CONF_KEY |
static java.lang.String |
CALL_QUEUE_READ_SHARE_CONF_KEY |
static java.lang.String |
CALL_QUEUE_SCAN_SHARE_CONF_KEY |
static java.lang.String |
CALL_QUEUE_TYPE_CODEL_CONF_VALUE |
static java.lang.String |
CALL_QUEUE_TYPE_CONF_DEFAULT |
static java.lang.String |
CALL_QUEUE_TYPE_CONF_KEY
The default, 'fifo', has the least friction but is dumb.
|
static java.lang.String |
CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE |
static java.lang.String |
CALL_QUEUE_TYPE_FIFO_CONF_VALUE |
static Log |
LOG |
static java.lang.String |
QUEUE_MAX_CALL_DELAY_CONF_KEY
max delay in msec used to bound the deprioritized requests
|
IPC_SERVER_MAX_CALLQUEUE_LENGTH, IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH
Constructor and Description |
---|
SimpleRpcScheduler(Configuration conf,
int handlerCount,
int priorityHandlerCount,
int replicationHandlerCount,
PriorityFunction priority,
Abortable server,
int highPriorityLevel) |
SimpleRpcScheduler(Configuration conf,
int handlerCount,
int priorityHandlerCount,
int replicationHandlerCount,
PriorityFunction priority,
int highPriorityLevel) |
Modifier and Type | Method and Description |
---|---|
boolean |
dispatch(CallRunner callTask)
Dispatches an RPC request asynchronously.
|
int |
getActiveRpcHandlerCount()
Retrieves the number of active handler.
|
int |
getGeneralQueueLength()
Retrieves length of the general queue for metrics.
|
long |
getNumGeneralCallsDropped()
If CoDel-based RPC executors are used, retrieves the number of Calls that were dropped
from general queue because RPC executor is under high load; returns 0 otherwise.
|
long |
getNumLifoModeSwitches()
If CoDel-based RPC executors are used, retrieves the number of Calls that were
picked from the tail of the queue (indicating adaptive LIFO mode, when
in the period of overloade we serve last requests first); returns 0 otherwise.
|
int |
getPriorityQueueLength()
Retrieves length of the priority queue for metrics.
|
int |
getReplicationQueueLength()
Retrieves length of the replication queue for metrics.
|
void |
init(RpcScheduler.Context context)
Does some quick initialization.
|
void |
onConfigurationChange(Configuration conf)
Resize call queues;
|
void |
start()
Prepares for request serving.
|
void |
stop()
Stops serving new requests.
|
public static final Log LOG
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 static final java.lang.String CALL_QUEUE_HANDLER_FACTOR_CONF_KEY
public static final java.lang.String CALL_QUEUE_TYPE_CONF_KEY
public static final java.lang.String CALL_QUEUE_TYPE_CODEL_CONF_VALUE
public static final java.lang.String CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE
public static final java.lang.String CALL_QUEUE_TYPE_FIFO_CONF_VALUE
public static final java.lang.String CALL_QUEUE_TYPE_CONF_DEFAULT
public static final java.lang.String QUEUE_MAX_CALL_DELAY_CONF_KEY
public static final java.lang.String CALL_QUEUE_CODEL_TARGET_DELAY
public static final java.lang.String CALL_QUEUE_CODEL_INTERVAL
public static final java.lang.String CALL_QUEUE_CODEL_LIFO_THRESHOLD
public static final int CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY
public static final int CALL_QUEUE_CODEL_DEFAULT_INTERVAL
public static final double CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD
public SimpleRpcScheduler(Configuration conf, int handlerCount, int priorityHandlerCount, int replicationHandlerCount, PriorityFunction priority, Abortable server, int highPriorityLevel)
conf
- handlerCount
- the number of handler threads that will be used to process callspriorityHandlerCount
- How many threads for priority handling.replicationHandlerCount
- How many threads for replication handling.highPriorityLevel
- priority
- Function to extract request priority.public SimpleRpcScheduler(Configuration conf, int handlerCount, int priorityHandlerCount, int replicationHandlerCount, PriorityFunction priority, int highPriorityLevel)
public void onConfigurationChange(Configuration conf)
onConfigurationChange
in interface ConfigurationObserver
conf
- new configurationpublic void init(RpcScheduler.Context context)
RpcScheduler
RpcScheduler.start()
. This method is called before start
.init
in class RpcScheduler
context
- provides methods to retrieve runtime information frompublic void start()
RpcScheduler
start
in class RpcScheduler
public void stop()
RpcScheduler
stop
in class RpcScheduler
public boolean dispatch(CallRunner callTask) throws java.lang.InterruptedException
RpcScheduler
dispatch
in class RpcScheduler
callTask
- the request to be dispatchedjava.lang.InterruptedException
public int getGeneralQueueLength()
RpcScheduler
getGeneralQueueLength
in class RpcScheduler
public int getPriorityQueueLength()
RpcScheduler
getPriorityQueueLength
in class RpcScheduler
public int getReplicationQueueLength()
RpcScheduler
getReplicationQueueLength
in class RpcScheduler
public int getActiveRpcHandlerCount()
RpcScheduler
getActiveRpcHandlerCount
in class RpcScheduler
public long getNumGeneralCallsDropped()
RpcScheduler
getNumGeneralCallsDropped
in class RpcScheduler
public long getNumLifoModeSwitches()
RpcScheduler
getNumLifoModeSwitches
in class RpcScheduler