Package org.apache.maven.plugin.surefire.extensions

Class SurefireForkChannel

java.lang.Object

org.apache.maven.surefire.extensions.ForkChannel

org.apache.maven.plugin.surefire.extensions.SurefireForkChannel

All Implemented Interfaces:

Closeable, AutoCloseable

final class SurefireForkChannel
extends ForkChannel

The TCP/IP server accepting only one client connection. The forked JVM connects to the server using the connection string. The main purpose of this class is to conect with tthe client, bind the command reader to the internal socket's InputStream, and bind the event handler writing the event objects to the event handler.
The objects WritableByteChannel and ReadableByteChannel are forked process streams (standard input and output). Both are ignored in this implementation but they are used in LegacyForkChannel.
The channel is closed after the forked JVM has finished normally or the shutdown hook is executed in the plugin.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	SurefireForkChannel.Bindings
private class	SurefireForkChannel.CommandBindings
private class	SurefireForkChannel.EventBindings

Field Summary

Fields

Modifier and Type	Field	Description
private final SurefireForkChannel.Bindings	bindings
private SurefireForkChannel.CommandBindings	commandBindings
private CloseableDaemonThread	commandReaderBindings
private SurefireForkChannel.EventBindings	eventBindings
private CloseableDaemonThread	eventHandlerBindings
private final String	localHost
private final int	localPort
private LineConsumerThread	out
private final AsynchronousServerSocketChannel	server
private Future<AsynchronousSocketChannel>	session
private final String	sessionId
private static final ExecutorService	THREAD_POOL

Constructor Summary

Constructors

Constructor	Description
SurefireForkChannel(ForkNodeArguments arguments)

Method Summary

Modifier and Type	Method	Description
void	bindCommandReader(CommandReader commands, WritableByteChannel stdIn)	Binds command handler to the channel.
void	bindEventHandler(EventHandler<Event> eventHandler, CountdownCloseable countdown, ReadableByteChannel stdOut)	Starts a Thread reading the events.
void	close()
void	disable()
private AsynchronousSocketChannel	getChannel()
int	getCountdownCloseablePermits()	the permits in CountdownCloseable.
String	getForkNodeConnectionString()	This is server related class, which if binds to a TCP port, determines the connection string for the client.
private final void	setTrueOptions(SocketOption<Boolean>... options)
void	tryConnectToClient()	Asynchronously connects to the client.
private void	verifySessionId()

Methods inherited from class org.apache.maven.surefire.extensions.ForkChannel

getArguments

Methods inherited from class java.lang.Object

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

Field Details

THREAD_POOL

private static final ExecutorService THREAD_POOL

server

private final AsynchronousServerSocketChannel server

localHost

private final String localHost

localPort

private final int localPort

sessionId

private final String sessionId

bindings

private final SurefireForkChannel.Bindings bindings

session

private volatile Future<AsynchronousSocketChannel> session

out

private volatile LineConsumerThread out

commandReaderBindings

private volatile CloseableDaemonThread commandReaderBindings

eventHandlerBindings

private volatile CloseableDaemonThread eventHandlerBindings

eventBindings

private volatile SurefireForkChannel.EventBindings eventBindings

commandBindings

private volatile SurefireForkChannel.CommandBindings commandBindings

Constructor Details

SurefireForkChannel

SurefireForkChannel(@Nonnull
 ForkNodeArguments arguments)
             throws IOException

Throws:

IOException

Method Details

tryConnectToClient

public void tryConnectToClient()

Description copied from class: ForkChannel

Asynchronously connects to the client.

Specified by:

tryConnectToClient in class ForkChannel

getForkNodeConnectionString

public String getForkNodeConnectionString()

Description copied from class: ForkChannel

This is server related class, which if binds to a TCP port, determines the connection string for the client.

Specified by:

getForkNodeConnectionString in class ForkChannel

Returns:

a connection string utilized by the client in the fork JVM

getCountdownCloseablePermits

public int getCountdownCloseablePermits()

Description copied from class: ForkChannel

the permits in CountdownCloseable.

Specified by:

getCountdownCloseablePermits in class ForkChannel

bindCommandReader

public void bindCommandReader(@Nonnull
 CommandReader commands,
 WritableByteChannel stdIn)
                       throws IOException,
InterruptedException

Description copied from class: ForkChannel

Binds command handler to the channel. Starts a Thread streaming out the commands.

Specified by:

bindCommandReader in class ForkChannel

Parameters:

commands - command reader, see CommandReader.readNextCommand()

stdIn - optional standard input stream of the JVM to write the encoded commands into it

Throws:

IOException - if an error in the fork channel

InterruptedException - channel interrupted

bindEventHandler

public void bindEventHandler(@Nonnull
 EventHandler<Event> eventHandler,
 @Nonnull
 CountdownCloseable countdown,
 ReadableByteChannel stdOut)
                      throws IOException,
InterruptedException

Description copied from class: ForkChannel

Starts a Thread reading the events.

Specified by:

bindEventHandler in class ForkChannel

Parameters:

eventHandler - event eventHandler

countdown - count down of the final call of Closeable.close()

stdOut - optional standard output stream of the JVM

Throws:

IOException - if an error in the fork channel

InterruptedException - channel interrupted

disable

public void disable()

Specified by:

disable in class ForkChannel

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class ForkChannel

Throws:

IOException

verifySessionId

private void verifySessionId()
                      throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

setTrueOptions

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

Throws:

IOException

getChannel

private AsynchronousSocketChannel getChannel()
                                      throws InterruptedException,
IOException

Throws:

InterruptedException

IOException