alluxio.worker.netty

Class NettyDataServer

java.lang.Object

alluxio.worker.netty.NettyDataServer

All Implemented Interfaces:

DataServer, Closeable, AutoCloseable

@NotThreadSafe
public final class NettyDataServer
extends Object
implements DataServer

Runs a netty data server that responds to block requests.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.worker.DataServer

DataServer.Factory

Constructor Summary

Constructors

Constructor and Description
NettyDataServer(SocketAddress address, WorkerProcess workerProcess) Creates a new instance of NettyDataServer.

Method Summary

Modifier and Type	Method and Description
void	close()
SocketAddress	getBindAddress() Gets the actual bind socket address.
boolean	isClosed() Checks if the DataServer is closed.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyDataServer

public NettyDataServer(SocketAddress address,
                       WorkerProcess workerProcess)

Creates a new instance of NettyDataServer.

Parameters:

address - the server address

workerProcess - the Alluxio worker process

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getBindAddress

public SocketAddress getBindAddress()

Description copied from interface: DataServer

Gets the actual bind socket address. It is either a InetSocketAddress or a DomainSocketAddress.

Specified by:

getBindAddress in interface DataServer

Returns:

the bind socket address

isClosed

public boolean isClosed()

Description copied from interface: DataServer

Checks if the DataServer is closed.

Specified by:

isClosed in interface DataServer

Returns:

true if the DataServer is closed, false otherwise