alluxio.retry

Class SleepingRetry

java.lang.Object

alluxio.retry.SleepingRetry

All Implemented Interfaces:

RetryPolicy

Direct Known Subclasses:

ExponentialBackoffRetry

@NotThreadSafe
public abstract class SleepingRetry
extends Object
implements RetryPolicy

A retry policy that uses thread sleeping for the delay.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SleepingRetry(int maxRetries)

Method Summary

Modifier and Type	Method and Description
boolean	attempt() Waits until it is time to perform the next retry, then returns.
int	getAttemptCount() How many retries have been performed.
protected abstract long	getSleepTime() How long to sleep before the next retry is performed.
protected TimeUnit	getSleepUnit() Unit of time that getSleepTime() is measured in.

Methods inherited from class java.lang.Object

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

Constructor Detail

SleepingRetry

protected SleepingRetry(int maxRetries)

Method Detail

getAttemptCount

public int getAttemptCount()

Description copied from interface: RetryPolicy

How many retries have been performed. If no retries have been performed, 0 is returned.

Specified by:

getAttemptCount in interface RetryPolicy

Returns:

number of retries performed

attempt

public boolean attempt()

Description copied from interface: RetryPolicy

Waits until it is time to perform the next retry, then returns. Returns false if no further retries should be performed. The first call to this method should never delay the caller, this allow users of the policy to use it in the context of a while-loop.

Specified by:

attempt in interface RetryPolicy

Returns:

whether another retry should be performed

getSleepUnit

protected TimeUnit getSleepUnit()

Unit of time that getSleepTime() is measured in. Defaults to TimeUnit.MILLISECONDS.

getSleepTime

protected abstract long getSleepTime()

How long to sleep before the next retry is performed. This method is used with getSleepUnit(), so all time given here must match the unit provided.