org.apache.hadoop.hbase.ipc

Class RpcExecutor.Handler

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.RpcExecutor.Handler

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

FastPathBalancedQueueRpcExecutor.FastPathHandler

Enclosing class:

RpcExecutor

protected class RpcExecutor.Handler
extends Thread

Handler thread run the CallRunner.run() in.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) AtomicInteger	activeHandlerCount
(package private) double	handlerFailureThreshhold
(package private) BlockingQueue<CallRunner>	q Q to find CallRunners to run in.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Handler(String name, double handlerFailureThreshhold, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount)

Method Summary

Modifier and Type	Method and Description
protected CallRunner	getCallRunner()
void	run()
private void	run(CallRunner cr)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

q

final BlockingQueue<CallRunner> q

Q to find CallRunners to run in.

handlerFailureThreshhold

final double handlerFailureThreshhold

activeHandlerCount

final AtomicInteger activeHandlerCount

Constructor Detail

Handler

Handler(String name,
        double handlerFailureThreshhold,
        BlockingQueue<CallRunner> q,
        AtomicInteger activeHandlerCount)

Method Detail

getCallRunner

protected CallRunner getCallRunner()
                            throws InterruptedException

Returns:

A CallRunner

Throws:

InterruptedException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

run

private void run(CallRunner cr)