alluxio.master

Class AlluxioMasterProcess

java.lang.Object

alluxio.master.AlluxioMasterProcess

All Implemented Interfaces:

MasterProcess, Process

@NotThreadSafe
public class AlluxioMasterProcess
extends Object
implements MasterProcess

This class encapsulates the different master services that are configured to run.

Nested Class Summary

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

MasterProcess.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	mExecutorService The ExecutorService for RPC server.
protected JournalSystem	mJournalSystem The journal system for writing journal entries and restoring master state.
protected SafeModeManager	mSafeModeManager The manager of safe mode state.

Method Summary

Modifier and Type	Method and Description
<T extends Master> T	getMaster(Class<T> clazz)
InetSocketAddress	getRpcAddress()
long	getStartTimeMs()
long	getUptimeMs()
InetSocketAddress	getWebAddress()
boolean	isInSafeMode()
boolean	isServing()
void	start() Starts the Alluxio process.
protected void	startJvmMonitorProcess() Starts jvm monitor process, to monitor jvm.
protected void	startMasters(boolean isLeader) Starts all masters, including block master, FileSystem master, lineage master and additional masters.
protected void	startServing(String startMessage, String stopMessage) Starts serving, letting MetricsSystem start sink and starting the web ui server and RPC Server.
protected void	startServingRPCServer() Starts the Thrift RPC server.
protected void	startServingWebServer() Starts serving web ui server, resetting master web port, adding the metrics servlet to the web server and starting web ui.
void	stop() Stops the Alluxio process, blocking until the action is completed.
protected void	stopMasters() Stops all masters, including lineage master, block master and fileSystem master and additional masters.
protected void	stopServing() Stops serving, trying stop RPC server and web ui server and letting MetricsSystem stop all the sinks.
String	toString()
boolean	waitForReady(int timeoutMs) Waits until the process is ready to serve requests.

Methods inherited from class java.lang.Object

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

Field Detail

mExecutorService

protected ExecutorService mExecutorService

The ExecutorService for RPC server.

mJournalSystem

protected final JournalSystem mJournalSystem

The journal system for writing journal entries and restoring master state.

mSafeModeManager

protected final SafeModeManager mSafeModeManager

The manager of safe mode state.

Method Detail

getMaster

public <T extends Master> T getMaster(Class<T> clazz)

Specified by:

getMaster in interface MasterProcess

Type Parameters:

T - the type of the master to get

Parameters:

clazz - the class of the master to get

Returns:

the given master

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in interface MasterProcess

Returns:

this master's rpc address

getStartTimeMs

public long getStartTimeMs()

Specified by:

getStartTimeMs in interface MasterProcess

Returns:

the start time of the master in milliseconds

getUptimeMs

public long getUptimeMs()

Specified by:

getUptimeMs in interface MasterProcess

Returns:

the uptime of the master in milliseconds

getWebAddress

@Nullable
public InetSocketAddress getWebAddress()

Specified by:

getWebAddress in interface MasterProcess

Returns:

the master's web address, or null if the web server hasn't been started yet

isInSafeMode

public boolean isInSafeMode()

Specified by:

isInSafeMode in interface MasterProcess

Returns:

true if Alluxio is running in safe mode, false otherwise

isServing

public boolean isServing()

Specified by:

isServing in interface MasterProcess

Returns:

true if the system is the leader (serving the rpc server), false otherwise

waitForReady

public boolean waitForReady(int timeoutMs)

Description copied from interface: Process

Waits until the process is ready to serve requests.

Specified by:

waitForReady in interface Process

Parameters:

timeoutMs - how long to wait in milliseconds

Returns:

whether the process became ready before the specified timeout

start

public void start()
           throws Exception

Description copied from interface: Process

Starts the Alluxio process. This call blocks until the process is stopped via Process.stop(). The Process.waitForReady(int) method can be used to make sure that the process is ready to serve requests.

Specified by:

start in interface Process

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: Process

Stops the Alluxio process, blocking until the action is completed.

Specified by:

stop in interface Process

Throws:

Exception

startMasters

protected void startMasters(boolean isLeader)

Starts all masters, including block master, FileSystem master, lineage master and additional masters.

Parameters:

isLeader - if the Master is leader

stopMasters

protected void stopMasters()

Stops all masters, including lineage master, block master and fileSystem master and additional masters.

startServing

protected void startServing(String startMessage,
                            String stopMessage)

Starts serving, letting MetricsSystem start sink and starting the web ui server and RPC Server.

Parameters:

startMessage - empty string or the message that the master gains the leadership

stopMessage - empty string or the message that the master loses the leadership

startServingWebServer

protected void startServingWebServer()

Starts serving web ui server, resetting master web port, adding the metrics servlet to the web server and starting web ui.

startJvmMonitorProcess

protected void startJvmMonitorProcess()

Starts jvm monitor process, to monitor jvm.

startServingRPCServer

protected void startServingRPCServer()

Starts the Thrift RPC server. The AlluxioMaster registers the Services of registered Masters and meta services to a multiplexed processor, then creates the master thrift service with the multiplexed processor.

stopServing

protected void stopServing()
                    throws Exception

Stops serving, trying stop RPC server and web ui server and letting MetricsSystem stop all the sinks.

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object