Package org.apache.hadoop.hbase.master.assignment

Class TestAssignmentManagerBase.SocketTimeoutRsExecutor

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.NoopRsExecutor

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.GoodRsExecutor

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.SocketTimeoutRsExecutor

All Implemented Interfaces:

TestAssignmentManagerBase.MockRSExecutor

Enclosing class:

TestAssignmentManagerBase

protected class TestAssignmentManagerBase.SocketTimeoutRsExecutor
extends TestAssignmentManagerBase.GoodRsExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.ServerName	lastServer
private int	retries
private final int	timeoutTimes

Constructor Summary

Constructors

Constructor	Description
SocketTimeoutRsExecutor(int timeoutTimes)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse	sendRequest(org.apache.hadoop.hbase.ServerName server, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest req)

Methods inherited from class org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.GoodRsExecutor

execCloseRegion, execOpenRegion

Methods inherited from class java.lang.Object

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

Field Details

timeoutTimes

private final int timeoutTimes

lastServer

private org.apache.hadoop.hbase.ServerName lastServer

retries

private int retries

Constructor Details

SocketTimeoutRsExecutor

public SocketTimeoutRsExecutor(int timeoutTimes)

Method Details

sendRequest

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse sendRequest(org.apache.hadoop.hbase.ServerName server,
 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest req)
                                                                                                    throws IOException

Specified by:

sendRequest in interface TestAssignmentManagerBase.MockRSExecutor

Overrides:

sendRequest in class TestAssignmentManagerBase.NoopRsExecutor

Throws:

IOException