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 and Description
private CallRunner	FifoRpcScheduler.FifoCallRunner.callRunner
private CallRunner	FastPathBalancedQueueRpcExecutor.FastPathHandler.loadedCallRunner

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

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

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

Modifier and Type	Method and Description
CallRunner	AdaptiveLifoCoDelCallQueue.element()
protected CallRunner	RpcExecutor.Handler.getCallRunner()
protected CallRunner	FastPathBalancedQueueRpcExecutor.FastPathHandler.getCallRunner()
(package private) CallRunner	FifoRpcScheduler.FifoCallRunner.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 and Description
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 and Description
boolean	AdaptiveLifoCoDelCallQueue.add(CallRunner callRunner)
int	RpcExecutor.CallPriorityComparator.compare(CallRunner a, CallRunner b)
abstract boolean	RpcExecutor.dispatch(CallRunner callTask) Add the request to the executor queue
boolean	RWQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	BalancedQueueRpcExecutor.dispatch(CallRunner callTask)
abstract boolean	RpcScheduler.dispatch(CallRunner task) Dispatches an RPC request asynchronously.
boolean	FastPathBalancedQueueRpcExecutor.dispatch(CallRunner callTask)
boolean	SimpleRpcScheduler.dispatch(CallRunner callTask)
boolean	FifoRpcScheduler.dispatch(CallRunner task)
boolean	MasterFifoRpcScheduler.dispatch(CallRunner task)
protected boolean	FifoRpcScheduler.executeRpcCall(ThreadPoolExecutor executor, AtomicInteger queueSize, CallRunner task)
protected String	FifoRpcScheduler.getCallMethod(CallRunner task)
(package private) boolean	FastPathBalancedQueueRpcExecutor.FastPathHandler.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	RpcExecutor.Handler.run(CallRunner cr)

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

Modifier and Type	Method and Description
boolean	AdaptiveLifoCoDelCallQueue.addAll(Collection<? extends CallRunner> c)
int	AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super CallRunner> c)
int	AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super CallRunner> c, int maxElements)
protected RpcExecutor.Handler	RpcExecutor.getHandler(String name, double handlerFailureThreshhold, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount) Override if providing alternate Handler implementation.
protected RpcExecutor.Handler	FastPathBalancedQueueRpcExecutor.getHandler(String name, double handlerFailureThreshhold, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount)
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

Constructor and Description
FifoCallRunner(CallRunner cr)

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

Constructor and Description
FastPathHandler(String name, double handlerFailureThreshhold, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, Deque<FastPathBalancedQueueRpcExecutor.FastPathHandler> fastPathHandlerStack)
Handler(String name, double handlerFailureThreshhold, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount)