org.apache.hadoop.hbase.ipc

Class FailedServers

java.lang.Object

org.apache.hadoop.hbase.ipc.FailedServers

@InterfaceAudience.Private
public class FailedServers
extends Object

A class to manage a list of servers that failed recently.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,Long>	failedServers
private long	latestExpiry
private static org.slf4j.Logger	LOG
private int	recheckServersTimeout

Constructor Summary

Constructors

Constructor and Description
FailedServers(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	addToFailedServers(InetSocketAddress address, Throwable throwable) Add an address to the list of the failed servers list.
boolean	isFailedServer(InetSocketAddress address) Check if the server should be considered as bad.

Methods inherited from class java.lang.Object

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

Field Detail

failedServers

private final Map<String,Long> failedServers

latestExpiry

private long latestExpiry

recheckServersTimeout

private final int recheckServersTimeout

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

FailedServers

public FailedServers(org.apache.hadoop.conf.Configuration conf)

Method Detail

addToFailedServers

public void addToFailedServers(InetSocketAddress address,
                               Throwable throwable)

Add an address to the list of the failed servers list.

isFailedServer

public boolean isFailedServer(InetSocketAddress address)

Check if the server should be considered as bad. Clean the old entries of the list.

Returns:

true if the server is in the failed servers list