alluxio.master

Class AlwaysStandbyPrimarySelector

java.lang.Object

alluxio.master.AlwaysStandbyPrimarySelector

All Implemented Interfaces:

PrimarySelector

public final class AlwaysStandbyPrimarySelector
extends Object
implements PrimarySelector

A primary selector which is always standby.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.PrimarySelector

PrimarySelector.Factory

Constructor Summary

Constructors

Constructor and Description
AlwaysStandbyPrimarySelector()

Method Summary

Modifier and Type	Method and Description
NodeState	getState()
NodeState	getStateUnsafe()
Scoped	onStateChange(java.util.function.Consumer<NodeState> listener) Registers a listener to be executed whenever the selector's state updates.
void	start(InetSocketAddress localAddress) Starts the primary selector.
void	stop() Stops the primary selector.
void	waitForState(NodeState state) Blocks until the primary selector enters the specified state.

Methods inherited from class java.lang.Object

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

Constructor Detail

AlwaysStandbyPrimarySelector

public AlwaysStandbyPrimarySelector()

Method Detail

start

public void start(InetSocketAddress localAddress)

Description copied from interface: PrimarySelector

Starts the primary selector.

Specified by:

start in interface PrimarySelector

Parameters:

localAddress - the address of the local master

stop

public void stop()

Description copied from interface: PrimarySelector

Stops the primary selector.

Specified by:

stop in interface PrimarySelector

getState

public NodeState getState()

Specified by:

getState in interface PrimarySelector

Returns:

the current state

getStateUnsafe

public NodeState getStateUnsafe()

Specified by:

getStateUnsafe in interface PrimarySelector

Returns:

the current state without the lock acquired

onStateChange

public Scoped onStateChange(java.util.function.Consumer<NodeState> listener)

Description copied from interface: PrimarySelector

Registers a listener to be executed whenever the selector's state updates. The listener will be executed synchronously in the state update thread, so it should run quickly.

Specified by:

onStateChange in interface PrimarySelector

Parameters:

listener - the listener

Returns:

an object which will unregister the listener when closed

waitForState

public void waitForState(NodeState state)
                  throws InterruptedException

Description copied from interface: PrimarySelector

Blocks until the primary selector enters the specified state.

Specified by:

waitForState in interface PrimarySelector

Parameters:

state - the state to wait for

Throws:

InterruptedException