org.apache.hadoop.hbase.ipc

Class RpcHandler

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.ipc.RpcHandler

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

FastPathRpcHandler

@InterfaceAudience.Private
public class RpcHandler
extends Thread

Thread to handle rpc call. Should only be used in RpcExecutor and its sub-classes.

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) Abortable	abortable
(package private) AtomicInteger	activeHandlerCount
(package private) AtomicInteger	failedHandlerCount
(package private) int	handlerCount
(package private) double	handlerFailureThreshhold
private static org.slf4j.Logger	LOG
(package private) BlockingQueue<CallRunner>	q Q to find CallRunners to run in.
private boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RpcHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
protected CallRunner	getCallRunner() Returns A CallRunner n
void	run()
private void	run(CallRunner cr)
void	stopRunning()

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

LOG

private static final org.slf4j.Logger LOG

q

final BlockingQueue<CallRunner> q

Q to find CallRunners to run in.

handlerCount

final int handlerCount

handlerFailureThreshhold

final double handlerFailureThreshhold

activeHandlerCount

final AtomicInteger activeHandlerCount

failedHandlerCount

final AtomicInteger failedHandlerCount

abortable

final Abortable abortable

running

private boolean running

Constructor Detail

RpcHandler

RpcHandler(String name,
           double handlerFailureThreshhold,
           int handlerCount,
           BlockingQueue<CallRunner> q,
           AtomicInteger activeHandlerCount,
           AtomicInteger failedHandlerCount,
           Abortable abortable)

Method Detail

getCallRunner

protected CallRunner getCallRunner()
                            throws InterruptedException

Returns A CallRunner n

Throws:

InterruptedException

stopRunning

public void stopRunning()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

run

private void run(CallRunner cr)