Package org.apache.hadoop.hbase.errorhandling

Class TimeoutExceptionInjector

java.lang.Object

org.apache.hadoop.hbase.errorhandling.TimeoutExceptionInjector

@Private
public class TimeoutExceptionInjector
extends Object

Time a given process/operation and report a failure if the elapsed time exceeds the max allowed time.

The timer won't start tracking time until calling start(). If complete() or trigger() is called before start(), calls to start() will fail.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	complete
private static final org.slf4j.Logger	LOG
private final long	maxTime
private long	start
private final Timer	timer
private final TimerTask	timerTask

Constructor Summary

Constructors

Constructor	Description
TimeoutExceptionInjector(ForeignExceptionListener listener, long maxTime)	Create a generic timer for a task/process.

Method Summary

Modifier and Type	Method	Description
void	complete()	For all time forward, do not throw an error because the process has completed.
long	getMaxTime()
void	start()	Start a timer to fail a process if it takes longer than the expected time to complete.
void	trigger()	Trigger the timer immediately.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

maxTime

private final long maxTime

complete

private volatile boolean complete

timer

private final Timer timer

timerTask

private final TimerTask timerTask

start

private long start

Constructor Details

TimeoutExceptionInjector

public TimeoutExceptionInjector(ForeignExceptionListener listener,
 long maxTime)

Create a generic timer for a task/process.

Parameters:

listener - listener to notify if the process times out

maxTime - max allowed running time for the process. Timer starts on calls to start()

Method Details

getMaxTime

public long getMaxTime()

complete

public void complete()

For all time forward, do not throw an error because the process has completed.

start

public void start()
           throws IllegalStateException

Start a timer to fail a process if it takes longer than the expected time to complete.

Non-blocking.

Throws:

IllegalStateException - if the timer has already been marked done via complete() or trigger()

trigger

public void trigger()

Trigger the timer immediately.

Exposed for testing.