org.apache.hadoop.hbase.procedure2

Class TestRemoteProcedureDispatcherUncaughtExceptionHandler.Dispatcher

java.lang.Object

org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>

org.apache.hadoop.hbase.procedure2.TestRemoteProcedureDispatcherUncaughtExceptionHandler.Dispatcher

Enclosing class:

TestRemoteProcedureDispatcherUncaughtExceptionHandler

private static final class TestRemoteProcedureDispatcherUncaughtExceptionHandler.Dispatcher
extends org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher

org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote>, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote>

Field Summary

Fields

Modifier and Type	Field and Description
private Thread.UncaughtExceptionHandler	handler

Fields inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher

DISPATCH_DELAY_CONF_KEY, DISPATCH_MAX_QUEUE_SIZE_CONF_KEY, THREAD_POOL_SIZE_CONF_KEY

Constructor Summary

Constructors

Constructor and Description
Dispatcher(Thread.UncaughtExceptionHandler handler)

Method Summary

Modifier and Type	Method and Description
protected void	abortPendingOperations(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)
protected Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler()
protected void	remoteDispatch(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)

Methods inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher

addNode, addOperationToNode, buildAndGroupRequestByType, fetchType, join, removeCompletedOperation, removeNode, setTimeoutExecutorUncaughtExceptionHandler, start, stop, submitTask, submitTask

Methods inherited from class java.lang.Object

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

Field Detail

handler

private final Thread.UncaughtExceptionHandler handler

Constructor Detail

Dispatcher

public Dispatcher(Thread.UncaughtExceptionHandler handler)

Method Detail

getUncaughtExceptionHandler

protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

Specified by:

getUncaughtExceptionHandler in class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>

remoteDispatch

protected void remoteDispatch(Integer key,
                              Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)

Specified by:

remoteDispatch in class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>

abortPendingOperations

protected void abortPendingOperations(Integer key,
                                      Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)

Specified by:

abortPendingOperations in class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>