Package org.apache.maven.surefire.booter.spi

Class SurefireMasterProcessChannelProcessorFactory

java.lang.Object

org.apache.maven.surefire.booter.spi.AbstractMasterProcessChannelProcessorFactory

org.apache.maven.surefire.booter.spi.SurefireMasterProcessChannelProcessorFactory

All Implemented Interfaces:

Closeable, AutoCloseable, MasterProcessChannelProcessorFactory

public class SurefireMasterProcessChannelProcessorFactory
extends AbstractMasterProcessChannelProcessorFactory

Producer of TCP/IP encoder and decoder.

Since:

3.0.0-M5

Field Summary

Fields

Modifier and Type	Field	Description
private AsynchronousSocketChannel	clientSocketChannel
private static final int	FLUSH_PERIOD_MILLIS

Constructor Summary

Constructors

Constructor	Description
SurefireMasterProcessChannelProcessorFactory()

Method Summary

Modifier and Type	Method	Description
boolean	canUse(String channelConfig)	Evaluates the channelConfig.
void	close()
void	connect(String channelConfig)	Open a new connection.
MasterProcessChannelDecoder	createDecoder(ForkNodeArguments forkingArguments)	Decoder factory method.
MasterProcessChannelEncoder	createEncoder(ForkNodeArguments forkingArguments)	Encoder factory method.
private static String	extractSessionId(URI uri)
private final void	setTrueOptions(SocketOption<Boolean>... options)

Methods inherited from class org.apache.maven.surefire.booter.spi.AbstractMasterProcessChannelProcessorFactory

schedulePeriodicFlusher

Methods inherited from class java.lang.Object

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

Field Details

FLUSH_PERIOD_MILLIS

private static final int FLUSH_PERIOD_MILLIS

See Also:

• Constant Field Values

clientSocketChannel

private volatile AsynchronousSocketChannel clientSocketChannel

Constructor Details

SurefireMasterProcessChannelProcessorFactory

public SurefireMasterProcessChannelProcessorFactory()

Method Details

canUse

public boolean canUse(String channelConfig)

Description copied from interface: MasterProcessChannelProcessorFactory

Evaluates the channelConfig.

Parameters:

channelConfig - a connection string used by the fork JVM

Returns:

true if channelConfig is applicable and thus this SPI is eligible in the fork

connect

public void connect(String channelConfig)
             throws IOException

Description copied from interface: MasterProcessChannelProcessorFactory

Open a new connection.

Parameters:

channelConfig - e.g. "pipe://3" or "tcp://localhost:65035"

Throws:

IOException - if cannot connect

createDecoder

public MasterProcessChannelDecoder createDecoder(@Nonnull
 ForkNodeArguments forkingArguments)

Description copied from interface: MasterProcessChannelProcessorFactory

Decoder factory method.

Parameters:

forkingArguments - forking arguments

Returns:

a new instance of decoder

createEncoder

public MasterProcessChannelEncoder createEncoder(@Nonnull
 ForkNodeArguments forkingArguments)

Description copied from interface: MasterProcessChannelProcessorFactory

Encoder factory method.

Parameters:

forkingArguments - forking arguments

Returns:

a new instance of encoder

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractMasterProcessChannelProcessorFactory

Throws:

IOException

setTrueOptions

@SafeVarargs
private final void setTrueOptions(SocketOption<Boolean>... options)
                           throws IOException

Throws:

IOException

extractSessionId

private static String extractSessionId(URI uri)