tachyon.worker

Class DataServer

java.lang.Object

tachyon.worker.DataServer

All Implemented Interfaces:

Runnable

public class DataServer
extends Object
implements Runnable

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
DataServer(InetSocketAddress address, WorkerStorage workerStorage) Create a data server with direct access to worker storage.

Method Summary

Modifier and Type	Method and Description
void	close() Close the data server.
boolean	isClosed()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataServer

public DataServer(InetSocketAddress address,
                  WorkerStorage workerStorage)

Create a data server with direct access to worker storage.

Parameters:

address - The address of the data server.

workerStorage - The handler of the directly accessed worker storage.

Method Detail

close

public void close()
           throws IOException

Close the data server.

Throws:

IOException

isClosed

public boolean isClosed()

Returns:

true if the server is closed, false otherwise

run

public void run()

Specified by:

run in interface Runnable