org.apache.hadoop.hbase.master.procedure

Class RSProcedureDispatcher.ExecuteProceduresRemoteCall

java.lang.Object

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

All Implemented Interfaces:

Runnable, RSProcedureDispatcher.RemoteProcedureResolver

Direct Known Subclasses:

RSProcedureDispatcher.DeadRSRemoteCall

Enclosing class:

RSProcedureDispatcher

protected class RSProcedureDispatcher.ExecuteProceduresRemoteCall
extends Object
implements RSProcedureDispatcher.RemoteProcedureResolver, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEFAULT_RS_RPC_RETRY_INTERVAL
private long	maxWaitTime
private int	numberOfAttemptsSoFar
private Set<RemoteProcedureDispatcher.RemoteProcedure>	remoteProcedures
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder	request
private static String	RS_RPC_RETRY_INTERVAL_CONF_KEY
private long	rsRpcRetryInterval
private ServerName	serverName

Constructor Summary

Constructors

Constructor and Description
ExecuteProceduresRemoteCall(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Summary

Modifier and Type	Method and Description
void	dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
void	dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
void	dispatchServerOperations(MasterProcedureEnv env, List<RSProcedureDispatcher.ServerOperation> operations)
private long	getMaxWaitTime()
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getRsAdmin()
protected ServerName	getServerName()
protected void	remoteCallFailed(MasterProcedureEnv env, IOException e)
void	run()
private boolean	scheduleForRetry(IOException e)
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse	sendRequest(ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
private IOException	unwrapException(IOException e)

Methods inherited from class java.lang.Object

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

Field Detail

serverName

private final ServerName serverName

remoteProcedures

private final Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures

numberOfAttemptsSoFar

private int numberOfAttemptsSoFar

maxWaitTime

private long maxWaitTime

rsRpcRetryInterval

private final long rsRpcRetryInterval

RS_RPC_RETRY_INTERVAL_CONF_KEY

private static final String RS_RPC_RETRY_INTERVAL_CONF_KEY

See Also:

Constant Field Values

DEFAULT_RS_RPC_RETRY_INTERVAL

private static final int DEFAULT_RS_RPC_RETRY_INTERVAL

See Also:

Constant Field Values

request

private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder request

Constructor Detail

ExecuteProceduresRemoteCall

public ExecuteProceduresRemoteCall(ServerName serverName,
                                   Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Detail

getRsAdmin

private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getRsAdmin()
                                                                                                         throws IOException

Throws:

IOException

getServerName

protected final ServerName getServerName()

scheduleForRetry

private boolean scheduleForRetry(IOException e)

getMaxWaitTime

private long getMaxWaitTime()

unwrapException

private IOException unwrapException(IOException e)

run

public void run()

Specified by:

run in interface Runnable

dispatchOpenRequests

public void dispatchOpenRequests(MasterProcedureEnv env,
                                 List<RSProcedureDispatcher.RegionOpenOperation> operations)

Specified by:

dispatchOpenRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

dispatchCloseRequests

public void dispatchCloseRequests(MasterProcedureEnv env,
                                  List<RSProcedureDispatcher.RegionCloseOperation> operations)

Specified by:

dispatchCloseRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

dispatchServerOperations

public void dispatchServerOperations(MasterProcedureEnv env,
                                     List<RSProcedureDispatcher.ServerOperation> operations)

Specified by:

dispatchServerOperations in interface RSProcedureDispatcher.RemoteProcedureResolver

sendRequest

protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse sendRequest(ServerName serverName,
                                                                                                              org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
                                                                                                       throws IOException

Throws:

IOException

remoteCallFailed

protected final void remoteCallFailed(MasterProcedureEnv env,
                                      IOException e)