Uses of Class
org.apache.hadoop.hbase.ipc.CallRunner

Packages that use CallRunner

Package	Description
org.apache.hadoop.hbase.ipc	Tools to help define network clients and servers.

Uses of CallRunner in org.apache.hadoop.hbase.ipc

Fields in org.apache.hadoop.hbase.ipc declared as CallRunner

Modifier and Type	Field	Description
private final CallRunner	FifoRpcScheduler.FifoCallRunner.callRunner
private CallRunner	FastPathRpcHandler.loadedCallRunner

Fields in org.apache.hadoop.hbase.ipc with type parameters of type CallRunner

Modifier and Type	Field	Description
(package private) final BlockingQueue<CallRunner>	RpcHandler.q	Q to find CallRunners to run in.
private LinkedBlockingDeque<CallRunner>	AdaptiveLifoCoDelCallQueue.queue
private final List<BlockingQueue<CallRunner>>	RandomQueueBalancer.queues
protected final List<BlockingQueue<CallRunner>>	RpcExecutor.queues

Methods in org.apache.hadoop.hbase.ipc that return CallRunner

Modifier and Type	Method	Description
CallRunner	AdaptiveLifoCoDelCallQueue.element()
protected CallRunner	FastPathRpcHandler.getCallRunner()
(package private) CallRunner	FifoRpcScheduler.FifoCallRunner.getCallRunner()
protected CallRunner	RpcHandler.getCallRunner()
CallRunner	AdaptiveLifoCoDelCallQueue.peek()
CallRunner	AdaptiveLifoCoDelCallQueue.poll()
CallRunner	AdaptiveLifoCoDelCallQueue.poll(long timeout, TimeUnit unit)
CallRunner	AdaptiveLifoCoDelCallQueue.remove()
CallRunner	AdaptiveLifoCoDelCallQueue.take()	Behaves as LinkedBlockingQueue.take(), except it will silently skip all calls which it thinks should be dropped.

Methods in org.apache.hadoop.hbase.ipc that return types with arguments of type CallRunner

Modifier and Type	Method	Description
private Optional<Class<? extends BlockingQueue<CallRunner>>>	RpcExecutor.getPluggableQueueClass()
(package private) List<BlockingQueue<CallRunner>>	RandomQueueBalancer.getQueues()	Exposed for use in tests
protected List<BlockingQueue<CallRunner>>	RpcExecutor.getQueues()	Returns the list of request queues
Iterator<CallRunner>	AdaptiveLifoCoDelCallQueue.iterator()

Methods in org.apache.hadoop.hbase.ipc with parameters of type CallRunner

Modifier and Type	Method	Description
boolean	AdaptiveLifoCoDelCallQueue.add(CallRunner callRunner)
int	RpcExecutor.CallPriorityComparator.compare(CallRunner a, CallRunner b)
boolean	BalancedQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	DelegatingRpcScheduler.dispatch(CallRunner task)
boolean	FastPathBalancedQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	FastPathRWQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	FifoRpcScheduler.dispatch(CallRunner task)
boolean	MasterFifoRpcScheduler.dispatch(CallRunner task)
abstract boolean	RpcExecutor.dispatch(CallRunner callTask)	Add the request to the executor queue
abstract boolean	RpcScheduler.dispatch(CallRunner task)	Dispatches an RPC request asynchronously.
boolean	RWQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	SimpleRpcScheduler.dispatch(CallRunner callTask)
protected boolean	RWQueueRpcExecutor.dispatchTo(boolean toWriteQueue, boolean toScanQueue, CallRunner callTask)
protected boolean	FifoRpcScheduler.executeRpcCall(ThreadPoolExecutor executor, AtomicInteger queueSize, CallRunner task)
protected String	FifoRpcScheduler.getCallMethod(CallRunner task)
private static String	RpcExecutor.getMethodName(CallRunner callRunner)	Return the Descriptors.MethodDescriptor.getName() from callRunner or "Unknown".
int	QueueBalancer.getNextQueue(CallRunner callRunner)	Returns the index of the next queue to which a request should be inserted
int	RandomQueueBalancer.getNextQueue(CallRunner callRunner)
private static long	RpcExecutor.getRpcCallSize(CallRunner callRunner)	Return the RpcCall.getSize() from callRunner or 0L.
(package private) boolean	FastPathRpcHandler.loadCallRunner(CallRunner cr)
private boolean	AdaptiveLifoCoDelCallQueue.needToDrop(CallRunner callRunner)
boolean	AdaptiveLifoCoDelCallQueue.offer(CallRunner callRunner)
boolean	AdaptiveLifoCoDelCallQueue.offer(CallRunner callRunner, long timeout, TimeUnit unit)
void	AdaptiveLifoCoDelCallQueue.put(CallRunner callRunner)
private void	RpcHandler.run(CallRunner cr)
protected boolean	RWQueueRpcExecutor.shouldDispatchToScanQueue(CallRunner task)

Method parameters in org.apache.hadoop.hbase.ipc with type arguments of type CallRunner

Modifier and Type	Method	Description
boolean	AdaptiveLifoCoDelCallQueue.addAll(Collection<? extends CallRunner> c)
int	AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super CallRunner> c)
int	AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super CallRunner> c, int maxElements)
static QueueBalancer	RpcExecutor.getBalancer(String executorName, org.apache.hadoop.conf.Configuration conf, List<BlockingQueue<CallRunner>> queues)
protected RpcHandler	FastPathBalancedQueueRpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)
protected RpcHandler	FastPathRWQueueRpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)
protected RpcHandler	RpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)	Override if providing alternate Handler implementation.
protected void	RpcExecutor.startHandlers(String nameSuffix, int numHandlers, List<BlockingQueue<CallRunner>> callQueues, int qindex, int qsize, int port, AtomicInteger activeHandlerCount)	Start up our handlers.

Constructors in org.apache.hadoop.hbase.ipc with parameters of type CallRunner

Modifier	Constructor	Description
(package private)	FifoCallRunner(CallRunner cr)

Constructor parameters in org.apache.hadoop.hbase.ipc with type arguments of type CallRunner

Modifier	Constructor	Description
(package private)	FastPathRpcHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable, Deque<FastPathRpcHandler> fastPathHandlerStack)
	RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf, String executorName, List<BlockingQueue<CallRunner>> queues)
(package private)	RpcHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)