Package org.apache.maven.surefire.booter

Class CommandReader

java.lang.Object

org.apache.maven.surefire.booter.CommandReader

All Implemented Interfaces:

CommandChainReader

public final class CommandReader
extends Object
implements CommandChainReader

Reader of commands coming from plugin(master) process.

Since:

2.19

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	CommandReader.ClassesIterable
private final class	CommandReader.ClassesIterator
private final class	CommandReader.CommandRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private final Thread	commandThread
private final MasterProcessChannelDecoder	decoder
private int	iteratedCount
private static final String	LAST_TEST_SYMBOL
private final Queue<BiProperty<MasterProcessCommand,CommandListener>>	listeners
private final ConsoleLogger	logger
private final Semaphore	nextCommandNotifier
private final Shutdown	shutdown
private final CountDownLatch	startMonitor
private final AtomicReference<Thread.State>	state
private final CopyOnWriteArrayList<String>	testClasses

Constructor Summary

Constructors

Constructor	Description
CommandReader(MasterProcessChannelDecoder decoder, Shutdown shutdown, ConsoleLogger logger)

Method Summary

Modifier and Type	Method	Description
void	addByeAckListener(CommandListener listener)
private void	addListener(MasterProcessCommand cmd, CommandListener listener)
void	addNoopListener(CommandListener listener)
void	addShutdownListener(CommandListener listener)
void	addSkipNextTestsListener(CommandListener listener)
private void	awaitNextTest()
boolean	awaitStarted()
(package private) Iterable<String>	getIterableClasses(MasterProcessChannelEncoder eventChannel)	The iterator can be used only in one Thread.
private boolean	insertToQueue(String test)
private boolean	isQueueFull()
private boolean	isStopped()
(package private) Iterator<String>	iterated()
private void	makeQueueFull()
void	stop()
private void	wakeupIterator()

Methods inherited from class java.lang.Object

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

Field Details

LAST_TEST_SYMBOL

private static final String LAST_TEST_SYMBOL

See Also:

• Constant Field Values

listeners

private final Queue<BiProperty<MasterProcessCommand,CommandListener>> listeners

commandThread

private final Thread commandThread

state

private final AtomicReference<Thread.State> state

startMonitor

private final CountDownLatch startMonitor

nextCommandNotifier

private final Semaphore nextCommandNotifier

testClasses

private final CopyOnWriteArrayList<String> testClasses

decoder

private final MasterProcessChannelDecoder decoder

shutdown

private final Shutdown shutdown

logger

private final ConsoleLogger logger

iteratedCount

private int iteratedCount

Constructor Details

CommandReader

public CommandReader(MasterProcessChannelDecoder decoder,
 Shutdown shutdown,
 ConsoleLogger logger)

Method Details

awaitStarted

public boolean awaitStarted()
                     throws TestSetFailedException

Specified by:

awaitStarted in interface CommandChainReader

Throws:

TestSetFailedException

addSkipNextTestsListener

public void addSkipNextTestsListener(CommandListener listener)

Specified by:

addSkipNextTestsListener in interface CommandChainReader

addShutdownListener

public void addShutdownListener(CommandListener listener)

Specified by:

addShutdownListener in interface CommandChainReader

addNoopListener

public void addNoopListener(CommandListener listener)

addByeAckListener

public void addByeAckListener(CommandListener listener)

addListener

private void addListener(MasterProcessCommand cmd,
 CommandListener listener)

iterated

Iterator<String> iterated()

Returns:

test classes which have been retrieved by getIterableClasses(MasterProcessChannelEncoder).

getIterableClasses

Iterable<String> getIterableClasses(MasterProcessChannelEncoder eventChannel)

The iterator can be used only in one Thread. Two simultaneous instances are not allowed for sake of only one nextCommandNotifier.

Parameters:

eventChannel - original stream in current JVM process

Returns:

Iterator with test classes lazily loaded as commands from the main process

stop

public void stop()

isStopped

private boolean isStopped()

isQueueFull

private boolean isQueueFull()

Returns:

true if LAST_TEST_SYMBOL found at the last index in testClasses.

makeQueueFull

private void makeQueueFull()

insertToQueue

private boolean insertToQueue(String test)

awaitNextTest

private void awaitNextTest()

wakeupIterator

private void wakeupIterator()