Package 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

@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	Description
(package private) final Abortable	abortable
(package private) final AtomicInteger	activeHandlerCount
(package private) final AtomicInteger	failedHandlerCount
(package private) final int	handlerCount
(package private) final double	handlerFailureThreshhold
private static final org.slf4j.Logger	LOG
(package private) final 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	Description
RpcHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, Abortable abortable)

Method Summary

Modifier and Type	Method	Description
protected CallRunner	getCallRunner()
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 Details

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 Details

RpcHandler

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

Method Details

getCallRunner

protected CallRunner getCallRunner()
                            throws InterruptedException

Returns:

A CallRunner

Throws:

InterruptedException - thrown by BlockingQueue.take()

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)