Package org.apache.jackrabbit.oak.plugins.atomic

Class AtomicCounterEditor.ConsolidatorTask

java.lang.Object

org.apache.jackrabbit.oak.plugins.atomic.AtomicCounterEditor.ConsolidatorTask

All Implemented Interfaces:

Callable<Void>

Enclosing class:

AtomicCounterEditor

public static class AtomicCounterEditor.ConsolidatorTask
extends Object
implements Callable<Void>

Field Summary

Fields

Modifier and Type	Field	Description
static long	MAX_TIMEOUT	millis over which the task will timeout
static long	MIN_TIMEOUT	millis below which the next delay will schedule at this amount.

Constructor Summary

Constructors

Constructor	Description
ConsolidatorTask(@NotNull String path, @Nullable PropertyState revision, @NotNull NodeStore store, @NotNull ScheduledExecutorService exec, long delay, @NotNull CommitHook hook)

Method Summary

Modifier and Type	Method	Description
Void	call()
String	getName()
static boolean	isTimedOut(long delay)
static long	nextDelay(long currentDelay)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_TIMEOUT

public static final long MAX_TIMEOUT

millis over which the task will timeout

MIN_TIMEOUT

public static final long MIN_TIMEOUT

millis below which the next delay will schedule at this amount.

See Also:

Constant Field Values

Constructor Detail

ConsolidatorTask

public ConsolidatorTask(@NotNull
                        @NotNull String path,
                        @Nullable
                        @Nullable PropertyState revision,
                        @NotNull
                        @NotNull NodeStore store,
                        @NotNull
                        @NotNull ScheduledExecutorService exec,
                        long delay,
                        @NotNull
                        @NotNull CommitHook hook)

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

nextDelay

public static long nextDelay(long currentDelay)

isTimedOut

public static boolean isTimedOut(long delay)

getName

public String getName()