tachyon.worker.nio

Class NIODataServer

java.lang.Object

tachyon.worker.nio.NIODataServer

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, DataServer

public class NIODataServer
extends Object
implements Runnable, DataServer

The Server to serve data file read request from remote machines. The current implementation is based on non-blocking NIO.

Constructor Summary

Constructors

Constructor and Description
NIODataServer(InetSocketAddress address, BlocksLocker locker) Create a data server with direct access to worker storage.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the data server.
int	getPort() Gets the port listening on.
boolean	isClosed()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

NIODataServer

public NIODataServer(InetSocketAddress address,
             BlocksLocker locker)

Create a data server with direct access to worker storage.

Parameters:

address - The address of the data server.

locker - The lock system for lock blocks.

Method Detail

close

public void close()
           throws IOException

Close the data server.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getPort

public int getPort()

Gets the port listening on.

Specified by:

getPort in interface DataServer

isClosed

public boolean isClosed()

Specified by:

isClosed in interface DataServer

Returns:

true if the server is closed, false otherwise

run

public void run()

Specified by:

run in interface Runnable