alluxio.master

Class AlluxioMasterProcess

java.lang.Object

alluxio.master.MasterProcess

alluxio.master.AlluxioMasterProcess

All Implemented Interfaces:

Process

@NotThreadSafe
public class AlluxioMasterProcess
extends MasterProcess

An Alluxio Master which runs a web and rpc server to handle FileSystem operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AlluxioMasterProcess.Factory Factory for creating AlluxioMasterProcess.

Field Summary

Fields

Modifier and Type	Field and Description
protected MasterContext	mContext Master context.
protected SafeModeManager	mSafeModeManager The manager of safe mode state.

Fields inherited from class alluxio.master.MasterProcess

mGrpcServer, mJournalSystem, mWebServer

Method Summary

Modifier and Type	Method and Description
protected void	closeMasters() Closes all masters, including block master, fileSystem master and additional masters.
<T extends Master> T	getMaster(Class<T> clazz) Gets the registered class from the master registry.
InetSocketAddress	getRpcAddress()
InetSocketAddress	getWebAddress()
boolean	isInSafeMode()
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, 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 gRPC 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 block master, 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()

Methods inherited from class alluxio.master.MasterProcess

getStartTimeMs, getUptimeMs, isServing, startRejectingServers, startServing, stopRejectingRpcServer, stopRejectingServers, stopRejectingWebServer, waitForReady

Methods inherited from class java.lang.Object

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

Field Detail

mSafeModeManager

protected final SafeModeManager mSafeModeManager

The manager of safe mode state.

mContext

protected final MasterContext mContext

Master context.

Method Detail

getMaster

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

Description copied from class: MasterProcess

Gets the registered class from the master registry.

Specified by:

getMaster in class MasterProcess

Type Parameters:

T - the type of the master to get

Parameters:

clazz - the class of the master to get

Returns:

the given master

isInSafeMode

public boolean isInSafeMode()

Returns:

true if Alluxio is running in safe mode, false otherwise

getWebAddress

@Nullable
public InetSocketAddress getWebAddress()

Specified by:

getWebAddress in class MasterProcess

Returns:

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

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in class MasterProcess

Returns:

this master's rpc address

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.

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: Process

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

Throws:

Exception

startMasters

protected void startMasters(boolean isLeader)
                     throws IOException

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

Parameters:

isLeader - if the Master is leader

Throws:

IOException

stopMasters

protected void stopMasters()

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

closeMasters

protected void closeMasters()

Closes all masters, including block master, fileSystem master and additional masters.

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.

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

startServingRPCServer

protected void startServingRPCServer()

Starts the gRPC server. The AlluxioMaster registers the Services of registered Masters and meta services.

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