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

Class TestLessInputStream

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.TestLessInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, NotifiableTestStream

public final class TestLessInputStream
extends AbstractCommandStream

Dispatches commands without tests.

Since:

2.19

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestLessInputStream.TestLessInputStreamBuilder	Builds streams, registers cachable commands and provides accessible API to dispatch immediate commands to all atomically alive streams.

Field Summary

Fields

Modifier and Type	Field	Description
private final Semaphore	barrier
private final TestLessInputStream.TestLessInputStreamBuilder	builder
private Iterator<Command>	cachableCommands
private final AtomicBoolean	closed
private final Queue<Command>	immediateCommands

Constructor Summary

Constructors

Modifier	Constructor	Description
private	TestLessInputStream(TestLessInputStream.TestLessInputStreamBuilder builder)

Method Summary

Modifier and Type	Method	Description
void	acknowledgeByeEventReceived()
(package private) int	availablePermits()	For testing purposes only.
private void	awaitNextCommand()
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()	Notifies TestProvidingInputStream in order to dispatch a new test back to the forked jvm (particular fork which hits this call); or do nothing in TestLessInputStream.
void	shutdown(Shutdown shutdownType)
void	skipSinceNextTest()	Sends an event to a fork jvm in order to skip tests.

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, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Details

barrier

private final Semaphore barrier

closed

private final AtomicBoolean closed

immediateCommands

private final Queue<Command> immediateCommands

builder

private final TestLessInputStream.TestLessInputStreamBuilder builder

cachableCommands

private Iterator<Command> cachableCommands

Constructor Details

TestLessInputStream

private TestLessInputStream(TestLessInputStream.TestLessInputStreamBuilder builder)

Method Details

provideNewTest

public void provideNewTest()

Description copied from interface: NotifiableTestStream

Notifies TestProvidingInputStream in order to dispatch a new test back to the forked jvm (particular fork which hits this call); or do nothing in TestLessInputStream.

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()

isClosed

protected boolean isClosed()

Specified by:

isClosed in class AbstractCommandStream

nextCommand

protected Command nextCommand()

Specified by:

nextCommand in class AbstractCommandStream

beforeNextCommand

protected void beforeNextCommand()
                          throws 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:

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

availablePermits

int availablePermits()

For testing purposes only.

Returns:

permits used internally by beforeNextCommand()

awaitNextCommand

private void awaitNextCommand()
                       throws IOException

Throws:

IOException