Package org.apache.hadoop.hbase.client

Class ConnectionImplementation.ServerErrorTracker

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionImplementation.ServerErrorTracker

Enclosing class:

ConnectionImplementation

static class ConnectionImplementation.ServerErrorTracker
extends Object

The record of errors for servers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ConnectionImplementation.ServerErrorTracker.ServerErrors	The record of errors for a server.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	canRetryUntil
private final ConcurrentMap<ServerName,ConnectionImplementation.ServerErrorTracker.ServerErrors>	errorsByServer
private final int	maxTries
private final long	startTrackingTime

Constructor Summary

Constructors

Constructor	Description
ServerErrorTracker(long timeout, int maxTries)	Constructor

Method Summary

Modifier and Type	Method	Description
(package private) long	calculateBackoffTime(ServerName server, long basePause)	Calculates the back-off time for a retrying request to a particular server.
(package private) boolean	canTryMore(int numAttempt)	We stop to retry when we have exhausted BOTH the number of tries and the time allocated.
(package private) long	getStartTrackingTime()
(package private) void	reportServerError(ServerName server)	Reports that there was an error on the server to do whatever bean-counting necessary.

Methods inherited from class java.lang.Object

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

Field Details

errorsByServer

private final ConcurrentMap<ServerName,ConnectionImplementation.ServerErrorTracker.ServerErrors> errorsByServer

canRetryUntil

private final long canRetryUntil

maxTries

private final int maxTries

startTrackingTime

private final long startTrackingTime

Constructor Details

ServerErrorTracker

public ServerErrorTracker(long timeout,
 int maxTries)

Constructor

Parameters:

timeout - how long to wait before timeout, in unit of millisecond

maxTries - how many times to try

Method Details

canTryMore

boolean canTryMore(int numAttempt)

We stop to retry when we have exhausted BOTH the number of tries and the time allocated.

Parameters:

numAttempt - how many times we have tried by now

calculateBackoffTime

long calculateBackoffTime(ServerName server,
 long basePause)

Calculates the back-off time for a retrying request to a particular server.

Parameters:

server - The server in question.

basePause - The default hci pause.

Returns:

The time to wait before sending next request.

reportServerError

void reportServerError(ServerName server)

Reports that there was an error on the server to do whatever bean-counting necessary.

Parameters:

server - The server in question.

getStartTrackingTime

long getStartTrackingTime()