org.apache.hadoop.hbase.client

Class RegistryEndpointsRefresher

java.lang.Object

org.apache.hadoop.hbase.client.RegistryEndpointsRefresher

@InterfaceAudience.Private
final class RegistryEndpointsRefresher
extends Object

Thread safe utility that keeps registry end points used by ConnectionRegistry up to date. By default the refresh happens periodically (configured via intervalSecsConfigName). The refresh can also be triggered on demand via refreshNow(). To prevent a flood of on-demand refreshes we expect that any attempts two should be spaced at least minIntervalSecsConfigName seconds apart.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RegistryEndpointsRefresher.Refresher

Field Summary

Fields

Modifier and Type	Field and Description
private long	initialDelayMs
private static org.slf4j.Logger	LOG
private static int	MIN_SECS_BETWEEN_REFRESHES_DEFAULT
private long	minTimeBetweenRefreshesMs
private static int	PERIODIC_REFRESH_INTERVAL_SECS_DEFAULT
private long	periodicRefreshMs
private RegistryEndpointsRefresher.Refresher	refresher
private boolean	refreshNow
private boolean	stopped
private Thread	thread

Constructor Summary

Constructors

Modifier	Constructor and Description
private	RegistryEndpointsRefresher(long initialDelayMs, long periodicRefreshMs, long minTimeBetweenRefreshesMs, RegistryEndpointsRefresher.Refresher refresher)

Method Summary

Modifier and Type	Method and Description
(package private) static RegistryEndpointsRefresher	create(org.apache.hadoop.conf.Configuration conf, String initialDelaySecsConfigName, String intervalSecsConfigName, String minIntervalSecsConfigName, RegistryEndpointsRefresher.Refresher refresher) Create a RegistryEndpointsRefresher.
private long	getRefreshIntervalMs(boolean firstRefresh)
private void	mainLoop()
(package private) void	refreshNow() Notifies the refresher thread to refresh the configuration.
(package private) void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

PERIODIC_REFRESH_INTERVAL_SECS_DEFAULT

private static final int PERIODIC_REFRESH_INTERVAL_SECS_DEFAULT

See Also:

Constant Field Values

MIN_SECS_BETWEEN_REFRESHES_DEFAULT

private static final int MIN_SECS_BETWEEN_REFRESHES_DEFAULT

See Also:

Constant Field Values

thread

private final Thread thread

refresher

private final RegistryEndpointsRefresher.Refresher refresher

initialDelayMs

private final long initialDelayMs

periodicRefreshMs

private final long periodicRefreshMs

minTimeBetweenRefreshesMs

private final long minTimeBetweenRefreshesMs

refreshNow

private boolean refreshNow

stopped

private boolean stopped

Constructor Detail

RegistryEndpointsRefresher

private RegistryEndpointsRefresher(long initialDelayMs,
                                   long periodicRefreshMs,
                                   long minTimeBetweenRefreshesMs,
                                   RegistryEndpointsRefresher.Refresher refresher)

Method Detail

stop

void stop()

getRefreshIntervalMs

private long getRefreshIntervalMs(boolean firstRefresh)

mainLoop

private void mainLoop()

refreshNow

void refreshNow()

Notifies the refresher thread to refresh the configuration. This does not guarantee a refresh. See class comment for details.

create

static RegistryEndpointsRefresher create(org.apache.hadoop.conf.Configuration conf,
                                         String initialDelaySecsConfigName,
                                         String intervalSecsConfigName,
                                         String minIntervalSecsConfigName,
                                         RegistryEndpointsRefresher.Refresher refresher)

Create a RegistryEndpointsRefresher. If the interval secs configured via intervalSecsConfigName is less than zero, will return null here, which means disable refreshing of endpoints.