alluxio.heartbeat

Class FixedIntervalSupplier

java.lang.Object

alluxio.heartbeat.FixedIntervalSupplier

All Implemented Interfaces:

SleepIntervalSupplier

public class FixedIntervalSupplier
extends Object
implements SleepIntervalSupplier

Fixed interval supplier.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	mLogger

Constructor Summary

Constructors

Constructor and Description
FixedIntervalSupplier(long fixedInterval) Constructs a new FixedIntervalSupplier.
FixedIntervalSupplier(long fixedInterval, org.slf4j.Logger logger) Constructs a new FixedIntervalSupplier.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getNextInterval(long previousTickedMs, long nowTimeStampMillis) Gets the next interval for sleeping.
long	getRunLimit(long previousTickedMs) Gets the run limit from previous ticked.
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

mLogger

protected final org.slf4j.Logger mLogger

Constructor Detail

FixedIntervalSupplier

public FixedIntervalSupplier(long fixedInterval,
                             org.slf4j.Logger logger)

Constructs a new FixedIntervalSupplier.

Parameters:

fixedInterval - the fixed interval

logger - the logger

FixedIntervalSupplier

public FixedIntervalSupplier(long fixedInterval)

Constructs a new FixedIntervalSupplier.

Parameters:

fixedInterval - the fixed interval

Method Detail

getNextInterval

public long getNextInterval(long previousTickedMs,
                            long nowTimeStampMillis)

Description copied from interface: SleepIntervalSupplier

Gets the next interval for sleeping.

Specified by:

getNextInterval in interface SleepIntervalSupplier

Parameters:

previousTickedMs - previous ticked time stamp in millisecond

nowTimeStampMillis - current time stamp in millisecond

Returns:

the interval to sleep starting from now before next time the timer triggers

getRunLimit

public long getRunLimit(long previousTickedMs)

Description copied from interface: SleepIntervalSupplier

Gets the run limit from previous ticked.

Specified by:

getRunLimit in interface SleepIntervalSupplier

Parameters:

previousTickedMs - previous ticked time stamp in millisecond

Returns:

the run limit

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object