alluxio.client.block.stream

Class BlockWorkerClientPool

java.lang.Object

alluxio.resource.DynamicResourcePool<BlockWorkerClient>

alluxio.client.block.stream.BlockWorkerClientPool

All Implemented Interfaces:

Pool<BlockWorkerClient>, Closeable, AutoCloseable

@ThreadSafe
public class BlockWorkerClientPool
extends DynamicResourcePool<BlockWorkerClient>

Class for managing block worker clients. After obtaining a client with DynamicResourcePool.acquire(), DynamicResourcePool.release(Object) must be called when the thread is done using the client.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.resource.DynamicResourcePool

DynamicResourcePool.Options, DynamicResourcePool.ResourceInternal<R>, DynamicResourcePool.SelectionPolicy

Field Summary

Fields inherited from class alluxio.resource.DynamicResourcePool

mClock, mResources, mSelectionPolicy

Constructor Summary

Constructors

Constructor and Description
BlockWorkerClientPool(UserState userState, GrpcServerAddress address, int minCapacity, int maxCapacity, AlluxioConfiguration alluxioConf) Creates a new block master client pool.

Method Summary

Modifier and Type	Method and Description
protected void	closeResource(BlockWorkerClient client) Closes the resource.
protected BlockWorkerClient	createNewResource() Creates a new resource.
protected GrpcServerAddress	getAddress()
protected com.codahale.metrics.Counter	getMetricCounter()
protected UserState	getUserState()
protected boolean	isHealthy(BlockWorkerClient client) Checks whether a client is healthy.
protected boolean	shouldGc(DynamicResourcePool.ResourceInternal<BlockWorkerClient> clientResourceInternal)

Methods inherited from class alluxio.resource.DynamicResourcePool

acquire, acquire, close, release, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.resource.Pool

acquireCloseable, acquireCloseable

Constructor Detail

BlockWorkerClientPool

public BlockWorkerClientPool(UserState userState,
                             GrpcServerAddress address,
                             int minCapacity,
                             int maxCapacity,
                             AlluxioConfiguration alluxioConf)

Creates a new block master client pool.

Parameters:

userState - the parent userState

address - address of the worker

minCapacity - the minimum capacity of the pool

maxCapacity - the maximum capacity of the pool

alluxioConf - Alluxio configuration

Method Detail

getUserState

protected UserState getUserState()

getAddress

protected GrpcServerAddress getAddress()

closeResource

protected void closeResource(BlockWorkerClient client)
                      throws IOException

Description copied from class: DynamicResourcePool

Closes the resource. After this, the resource should not be used. It is not guaranteed that the resource is closed after the function returns.

Specified by:

closeResource in class DynamicResourcePool<BlockWorkerClient>

Parameters:

client - the resource to close

Throws:

IOException

createNewResource

protected BlockWorkerClient createNewResource()
                                       throws IOException

Description copied from class: DynamicResourcePool

Creates a new resource.

Specified by:

createNewResource in class DynamicResourcePool<BlockWorkerClient>

Returns:

the newly created resource

Throws:

IOException

isHealthy

protected boolean isHealthy(BlockWorkerClient client)

Checks whether a client is healthy.

Specified by:

isHealthy in class DynamicResourcePool<BlockWorkerClient>

Parameters:

client - the client to check

Returns:

true if the client is active (i.e. connected)

getMetricCounter

protected com.codahale.metrics.Counter getMetricCounter()

Specified by:

getMetricCounter in class DynamicResourcePool<BlockWorkerClient>

shouldGc

protected boolean shouldGc(DynamicResourcePool.ResourceInternal<BlockWorkerClient> clientResourceInternal)

Specified by:

shouldGc in class DynamicResourcePool<BlockWorkerClient>

Parameters:

clientResourceInternal - the resource to check

Returns:

true if the resource should be garbage collected