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

Class ForkStarter

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.ForkStarter

public class ForkStarter
extends Object

Starts the fork or runs in-process.
Lives only on the plugin-side (not present in remote vms)
Knows how to fork new vms and also how to delegate non-forking invocation to SurefireStarter directly

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	ForkStarter.CloseableCloser	Closes stuff, with a shutdown hook to make sure things really get closed.
private final class	ForkStarter.ForkedNodeArg

Field Summary

Fields

Modifier and Type	Field	Description
private final Queue<ForkClient>	currentForkClients
private final Collection<DefaultReporterFactory>	defaultReporterFactories
private static final String	EXECUTION_EXCEPTION
private final ForkConfiguration	forkConfiguration
private static final ThreadFactory	FORKED_JVM_DAEMON_THREAD_FACTORY
private final int	forkedProcessTimeoutInSeconds
private final ConsoleLogger	log
private final Set<String>	logsAtEnd
private static final long	PING_IN_SECONDS
private final ScheduledExecutorService	pingThreadScheduler
private final ProviderConfiguration	providerConfiguration
private final ReportsMerger	reportMerger
private static final ThreadFactory	SHUTDOWN_HOOK_THREAD_FACTORY
private final StartupConfiguration	startupConfiguration
private final StartupReportConfiguration	startupReportConfiguration
private static final AtomicInteger	SYSTEM_PROPERTIES_FILE_COUNTER
private static final int	TIMEOUT_CHECK_PERIOD_MILLIS
private final ScheduledExecutorService	timeoutCheckScheduler

Constructor Summary

Constructors

Constructor	Description
ForkStarter(ProviderConfiguration providerConfiguration, StartupConfiguration startupConfiguration, ForkConfiguration forkConfiguration, int forkedProcessTimeoutInSeconds, StartupReportConfiguration startupReportConfiguration, ConsoleLogger log)

Method Summary

Modifier and Type	Method	Description
private static RunResult	awaitResultsDone(Collection<Future<RunResult>> results, ExecutorService executorService)
private static Stoppable	bindErrorStream(int forkNumber, CountdownCloseable countdownCloseable, CommandlineStreams streams, Object errorStreamLock)
private void	closeExecutor(ExecutorService executorService)
private static Thread	createCachableShutdownHookThread(TestLessInputStream.TestLessInputStreamBuilder builder, Shutdown shutdownType)
private static Thread	createImmediateShutdownHookThread(TestLessInputStream.TestLessInputStreamBuilder builder, Shutdown shutdownType)
private static ScheduledExecutorService	createPingScheduler()
private static Thread	createShutdownHookThread(Iterable<TestProvidingInputStream> streams, Shutdown shutdownType)
private static ScheduledExecutorService	createTimeoutCheckScheduler()
private RunResult	fork(Object testSet, PropertiesWrapper providerProperties, ForkClient forkClient, SurefireProperties effectiveSystemProperties, int forkNumber, AbstractCommandReader commandReader, ForkNodeFactory forkNodeFactory, boolean readTestsFromInStream)
private Iterable<Class<?>>	getSuitesIterator()
private boolean	hasSuiteXmlFiles()
private boolean	isForkOnce()
void	killOrphanForks()
private static void	notifyStreamsToSkipTests(Collection<? extends NotifiableTestStream> notifiableTestStreams)
private RunResult	run(SurefireProperties effectiveSystemProperties)
private RunResult	run(SurefireProperties effectiveSystemProps, Map<String,String> providerProperties)
RunResult	run(SurefireProperties effectiveSystemProperties, DefaultScanResult scanResult)
private RunResult	runSuitesForkOnceMultiple(SurefireProperties effectiveSystemProps, int forkCount)
private RunResult	runSuitesForkPerTestSet(SurefireProperties effectiveSystemProps, int forkCount)
private ScheduledFuture<?>	triggerPingTimerForShutdown(Iterable<TestProvidingInputStream> streams)
private ScheduledFuture<?>	triggerPingTimerForShutdown(TestLessInputStream.TestLessInputStreamBuilder builder)
private ScheduledFuture<?>	triggerTimeoutCheck()

Methods inherited from class java.lang.Object

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

Field Details

EXECUTION_EXCEPTION

private static final String EXECUTION_EXCEPTION

See Also:

• Constant Field Values

PING_IN_SECONDS

private static final long PING_IN_SECONDS

See Also:

• Constant Field Values

TIMEOUT_CHECK_PERIOD_MILLIS

private static final int TIMEOUT_CHECK_PERIOD_MILLIS

See Also:

• Constant Field Values

FORKED_JVM_DAEMON_THREAD_FACTORY

private static final ThreadFactory FORKED_JVM_DAEMON_THREAD_FACTORY

SHUTDOWN_HOOK_THREAD_FACTORY

private static final ThreadFactory SHUTDOWN_HOOK_THREAD_FACTORY

SYSTEM_PROPERTIES_FILE_COUNTER

private static final AtomicInteger SYSTEM_PROPERTIES_FILE_COUNTER

logsAtEnd

private final Set<String> logsAtEnd

pingThreadScheduler

private final ScheduledExecutorService pingThreadScheduler

timeoutCheckScheduler

private final ScheduledExecutorService timeoutCheckScheduler

currentForkClients

private final Queue<ForkClient> currentForkClients

forkedProcessTimeoutInSeconds

private final int forkedProcessTimeoutInSeconds

providerConfiguration

private final ProviderConfiguration providerConfiguration

startupConfiguration

private final StartupConfiguration startupConfiguration

forkConfiguration

private final ForkConfiguration forkConfiguration

startupReportConfiguration

private final StartupReportConfiguration startupReportConfiguration

log

private final ConsoleLogger log

reportMerger

private final ReportsMerger reportMerger

defaultReporterFactories

private final Collection<DefaultReporterFactory> defaultReporterFactories

Constructor Details

ForkStarter

public ForkStarter(ProviderConfiguration providerConfiguration,
 StartupConfiguration startupConfiguration,
 ForkConfiguration forkConfiguration,
 int forkedProcessTimeoutInSeconds,
 StartupReportConfiguration startupReportConfiguration,
 ConsoleLogger log)

Method Details

run

public RunResult run(@Nonnull
 SurefireProperties effectiveSystemProperties,
 @Nonnull
 DefaultScanResult scanResult)
              throws SurefireBooterForkException

Throws:

SurefireBooterForkException

killOrphanForks

public void killOrphanForks()

run

private RunResult run(SurefireProperties effectiveSystemProps,
 Map<String,String> providerProperties)
               throws SurefireBooterForkException

Throws:

SurefireBooterForkException

run

private RunResult run(SurefireProperties effectiveSystemProperties)
               throws SurefireBooterForkException

Throws:

SurefireBooterForkException

isForkOnce

private boolean isForkOnce()

hasSuiteXmlFiles

private boolean hasSuiteXmlFiles()

runSuitesForkOnceMultiple

private RunResult runSuitesForkOnceMultiple(SurefireProperties effectiveSystemProps,
 int forkCount)
                                     throws SurefireBooterForkException

Throws:

SurefireBooterForkException

notifyStreamsToSkipTests

private static void notifyStreamsToSkipTests(Collection<? extends NotifiableTestStream> notifiableTestStreams)

runSuitesForkPerTestSet

private RunResult runSuitesForkPerTestSet(SurefireProperties effectiveSystemProps,
 int forkCount)
                                   throws SurefireBooterForkException

Throws:

SurefireBooterForkException

awaitResultsDone

private static RunResult awaitResultsDone(Collection<Future<RunResult>> results,
 ExecutorService executorService)
                                   throws SurefireBooterForkException

Throws:

SurefireBooterForkException

closeExecutor

private void closeExecutor(ExecutorService executorService)
                    throws SurefireBooterForkException

Throws:

SurefireBooterForkException

fork

private RunResult fork(Object testSet,
 PropertiesWrapper providerProperties,
 ForkClient forkClient,
 SurefireProperties effectiveSystemProperties,
 int forkNumber,
 AbstractCommandReader commandReader,
 ForkNodeFactory forkNodeFactory,
 boolean readTestsFromInStream)
                throws SurefireBooterForkException

Throws:

SurefireBooterForkException

bindErrorStream

private static Stoppable bindErrorStream(int forkNumber,
 CountdownCloseable countdownCloseable,
 CommandlineStreams streams,
 Object errorStreamLock)

getSuitesIterator

private Iterable<Class<?>> getSuitesIterator()
                                      throws SurefireBooterForkException

Throws:

SurefireBooterForkException

createImmediateShutdownHookThread

private static Thread createImmediateShutdownHookThread(TestLessInputStream.TestLessInputStreamBuilder builder,
 Shutdown shutdownType)

createCachableShutdownHookThread

private static Thread createCachableShutdownHookThread(TestLessInputStream.TestLessInputStreamBuilder builder,
 Shutdown shutdownType)

createShutdownHookThread

private static Thread createShutdownHookThread(Iterable<TestProvidingInputStream> streams,
 Shutdown shutdownType)

createPingScheduler

private static ScheduledExecutorService createPingScheduler()

createTimeoutCheckScheduler

private static ScheduledExecutorService createTimeoutCheckScheduler()

triggerPingTimerForShutdown

private ScheduledFuture<?> triggerPingTimerForShutdown(TestLessInputStream.TestLessInputStreamBuilder builder)

triggerPingTimerForShutdown

private ScheduledFuture<?> triggerPingTimerForShutdown(Iterable<TestProvidingInputStream> streams)

triggerTimeoutCheck

private ScheduledFuture<?> triggerTimeoutCheck()