alluxio.client.file

Class FileSystemMasterClientPool

java.lang.Object

alluxio.resource.DynamicResourcePool<FileSystemMasterClient>

alluxio.client.file.FileSystemMasterClientPool

All Implemented Interfaces:

Pool<FileSystemMasterClient>, Closeable, AutoCloseable

@ThreadSafe
public final class FileSystemMasterClientPool
extends DynamicResourcePool<FileSystemMasterClient>

A fixed pool of FileSystemMasterClient instances.

Nested Class Summary

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

DynamicResourcePool.Options, DynamicResourcePool.ResourceInternal<R>

Field Summary

Fields inherited from class alluxio.resource.DynamicResourcePool

mClock

Constructor Summary

Constructors

Constructor and Description
FileSystemMasterClientPool(Subject subject, MasterInquireClient masterInquireClient) Creates a new file system master client pool.
FileSystemMasterClientPool(Subject subject, MasterInquireClient masterInquireClient, int clientThreads) Creates a new file system master client pool.

Method Summary

Modifier and Type	Method and Description
protected void	closeResource(FileSystemMasterClient client) Closes the resource.
protected void	closeResourceSync(FileSystemMasterClient client) Similar as above but this guarantees that the resource is closed after the function returns unless it fails to close.
protected FileSystemMasterClient	createNewResource() Creates a new resource.
protected boolean	isHealthy(FileSystemMasterClient client) Checks whether a resource is healthy or not.
protected boolean	shouldGc(DynamicResourcePool.ResourceInternal<FileSystemMasterClient> 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

Constructor Detail

FileSystemMasterClientPool

public FileSystemMasterClientPool(Subject subject,
                                  MasterInquireClient masterInquireClient)

Creates a new file system master client pool.

Parameters:

subject - the parent subject

masterInquireClient - a client for determining the master address

FileSystemMasterClientPool

public FileSystemMasterClientPool(Subject subject,
                                  MasterInquireClient masterInquireClient,
                                  int clientThreads)

Creates a new file system master client pool.

Parameters:

subject - the parent subject

masterInquireClient - a client for determining the master address

clientThreads - the number of client threads to use

Method Detail

closeResource

protected void closeResource(FileSystemMasterClient client)

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

Parameters:

client - the resource to close

closeResourceSync

protected void closeResourceSync(FileSystemMasterClient client)

Description copied from class: DynamicResourcePool

Similar as above but this guarantees that the resource is closed after the function returns unless it fails to close.

Specified by:

closeResourceSync in class DynamicResourcePool<FileSystemMasterClient>

Parameters:

client - the resource to close

createNewResource

protected FileSystemMasterClient createNewResource()

Description copied from class: DynamicResourcePool

Creates a new resource.

Specified by:

createNewResource in class DynamicResourcePool<FileSystemMasterClient>

Returns:

the newly created resource

isHealthy

protected boolean isHealthy(FileSystemMasterClient client)

Description copied from class: DynamicResourcePool

Checks whether a resource is healthy or not.

Specified by:

isHealthy in class DynamicResourcePool<FileSystemMasterClient>

Parameters:

client - the resource to check

Returns:

true if the resource is healthy

shouldGc

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

Specified by:

shouldGc in class DynamicResourcePool<FileSystemMasterClient>

Parameters:

clientResourceInternal - the resource to check

Returns:

true if the resource should be garbage collected