Package org.apache.hadoop.hbase.util

Class RSProcDispatcher

java.lang.Object

org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.ServerName>

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

org.apache.hadoop.hbase.util.RSProcDispatcher

All Implemented Interfaces:

org.apache.hadoop.hbase.master.ServerListener

public class RSProcDispatcher
extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

Test implementation of RSProcedureDispatcher that throws desired errors for testing purpose.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	RSProcDispatcher.DeadRSRemoteCall
(package private) class	RSProcDispatcher.TestExecuteProceduresRemoteCall

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ExecuteProceduresRemoteCall, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionCloseOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionOpenOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ServerOperation

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 extends Object,TRemote extends Object>, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure<TEnv extends Object,TRemote extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicInteger	ERROR_IDX
private static final List<IOException>	ERRORS
private static final AtomicInteger	I
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

master, RS_RPC_STARTUP_WAIT_TIME_CONF_KEY

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	Description
RSProcDispatcher(org.apache.hadoop.hbase.master.MasterServices master)

Method Summary

Modifier and Type	Method	Description
protected void	remoteDispatch(org.apache.hadoop.hbase.ServerName serverName, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Methods inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

abortPendingOperations, getUncaughtExceptionHandler, serverAdded, serverRemoved, splitAndResolveOperation, start, stop

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

addNode, addOperationToNode, buildAndGroupRequestByType, fetchType, hasNode, join, removeCompletedOperation, removeNode, setTimeoutExecutorUncaughtExceptionHandler, submitTask, submitTask

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.master.ServerListener

waiting

Field Details

LOG

private static final org.slf4j.Logger LOG

I

private static final AtomicInteger I

ERRORS

private static final List<IOException> ERRORS

ERROR_IDX

private static final AtomicInteger ERROR_IDX

Constructor Details

RSProcDispatcher

public RSProcDispatcher(org.apache.hadoop.hbase.master.MasterServices master)

Method Details

remoteDispatch

protected void remoteDispatch(org.apache.hadoop.hbase.ServerName serverName,
 Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Overrides:

remoteDispatch in class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher