Class LocalSlaveStreamHandler

java.lang.Object

com.carrotsearch.ant.tasks.junit4.LocalSlaveStreamHandler

All Implemented Interfaces:

org.apache.tools.ant.taskdefs.ExecuteStreamHandler

public class LocalSlaveStreamHandler
extends Object
implements org.apache.tools.ant.taskdefs.ExecuteStreamHandler

Establish event passing with a subprocess and pump events to the bus.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	LocalSlaveStreamHandler.OnDiskStreamEvent

Field Summary

Fields

Modifier and Type	Field	Description
private Charset	clientCharset	Client charset extracted from BootstrapEvent.
private final com.google.common.eventbus.EventBus	eventBus
private final InputStream	eventStream
private final long	heartbeat
private Long	lastActivity	A timestamp of last received event (GH-106).
private List<Thread>	pumpers
private final ClassLoader	refLoader
private InputStream	stderr
private OutputStream	stdin	raw input stream to the client.
private OutputStreamWriter	stdinWriter	character-wrapped input stream to the client.
private InputStream	stdout
private boolean	stopping
private final RandomAccessFile	streamsBuffer
private final OutputStream	streamsBufferWrapper
private final OutputStream	syserr
private final OutputStream	sysout
private final PrintStream	warnStream
private Thread	watchdog	Watchdog thread if heartbeat is to be measured.

Constructor Summary

Constructors

Constructor	Description
LocalSlaveStreamHandler(com.google.common.eventbus.EventBus eventBus, ClassLoader classLoader, PrintStream warnStream, InputStream eventStream, OutputStream sysout, OutputStream syserr, long heartbeat, RandomAccessFile streamsBuffer)

Method Summary

Modifier and Type	Method	Description
(package private) void	pumpEvents(InputStream eventStream)	Pump events from event stream.
void	setProcessErrorStream(InputStream is)
void	setProcessInputStream(OutputStream os)
void	setProcessOutputStream(InputStream is)
void	start()
void	stop()

Methods inherited from class Object

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

Field Details

eventBus

private final com.google.common.eventbus.EventBus eventBus

refLoader

private final ClassLoader refLoader

stdout

private InputStream stdout

stderr

private InputStream stderr

stdin

private OutputStream stdin

raw input stream to the client.

stdinWriter

private OutputStreamWriter stdinWriter

character-wrapped input stream to the client.

warnStream

private final PrintStream warnStream

eventStream

private final InputStream eventStream

stopping

private volatile boolean stopping

pumpers

private List<Thread> pumpers

sysout

private final OutputStream sysout

syserr

private final OutputStream syserr

heartbeat

private final long heartbeat

streamsBuffer

private final RandomAccessFile streamsBuffer

streamsBufferWrapper

private final OutputStream streamsBufferWrapper

lastActivity

private volatile Long lastActivity

A timestamp of last received event (GH-106).

watchdog

private Thread watchdog

Watchdog thread if heartbeat is to be measured.

clientCharset

private Charset clientCharset

Client charset extracted from BootstrapEvent.

Constructor Details

LocalSlaveStreamHandler

public LocalSlaveStreamHandler(com.google.common.eventbus.EventBus eventBus,
 ClassLoader classLoader,
 PrintStream warnStream,
 InputStream eventStream,
 OutputStream sysout,
 OutputStream syserr,
 long heartbeat,
 RandomAccessFile streamsBuffer)

Method Details

setProcessErrorStream

public void setProcessErrorStream(InputStream is)
                           throws IOException

Specified by:

setProcessErrorStream in interface org.apache.tools.ant.taskdefs.ExecuteStreamHandler

Throws:

IOException

setProcessOutputStream

public void setProcessOutputStream(InputStream is)
                            throws IOException

Specified by:

setProcessOutputStream in interface org.apache.tools.ant.taskdefs.ExecuteStreamHandler

Throws:

IOException

setProcessInputStream

public void setProcessInputStream(OutputStream os)
                           throws IOException

Specified by:

setProcessInputStream in interface org.apache.tools.ant.taskdefs.ExecuteStreamHandler

Throws:

IOException

start

public void start()
           throws IOException

Specified by:

start in interface org.apache.tools.ant.taskdefs.ExecuteStreamHandler

Throws:

IOException

pumpEvents

void pumpEvents(InputStream eventStream)

Pump events from event stream.

stop

public void stop()

Specified by:

stop in interface org.apache.tools.ant.taskdefs.ExecuteStreamHandler