@InterfaceAudience.Private public class FailedServers extends Object
Modifier and Type | Field and Description |
---|---|
private Map<Address,Long> |
failedServers |
private long |
latestExpiry |
private static org.slf4j.Logger |
LOG |
private int |
recheckServersTimeout |
Constructor and Description |
---|
FailedServers(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
addToFailedServers(Address address,
Throwable throwable)
Add an address to the list of the failed servers list.
|
boolean |
isFailedServer(Address address)
Check if the server should be considered as bad.
|
private final Map<Address,Long> failedServers
private long latestExpiry
private final int recheckServersTimeout
private static final org.slf4j.Logger LOG
public FailedServers(org.apache.hadoop.conf.Configuration conf)
public void addToFailedServers(Address address, Throwable throwable)
public boolean isFailedServer(Address address)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.