Package org.terracotta.utilities.io

Class Files.RetryingDeleteTask

java.lang.Object

java.util.concurrent.FutureTask<Void>

org.terracotta.utilities.io.Files.RetryingDeleteTask

All Implemented Interfaces:

Runnable, Future<Void>, RunnableFuture<Void>

Enclosing class:

Files

private static class Files.RetryingDeleteTask
extends FutureTask<Void>

Task to perform a background deletion. This task resubmits itself if the deletion, after retry, fails delete the file/directory.

Field Summary

Fields

Modifier and Type	Field	Description
private final Path	deletionPath
private final ExecutorService	executor
private static final int	LOGGING_SUPPRESSION_FACTOR
private final Runnable	progressHelper
private final boolean	retryDirNotEmpty
private final Predicate<FileSystemException>	shouldLog
private final Callable<Void>	task

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RetryingDeleteTask(ExecutorService executor, Callable<Void> deletionTask, Path deletionPath, boolean retryDirNotEmpty, Runnable progressHelper)

Method Summary

Modifier and Type	Method	Description
private void	logFailedAttempt(FileSystemException t)
void	run()

Methods inherited from class java.util.concurrent.FutureTask

cancel, done, get, get, isCancelled, isDone, runAndReset, set, setException, toString

Methods inherited from class java.lang.Object

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

Field Details

LOGGING_SUPPRESSION_FACTOR

private static final int LOGGING_SUPPRESSION_FACTOR

See Also:

• Constant Field Values

executor

private final ExecutorService executor

task

private final Callable<Void> task

deletionPath

private final Path deletionPath

retryDirNotEmpty

private final boolean retryDirNotEmpty

progressHelper

private final Runnable progressHelper

shouldLog

private final Predicate<FileSystemException> shouldLog

Constructor Details

RetryingDeleteTask

private RetryingDeleteTask(ExecutorService executor,
 Callable<Void> deletionTask,
 Path deletionPath,
 boolean retryDirNotEmpty,
 Runnable progressHelper)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<Void>

Overrides:

run in class FutureTask<Void>

logFailedAttempt

private void logFailedAttempt(FileSystemException t)