Package io.deephaven.engine.util.file

Class TrackedFileHandleFactory

java.lang.Object

io.deephaven.engine.util.file.TrackedFileHandleFactory

All Implemented Interfaces:

FileHandleFactory

public class TrackedFileHandleFactory
extends Object
implements FileHandleFactory

Simple least-recently-opened "cache" for FileHandles, to avoid running up against ulimits. Will probably not achieve satisfactory results if the number of file handles concurrently in active use exceeds capacity. Note that returned FileHandles may be closed asynchronously by the factory.

TODO: Consider adding a lookup to enable handle sharing. Not necessary for current usage.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.util.file.FileHandleFactory

FileHandleFactory.FileToHandleFunction, FileHandleFactory.OpenOptionsHelper

Field Summary

Fields

Modifier and Type	Field	Description
final FileHandleFactory.FileToHandleFunction	readOnlyHandleCreator
final FileHandleFactory.FileToHandleFunction	readWriteCreateHandleCreator
final FileHandleFactory.FileToHandleFunction	writeAppendCreateHandleCreator
final FileHandleFactory.FileToHandleFunction	writeTruncateCreateHandleCreator

Method Summary

Modifier and Type	Method	Description
void	closeAll()
int	getCapacity()
static TrackedFileHandleFactory	getInstance()
int	getSize()
double	getTargetUsageRatio()
int	getTargetUsageThreshold()
final @NotNull FileHandle	makeHandle(@NotNull File file, @NotNull OpenOption[] openOptions)	Create a new FileHandle with the specified set of OpenOptions.
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

readOnlyHandleCreator

public final FileHandleFactory.FileToHandleFunction readOnlyHandleCreator

readWriteCreateHandleCreator

public final FileHandleFactory.FileToHandleFunction readWriteCreateHandleCreator

writeAppendCreateHandleCreator

public final FileHandleFactory.FileToHandleFunction writeAppendCreateHandleCreator

writeTruncateCreateHandleCreator

public final FileHandleFactory.FileToHandleFunction writeTruncateCreateHandleCreator

Method Details

getInstance

public static TrackedFileHandleFactory getInstance()

getCapacity

public int getCapacity()

getTargetUsageRatio

public double getTargetUsageRatio()

getTargetUsageThreshold

public int getTargetUsageThreshold()

getSize

public int getSize()

makeHandle

@NotNull
public final @NotNull FileHandle makeHandle(@NotNull
 @NotNull File file,
 @NotNull
 @NotNull OpenOption[] openOptions)
                                     throws IOException

Description copied from interface: FileHandleFactory

Create a new FileHandle with the specified set of OpenOptions.

Specified by:

makeHandle in interface FileHandleFactory

Parameters:

file - The File to open

openOptions - The OpenOptions to use

Returns:

The new file handle

Throws:

IOException

closeAll

public void closeAll()

shutdown

public void shutdown()