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 -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Charset
Client charset extracted fromBootstrapEvent
.private final com.google.common.eventbus.EventBus
private final InputStream
private final long
private Long
A timestamp of last received event (GH-106).private final ClassLoader
private InputStream
private OutputStream
raw input stream to the client.private OutputStreamWriter
character-wrapped input stream to the client.private InputStream
private boolean
private final RandomAccessFile
private final OutputStream
private final OutputStream
private final OutputStream
private final PrintStream
private Thread
Watchdog thread if heartbeat is to be measured. -
Constructor Summary
ConstructorsConstructorDescriptionLocalSlaveStreamHandler
(com.google.common.eventbus.EventBus eventBus, ClassLoader classLoader, PrintStream warnStream, InputStream eventStream, OutputStream sysout, OutputStream syserr, long heartbeat, RandomAccessFile streamsBuffer) -
Method Summary
Modifier and TypeMethodDescription(package private) void
pumpEvents
(InputStream eventStream) Pump events from event stream.void
void
void
void
start()
void
stop()
-
Field Details
-
eventBus
private final com.google.common.eventbus.EventBus eventBus -
refLoader
-
stdout
-
stderr
-
stdin
raw input stream to the client. -
stdinWriter
character-wrapped input stream to the client. -
warnStream
-
eventStream
-
stopping
private volatile boolean stopping -
pumpers
-
sysout
-
syserr
-
heartbeat
private final long heartbeat -
streamsBuffer
-
streamsBufferWrapper
-
lastActivity
A timestamp of last received event (GH-106). -
watchdog
Watchdog thread if heartbeat is to be measured. -
clientCharset
Client charset extracted fromBootstrapEvent
.
-
-
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
- Specified by:
setProcessErrorStream
in interfaceorg.apache.tools.ant.taskdefs.ExecuteStreamHandler
- Throws:
IOException
-
setProcessOutputStream
- Specified by:
setProcessOutputStream
in interfaceorg.apache.tools.ant.taskdefs.ExecuteStreamHandler
- Throws:
IOException
-
setProcessInputStream
- Specified by:
setProcessInputStream
in interfaceorg.apache.tools.ant.taskdefs.ExecuteStreamHandler
- Throws:
IOException
-
start
- Specified by:
start
in interfaceorg.apache.tools.ant.taskdefs.ExecuteStreamHandler
- Throws:
IOException
-
pumpEvents
Pump events from event stream. -
stop
public void stop()- Specified by:
stop
in interfaceorg.apache.tools.ant.taskdefs.ExecuteStreamHandler
-