Class RecoveryTimeouts

java.lang.Object

com.loomcache.server.persistence.RecoveryTimeouts

public final class RecoveryTimeouts
extends Object

Bounds persistence recovery phases so startup cannot block indefinitely.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	RecoveryTimeouts.RecoveryPair<A,B>
static interface	RecoveryTimeouts.RecoveryTask<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_DATA_LOAD_TIMEOUT_SECONDS
static final int	DEFAULT_PARALLELISM
static final long	DEFAULT_VALIDATION_TIMEOUT_SECONDS
static final int	MAX_PARALLELISM

Method Summary

Modifier and Type	Method	Description
static <T> T	run(String phaseName, long timeoutSeconds, int parallelism, RecoveryTimeouts.RecoveryTask<T> task)
static <T> T	run(String phaseName, long timeoutSeconds, RecoveryTimeouts.RecoveryTask<T> task)
static <A,B> RecoveryTimeouts.RecoveryPair<A,B>	runPair(String phaseName, long timeoutSeconds, int parallelism, RecoveryTimeouts.RecoveryTask<A> firstTask, RecoveryTimeouts.RecoveryTask<B> secondTask)
static void	validateParallelism(int parallelism, String fieldName)
static void	validateSeconds(long timeoutSeconds, String fieldName)

Methods inherited from class Object

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

Field Details

DEFAULT_VALIDATION_TIMEOUT_SECONDS

public static final long DEFAULT_VALIDATION_TIMEOUT_SECONDS

See Also:

• Constant Field Values

DEFAULT_DATA_LOAD_TIMEOUT_SECONDS

public static final long DEFAULT_DATA_LOAD_TIMEOUT_SECONDS

See Also:

• Constant Field Values

DEFAULT_PARALLELISM

public static final int DEFAULT_PARALLELISM

See Also:

• Constant Field Values

MAX_PARALLELISM

public static final int MAX_PARALLELISM

See Also:

• Constant Field Values

Method Details

validateSeconds

public static void validateSeconds(long timeoutSeconds,
 String fieldName)

validateParallelism

public static void validateParallelism(int parallelism,
 String fieldName)

run

public static <T> T run(String phaseName,
 long timeoutSeconds,
 RecoveryTimeouts.RecoveryTask<T> task)
                 throws IOException

Throws:

IOException

run

public static <T> T run(String phaseName,
 long timeoutSeconds,
 int parallelism,
 RecoveryTimeouts.RecoveryTask<T> task)
                 throws IOException

Throws:

IOException

runPair

public static <A,B>
RecoveryTimeouts.RecoveryPair<A,B> runPair(String phaseName,
 long timeoutSeconds,
 int parallelism,
 RecoveryTimeouts.RecoveryTask<A> firstTask,
 RecoveryTimeouts.RecoveryTask<B> secondTask)
                                    throws IOException

Throws:

IOException