alluxio.worker.grpc

Class GrpcDataServer

java.lang.Object

alluxio.worker.grpc.GrpcDataServer

All Implemented Interfaces:

DataServer, Closeable, AutoCloseable

@NotThreadSafe
public final class GrpcDataServer
extends Object
implements DataServer

Runs a gRPC data server that responds to block requests.

Constructor Summary

Constructors

Constructor and Description
GrpcDataServer(String hostName, SocketAddress bindAddress, WorkerProcess workerProcess) Creates a new instance of GrpcDataServer.

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.
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

GrpcDataServer

public GrpcDataServer(String hostName,
                      SocketAddress bindAddress,
                      WorkerProcess workerProcess)

Creates a new instance of GrpcDataServer.

Parameters:

hostName - the server host name

bindAddress - the server bind 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

awaitTermination

public void awaitTermination()

Description copied from interface: DataServer

Waits for server to terminate.

Specified by:

awaitTermination in interface DataServer