alluxio.grpc

Class GrpcConnectionPool

java.lang.Object

alluxio.grpc.GrpcConnectionPool

@ThreadSafe
public class GrpcConnectionPool
extends Object

Used to provide gRPC level connection management and pooling facilities. This class is used internally by GrpcChannelBuilder and GrpcChannel.

Field Summary

Fields

Modifier and Type	Field and Description
static GrpcConnectionPool	INSTANCE

Constructor Summary

Constructors

Constructor and Description
GrpcConnectionPool() Creates a new GrpcConnectionPool.

Method Summary

Modifier and Type	Method and Description
GrpcConnection	acquireConnection(GrpcChannelKey channelKey, AlluxioConfiguration conf) Acquires and increases the ref-count for the ManagedChannel.
void	releaseConnection(GrpcConnectionKey connectionKey, AlluxioConfiguration conf) Decreases the ref-count of the ManagedChannel for the given address.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final GrpcConnectionPool INSTANCE

Constructor Detail

GrpcConnectionPool

public GrpcConnectionPool()

Creates a new GrpcConnectionPool.

Method Detail

acquireConnection

public GrpcConnection acquireConnection(GrpcChannelKey channelKey,
                                        AlluxioConfiguration conf)

Acquires and increases the ref-count for the ManagedChannel.

Parameters:

channelKey - the channel key

conf - the Alluxio configuration

Returns:

a GrpcConnection

releaseConnection

public void releaseConnection(GrpcConnectionKey connectionKey,
                              AlluxioConfiguration conf)

Decreases the ref-count of the ManagedChannel for the given address. It shuts down the underlying channel if reference count reaches zero.

Parameters:

connectionKey - the connection key

conf - the Alluxio configuration