Package org.apache.drill.exec.testing

Class CountDownLatchInjectionImpl

java.lang.Object

org.apache.drill.exec.testing.Injection

org.apache.drill.exec.testing.CountDownLatchInjectionImpl

All Implemented Interfaces:

AutoCloseable, AutoCloseables.Closeable, CountDownLatchInjection

public class CountDownLatchInjectionImpl
extends Injection
implements CountDownLatchInjection

See CountDownLatchInjection Degenerates to PauseInjection.pause(), if initialized to zero count. In any case, this injection provides more control than PauseInjection.

Field Summary

Fields inherited from class org.apache.drill.exec.testing.Injection

address, desc, port, siteClass

Method Summary

Modifier and Type	Method	Description
void	await()	Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted.
void	awaitUninterruptibly()	Await without interruption.
void	close()	Close the latch.
void	countDown()	Decrements the count of the latch, releasing all waiting threads if the count reaches zero.
void	initialize(int count)	Initializes the underlying latch
protected boolean	injectNow()	This function checks if it is the right time for the injection to happen.

Methods inherited from class org.apache.drill.exec.testing.Injection

getDesc, getMsPause, getSiteClass, isValidForBit, toString

Methods inherited from class java.lang.Object

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

Method Details

injectNow

protected boolean injectNow()

Description copied from class: Injection

This function checks if it is the right time for the injection to happen.

Overrides:

injectNow in class Injection

Returns:

if the injection should be injected now

initialize

public void initialize(int count)

Description copied from interface: CountDownLatchInjection

Initializes the underlying latch

Specified by:

initialize in interface CountDownLatchInjection

Parameters:

count - the number of times CountDownLatchInjection.countDown() must be invoke before threads can pass through CountDownLatchInjection.await()

await

public void await()
           throws InterruptedException

Description copied from interface: CountDownLatchInjection

Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted.

Specified by:

await in interface CountDownLatchInjection

Throws:

InterruptedException

awaitUninterruptibly

public void awaitUninterruptibly()

Description copied from interface: CountDownLatchInjection

Await without interruption. In the case of interruption, log a warning and continue to wait.

Specified by:

awaitUninterruptibly in interface CountDownLatchInjection

countDown

public void countDown()

Description copied from interface: CountDownLatchInjection

Decrements the count of the latch, releasing all waiting threads if the count reaches zero.

Specified by:

countDown in interface CountDownLatchInjection

close

public void close()

Description copied from interface: CountDownLatchInjection

Close the latch.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface AutoCloseables.Closeable

Specified by:

close in interface CountDownLatchInjection