Package org.apache.maven.surefire.booter
Class CommandReader
java.lang.Object
org.apache.maven.surefire.booter.CommandReader
Reader of commands coming from plugin(master) process.
- Since:
- 2.19
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate final class
private final class
private final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Thread
private int
private static final String
private final Queue<BiProperty<MasterProcessCommand,
CommandListener>> private ConsoleLogger
private final Semaphore
private static final CommandReader
private Shutdown
private final CountDownLatch
private final AtomicReference<Thread.State>
private final CopyOnWriteArrayList<String>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
boolean
getIterableClasses
(ForkedChannelEncoder eventChannel) The iterator can be used only in one Thread.static CommandReader
private boolean
insertToQueue
(String test) private boolean
private boolean
iterated()
private void
void
removeListener
(CommandListener listener) setLogger
(ConsoleLogger logger) setShutdown
(Shutdown shutdown) void
stop()
private void
-
Field Details
-
LAST_TEST_SYMBOL
- See Also:
-
READER
-
listeners
-
commandThread
-
state
-
startMonitor
-
nextCommandNotifier
-
testClasses
-
shutdown
-
iteratedCount
private int iteratedCount -
logger
-
-
Constructor Details
-
CommandReader
private CommandReader()
-
-
Method Details
-
getReader
-
setShutdown
-
setLogger
-
awaitStarted
- Throws:
TestSetFailedException
-
addListener
- Parameters:
listener
- listener called with Anycommand type
-
addTestListener
-
addTestsFinishedListener
-
addSkipNextTestsListener
-
addShutdownListener
-
addNoopListener
-
addByeAckListener
-
addListener
-
removeListener
-
iterated
- Returns:
- test classes which have been retrieved by
getIterableClasses(ForkedChannelEncoder)
.
-
getIterableClasses
The iterator can be used only in one Thread. Two simultaneous instances are not allowed for sake of only onenextCommandNotifier
.- 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
ifLAST_TEST_SYMBOL
found at the last index intestClasses
.
-
makeQueueFull
private void makeQueueFull() -
insertToQueue
-
awaitNextTest
private void awaitNextTest() -
wakeupIterator
private void wakeupIterator()
-