alluxio.logserver

Class AlluxioLogServerProcess

java.lang.Object

alluxio.logserver.AlluxioLogServerProcess

All Implemented Interfaces:

Process

public class AlluxioLogServerProcess
extends Object
implements Process

A centralized log server for Alluxio. Alluxio masters and workers generate logs and store the logs in local storage. AlluxioLogServerProcess allows masters and workers to "push" their logs to a centralized log server where another copy of the logs will be stored.

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOGSERVER_CLIENT_LOGGER_APPENDER_NAME Name of the appender used by log server to perform actual logging of messages received from remote Alluxio servers.

Constructor Summary

Constructors

Constructor and Description
AlluxioLogServerProcess(String baseLogsDir) Constructs an AlluxioLogServerProcess instance.

Method Summary

Modifier and Type	Method and Description
void	start() Starts the Alluxio process.
void	stop() Stops the Alluxio process, blocking until the action is completed.
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, toString, wait, wait, wait

Field Detail

LOGSERVER_CLIENT_LOGGER_APPENDER_NAME

public static final String LOGSERVER_CLIENT_LOGGER_APPENDER_NAME

Name of the appender used by log server to perform actual logging of messages received from remote Alluxio servers. It has to match the value in log4j.properties.

See Also:

Constant Field Values

Constructor Detail

AlluxioLogServerProcess

public AlluxioLogServerProcess(String baseLogsDir)

Constructs an AlluxioLogServerProcess instance.

Parameters:

baseLogsDir - base directory to store the logs pushed from remote Alluxio servers

Method Detail

start

public void start()
           throws Exception

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. Creates and starts logging server and client thread pool.

Specified by:

start in interface Process

Throws:

Exception

stop

public void stop()
          throws Exception

Stops the Alluxio process, blocking until the action is completed. Stops the main thread of AlluxioLogServerProcess. Close the server socket, shutdown the thread pool, stop accepting new requests, and blocks until all worker threads terminate.

Specified by:

stop in interface Process

Throws:

Exception

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