org.apache.hadoop.hbase.master.procedure

Class RSProcedureDispatcher.AbstractRSRemoteCall

java.lang.Object

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

RSProcedureDispatcher.CloseRegionRemoteCall, RSProcedureDispatcher.ExecuteProceduresRemoteCall, RSProcedureDispatcher.OpenRegionRemoteCall

Enclosing class:

RSProcedureDispatcher

protected abstract class RSProcedureDispatcher.AbstractRSRemoteCall
extends Object
implements Runnable

Base remote call

Field Summary

Fields

Modifier and Type	Field and Description
private long	maxWaitTime
private int	numberOfAttemptsSoFar
private ServerName	serverName

Constructor Summary

Constructors

Constructor and Description
AbstractRSRemoteCall(ServerName serverName)

Method Summary

Modifier and Type	Method and Description
private long	getMaxWaitTime()
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getRsAdmin()
protected ServerName	getServerName()
protected boolean	scheduleForRetry(IOException e)
protected IOException	unwrapException(IOException e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

serverName

private final ServerName serverName

numberOfAttemptsSoFar

private int numberOfAttemptsSoFar

maxWaitTime

private long maxWaitTime

Constructor Detail

AbstractRSRemoteCall

public AbstractRSRemoteCall(ServerName serverName)

Method Detail

getRsAdmin

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

Throws:

IOException

getServerName

protected ServerName getServerName()

scheduleForRetry

protected boolean scheduleForRetry(IOException e)

getMaxWaitTime

private long getMaxWaitTime()

unwrapException

protected IOException unwrapException(IOException e)