Package org.apache.hadoop.hbase

Class GenericTestUtils.DelayAnswer

java.lang.Object

org.apache.hadoop.hbase.GenericTestUtils.DelayAnswer

All Implemented Interfaces:

org.mockito.stubbing.Answer<Object>

Enclosing class:

GenericTestUtils

public static class GenericTestUtils.DelayAnswer
extends Object
implements org.mockito.stubbing.Answer<Object>

Mockito answer helper that triggers one latch as soon as the method is called, then waits on another before continuing.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	fireCounter
private final CountDownLatch	fireLatch
private final org.slf4j.Logger	LOG
private final AtomicInteger	resultCounter
private final CountDownLatch	resultLatch
private Object	returnValue
private Throwable	thrown
private final CountDownLatch	waitLatch

Constructor Summary

Constructors

Constructor	Description
DelayAnswer(org.slf4j.Logger log)

Method Summary

Modifier and Type	Method	Description
Object	answer(org.mockito.invocation.InvocationOnMock invocation)
int	getFireCount()
int	getResultCount()
Object	getReturnValue()	After the call has gone through, return the call's return value, or null in case it was void or an exception was thrown.
Throwable	getThrown()	After the call has gone through, return any exception that was thrown, or null if no exception was thrown.
protected Object	passThrough(org.mockito.invocation.InvocationOnMock invocation)
void	proceed()	Tell the method to proceed.
void	waitForCall()	Wait until the method is called.
void	waitForResult()	After calling proceed(), this will wait until the call has completed and a result has been returned to the caller.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private final org.slf4j.Logger LOG

fireLatch

private final CountDownLatch fireLatch

waitLatch

private final CountDownLatch waitLatch

resultLatch

private final CountDownLatch resultLatch

fireCounter

private final AtomicInteger fireCounter

resultCounter

private final AtomicInteger resultCounter

thrown

private volatile Throwable thrown

returnValue

private volatile Object returnValue

Constructor Details

DelayAnswer

public DelayAnswer(org.slf4j.Logger log)

Method Details

waitForCall

public void waitForCall()
                 throws InterruptedException

Wait until the method is called.

Throws:

InterruptedException

proceed

public void proceed()

Tell the method to proceed. This should only be called after waitForCall()

answer

public Object answer(org.mockito.invocation.InvocationOnMock invocation)
              throws Throwable

Specified by:

answer in interface org.mockito.stubbing.Answer<Object>

Throws:

Throwable

passThrough

protected Object passThrough(org.mockito.invocation.InvocationOnMock invocation)
                      throws Throwable

Throws:

Throwable

waitForResult

public void waitForResult()
                   throws InterruptedException

After calling proceed(), this will wait until the call has completed and a result has been returned to the caller.

Throws:

InterruptedException

getThrown

public Throwable getThrown()

After the call has gone through, return any exception that was thrown, or null if no exception was thrown.

getReturnValue

public Object getReturnValue()

After the call has gone through, return the call's return value, or null in case it was void or an exception was thrown.

getFireCount

public int getFireCount()

getResultCount

public int getResultCount()