Package 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	Description
private static final int	DEFAULT_RS_RPC_RETRY_INTERVAL
private long	maxWaitTime
private int	numberOfAttemptsSoFar
private final Set<RemoteProcedureDispatcher.RemoteProcedure>	remoteProcedures
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder	request
private static final String	RS_RPC_RETRY_INTERVAL_CONF_KEY
private final long	rsRpcRetryInterval
private final ServerName	serverName

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 final ServerName	getServerName()
private boolean	isSaslError(IOException e)
protected final 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 boolean	unableToConnectToServer(IOException e)	The category of exceptions where we can ensure that the request has not yet been received and/or processed by the target regionserver yet and hence we can determine whether it is safe to choose different regionserver as the target.
private IOException	unwrapException(IOException e)

Methods inherited from class java.lang.Object

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

Field Details

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 Details

ExecuteProceduresRemoteCall

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

Method Details

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)

unableToConnectToServer

private boolean unableToConnectToServer(IOException e)

The category of exceptions where we can ensure that the request has not yet been received and/or processed by the target regionserver yet and hence we can determine whether it is safe to choose different regionserver as the target.

Parameters:

e - IOException thrown by the underlying rpc framework.

Returns:

true if the exception belongs to the category where the regionserver has not yet received the request yet.

isSaslError

private boolean isSaslError(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)