org.apache.maven.plugin.surefire.booterclient.lazytestprovider

Class TestProvidingInputStream

java.lang.Object

java.io.InputStream

org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractForkInputStream

org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandStream

org.apache.maven.plugin.surefire.booterclient.lazytestprovider.TestProvidingInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, NotifiableTestStream

public final class TestProvidingInputStream
extends AbstractCommandStream

An InputStream that, when read, provides test class names out of a queue.
The Stream provides only one test at a time, but only after provideNewTest() has been invoked.
After providing each test class name, followed by a newline character, a flush is performed on the FlushReceiver provided by the FlushReceiverProvider that can be set using AbstractForkInputStream.setFlushReceiverProvider(FlushReceiverProvider).
The instance is used only in reusable forks in ForkStarter by one Thread.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.Semaphore	barrier
private java.util.concurrent.atomic.AtomicBoolean	closed
private java.util.Queue<Command>	commands
private java.util.Queue<java.lang.String>	testClassNames

Constructor Summary

Constructors

Constructor and Description
TestProvidingInputStream(java.util.Queue<java.lang.String> testClassNames) C'tor

Method Summary

Modifier and Type	Method and Description
void	acknowledgeByeEventReceived()
private void	awaitNextTest()
protected void	beforeNextCommand() Possibly waiting for next command (see AbstractCommandStream.nextCommand()) unless the stream is atomically closed (see AbstractCommandStream.isClosed() returns true) before this method has returned.
void	close()
protected boolean	isClosed()
protected Command	nextCommand()
void	noop()
void	provideNewTest() Signal that a new test is to be provided.
void	shutdown(Shutdown shutdownType)
void	skipSinceNextTest() Sends an event to a fork jvm in order to skip tests.
(package private) void	testSetFinished() For testing purposes.

Methods inherited from class org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandStream

canContinue, invalidateInternalBuffer, read

Methods inherited from class org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractForkInputStream

setFlushReceiverProvider, tryFlush

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

barrier

private final java.util.concurrent.Semaphore barrier

commands

private final java.util.Queue<Command> commands

closed

private final java.util.concurrent.atomic.AtomicBoolean closed

testClassNames

private final java.util.Queue<java.lang.String> testClassNames

Constructor Detail

TestProvidingInputStream

public TestProvidingInputStream(java.util.Queue<java.lang.String> testClassNames)

C'tor

Parameters:

testClassNames - source of the tests to be read from this stream

Method Detail

testSetFinished

void testSetFinished()

For testing purposes.

skipSinceNextTest

public void skipSinceNextTest()

Description copied from interface: NotifiableTestStream

Sends an event to a fork jvm in order to skip tests. Returns immediately without blocking.

shutdown

public void shutdown(Shutdown shutdownType)

noop

public void noop()

acknowledgeByeEventReceived

public void acknowledgeByeEventReceived()

nextCommand

protected Command nextCommand()

Specified by:

nextCommand in class AbstractCommandStream

beforeNextCommand

protected void beforeNextCommand()
                          throws java.io.IOException

Description copied from class: AbstractCommandStream

Possibly waiting for next command (see AbstractCommandStream.nextCommand()) unless the stream is atomically closed (see AbstractCommandStream.isClosed() returns true) before this method has returned.

Overrides:

beforeNextCommand in class AbstractCommandStream

Throws:

java.io.IOException - stream error while waiting for notification regarding next test required by forked jvm

isClosed

protected boolean isClosed()

Specified by:

isClosed in class AbstractCommandStream

provideNewTest

public void provideNewTest()

Signal that a new test is to be provided.

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

awaitNextTest

private void awaitNextTest()
                    throws java.io.IOException

Throws:

java.io.IOException