Package org.apache.hadoop.hbase.rsgroup

Class RSGroupInfoManagerImpl.ServerEventsListenerThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.rsgroup.RSGroupInfoManagerImpl.ServerEventsListenerThread

All Implemented Interfaces:

Runnable, ServerListener

Enclosing class:

RSGroupInfoManagerImpl

private class RSGroupInfoManagerImpl.ServerEventsListenerThread
extends Thread
implements ServerListener

Calls RSGroupInfoManagerImpl.updateDefaultServers(SortedSet) to update list of known servers. Notifications about server changes are received by registering ServerListener. As a listener, we need to return immediately, so the real work of updating the servers is done asynchronously in this thread.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	changed
private final org.slf4j.Logger	LOG

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ServerEventsListenerThread()

Method Summary

Modifier and Type	Method	Description
void	run()
void	serverAdded(ServerName serverName)	The server has joined the cluster.
private void	serverChanged()
void	serverRemoved(ServerName serverName)	The server was removed from the cluster.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.master.ServerListener

waiting

Field Details

LOG

private final org.slf4j.Logger LOG

changed

private boolean changed

Constructor Details

ServerEventsListenerThread

ServerEventsListenerThread()

Method Details

serverAdded

public void serverAdded(ServerName serverName)

Description copied from interface: ServerListener

The server has joined the cluster.

Specified by:

serverAdded in interface ServerListener

Parameters:

serverName - The remote servers name.

serverRemoved

public void serverRemoved(ServerName serverName)

Description copied from interface: ServerListener

The server was removed from the cluster.

Specified by:

serverRemoved in interface ServerListener

Parameters:

serverName - The remote servers name.

serverChanged

private void serverChanged()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread