org.apache.tephra.visibility

Class DefaultFenceWait

java.lang.Object

org.apache.tephra.visibility.DefaultFenceWait

All Implemented Interfaces:

FenceWait

public class DefaultFenceWait
extends Object
implements FenceWait

Default implementation of FenceWait.

Method Summary

Methods

Modifier and Type	Method and Description
void	await(long timeout, TimeUnit timeUnit) Waits until the fence is complete, or till the timeout specified.

Methods inherited from class java.lang.Object

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

Method Detail

await

public void await(long timeout,
         TimeUnit timeUnit)
           throws TransactionFailureException,
                  InterruptedException,
                  TimeoutException

Description copied from interface: FenceWait

Waits until the fence is complete, or till the timeout specified. The fence wait transaction will get re-tried several times until the timeout.

If a fence wait times out then it means there are still some readers with in-progress transactions that have not seen the change. In this case the wait will have to be retried using the same FenceWait object.

Specified by:

await in interface FenceWait

Parameters:

timeout - Maximum time to wait

timeUnit - TimeUnit for timeout and sleepTime

Throws:

TransactionFailureException - when not able to start fence wait transaction

InterruptedException - on any interrupt

TimeoutException - when timeout is reached