alluxio.worker.netty

Class NettyDataServer

java.lang.Object

alluxio.worker.netty.NettyDataServer

All Implemented Interfaces:

DataServer, Closeable, AutoCloseable

@NotThreadSafe
public class NettyDataServer
extends Object
implements DataServer

Runs a netty data server that responds to block requests.

Constructor Summary

Constructors

Constructor and Description
NettyDataServer(InetSocketAddress nettyBindAddress, InetSocketAddress s3BindAddress, UfsManager ufsManager, DoraWorker doraWorker) Creates a new instance of NettyDataServer.
NettyDataServer(InetSocketAddress nettyBindAddress, UfsManager ufsManager) Creates a new instance of NettyDataServer.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination() Waits for server to terminate.
void	close()
SocketAddress	getBindAddress() Gets the actual bind socket address.
SocketAddress	getS3BindAddress() Gets the actual bind socket address for S3.
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

@Inject
public NettyDataServer(@Named(value="NettyBindAddress")
                               InetSocketAddress nettyBindAddress,
                               @Named(value="S3BindAddress")
                               InetSocketAddress s3BindAddress,
                               UfsManager ufsManager,
                               DoraWorker doraWorker)

Creates a new instance of NettyDataServer.

Parameters:

nettyBindAddress - the server address

s3BindAddress - the s3 server address

ufsManager - the UfsManager object

doraWorker - the DoraWorker object

NettyDataServer

public NettyDataServer(@Named(value="NettyBindAddress")
                       InetSocketAddress nettyBindAddress,
                       UfsManager ufsManager)

Creates a new instance of NettyDataServer. This is for the constructor of the NettyDataServer subclass.

Parameters:

nettyBindAddress - the server address

ufsManager - the UfsManager object

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

getS3BindAddress

public SocketAddress getS3BindAddress()

Description copied from interface: DataServer

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

Specified by:

getS3BindAddress 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

awaitTermination

public void awaitTermination()

Description copied from interface: DataServer

Waits for server to terminate.

Specified by:

awaitTermination in interface DataServer