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 and Description
private static class	ConnectionImplementation.ServerErrorTracker.ServerErrors The record of errors for a server.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ServerErrorTracker(long timeout, int maxTries) Constructor

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

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 Detail

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()