Package org.apache.maven.surefire.booter

Class CommandReader

java.lang.Object

org.apache.maven.surefire.booter.CommandReader

public final class CommandReader
extends Object

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 int	iteratedCount
private static final String	LAST_TEST_SYMBOL
private final Queue<BiProperty<MasterProcessCommand,CommandListener>>	listeners
private ConsoleLogger	logger
private final Semaphore	nextCommandNotifier
private static final CommandReader	READER
private Shutdown	shutdown
private final CountDownLatch	startMonitor
private final AtomicReference<Thread.State>	state
private final CopyOnWriteArrayList<String>	testClasses

Constructor Summary

Constructors

Modifier	Constructor	Description
private	CommandReader()

Method Summary

Modifier and Type	Method	Description
void	addByeAckListener(CommandListener listener)
void	addListener(CommandListener listener)
private void	addListener(MasterProcessCommand cmd, CommandListener listener)
void	addNoopListener(CommandListener listener)
void	addShutdownListener(CommandListener listener)
void	addSkipNextTestsListener(CommandListener listener)
void	addTestListener(CommandListener listener)
void	addTestsFinishedListener(CommandListener listener)
private void	awaitNextTest()
boolean	awaitStarted()
(package private) Iterable<String>	getIterableClasses(ForkedChannelEncoder eventChannel)	The iterator can be used only in one Thread.
static CommandReader	getReader()
private boolean	insertToQueue(String test)
private boolean	isQueueFull()
private boolean	isStopped()
(package private) Iterator<String>	iterated()
private void	makeQueueFull()
void	removeListener(CommandListener listener)
CommandReader	setLogger(ConsoleLogger logger)
CommandReader	setShutdown(Shutdown shutdown)
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

READER

private static final CommandReader READER

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

shutdown

private volatile Shutdown shutdown

iteratedCount

private int iteratedCount

logger

private volatile ConsoleLogger logger

Constructor Details

CommandReader

private CommandReader()

Method Details

getReader

public static CommandReader getReader()

setShutdown

public CommandReader setShutdown(Shutdown shutdown)

setLogger

public CommandReader setLogger(ConsoleLogger logger)

awaitStarted

public boolean awaitStarted()
                     throws TestSetFailedException

Throws:

TestSetFailedException

addListener

public void addListener(CommandListener listener)

Parameters:

listener - listener called with Any command type

addTestListener

public void addTestListener(CommandListener listener)

addTestsFinishedListener

public void addTestsFinishedListener(CommandListener listener)

addSkipNextTestsListener

public void addSkipNextTestsListener(CommandListener listener)

addShutdownListener

public void addShutdownListener(CommandListener listener)

addNoopListener

public void addNoopListener(CommandListener listener)

addByeAckListener

public void addByeAckListener(CommandListener listener)

addListener

private void addListener(MasterProcessCommand cmd,
 CommandListener listener)

removeListener

public void removeListener(CommandListener listener)

iterated

Iterator<String> iterated()

Returns:

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

getIterableClasses

Iterable<String> getIterableClasses(ForkedChannelEncoder 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()