Package org.apache.maven.surefire.stream

Class EventDecoder

java.lang.Object

org.apache.maven.surefire.api.stream.AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

org.apache.maven.surefire.stream.EventDecoder

All Implemented Interfaces:

AutoCloseable

public class EventDecoder
extends AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

AbstractStreamDecoder.BufferedStream, AbstractStreamDecoder.MalformedFrameException, AbstractStreamDecoder.Memento, AbstractStreamDecoder.Segment, AbstractStreamDecoder.StreamReadStatus

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEBUG_SINK_BUFFER_SIZE
private final OutputStream	debugSink
private static final SegmentType[]	EVENT_TEST_CONTROL
private static final Map<AbstractStreamDecoder.Segment,ForkedProcessEventType>	EVENT_TYPES
private static final SegmentType[]	EVENT_WITH_ERROR_TRACE
private static final SegmentType[]	EVENT_WITH_ONE_STRING
private static final SegmentType[]	EVENT_WITH_RUNMODE_TID_AND_ONE_STRING
private static final SegmentType[]	EVENT_WITH_RUNMODE_TID_AND_TWO_STRINGS
private static final SegmentType[]	EVENT_WITHOUT_DATA
private static final int	NO_POSITION
private static final Map<AbstractStreamDecoder.Segment,RunMode>	RUN_MODES

Fields inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
EventDecoder(ReadableByteChannel channel, ForkNodeArguments arguments)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	debugStream(byte[] array, int position, int remaining)
Event	decode(AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>.Memento memento)
protected final byte[]	getEncodedMagicNumber()
private OutputStream	newDebugSink(ForkNodeArguments arguments)
(package private) static TestSetReportEntry	newReportEntry(RunMode runMode, long testRunId, String source, String sourceText, String name, String nameText, String group, String message, Integer timeElapsed, String traceMessage, String smartTrimmedStackTrace, String stackTrace)
protected final SegmentType[]	nextSegmentType(ForkedProcessEventType eventType)
private static Map<AbstractStreamDecoder.Segment,ForkedProcessEventType>	segmentsToEvents()
private static Map<AbstractStreamDecoder.Segment,RunMode>	segmentsToRunModes()
protected final Event	toMessage(ForkedProcessEventType eventType, AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>.Memento memento)
private static TestSetReportEntry	toReportEntry(List<Object> args)
private static StackTraceWriter	toStackTraceWriter(List<Object> args)
private static StackTraceWriter	toTrace(String traceMessage, String smartTrimmedStackTrace, String stackTrace)

Methods inherited from class org.apache.maven.surefire.api.stream.AbstractStreamDecoder

checkArguments, checkDelimiter, checkHeader, getArguments, printRemainingStream, read, readByte, readCharset, readInt, readInteger, readLong, readLongPrivate, readMessageType, readSegment, readString

Methods inherited from class java.lang.Object

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

Field Details

DEBUG_SINK_BUFFER_SIZE

private static final int DEBUG_SINK_BUFFER_SIZE

See Also:

• Constant Field Values

EVENT_TYPES

private static final Map<AbstractStreamDecoder.Segment,ForkedProcessEventType> EVENT_TYPES

RUN_MODES

private static final Map<AbstractStreamDecoder.Segment,RunMode> RUN_MODES

EVENT_WITHOUT_DATA

private static final SegmentType[] EVENT_WITHOUT_DATA

EVENT_WITH_ERROR_TRACE

private static final SegmentType[] EVENT_WITH_ERROR_TRACE

EVENT_WITH_ONE_STRING

private static final SegmentType[] EVENT_WITH_ONE_STRING

EVENT_WITH_RUNMODE_TID_AND_ONE_STRING

private static final SegmentType[] EVENT_WITH_RUNMODE_TID_AND_ONE_STRING

EVENT_WITH_RUNMODE_TID_AND_TWO_STRINGS

private static final SegmentType[] EVENT_WITH_RUNMODE_TID_AND_TWO_STRINGS

EVENT_TEST_CONTROL

private static final SegmentType[] EVENT_TEST_CONTROL

NO_POSITION

private static final int NO_POSITION

See Also:

• Constant Field Values

debugSink

private final OutputStream debugSink

Constructor Details

EventDecoder

public EventDecoder(@Nonnull
 ReadableByteChannel channel,
 @Nonnull
 ForkNodeArguments arguments)

Method Details

decode

public Event decode(@Nonnull
 AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>.Memento memento)
             throws IOException

Specified by:

decode in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Throws:

IOException

getEncodedMagicNumber

@Nonnull
protected final byte[] getEncodedMagicNumber()

Specified by:

getEncodedMagicNumber in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

nextSegmentType

@Nonnull
protected final SegmentType[] nextSegmentType(@Nonnull
 ForkedProcessEventType eventType)

Specified by:

nextSegmentType in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

toMessage

@Nonnull
protected final Event toMessage(@Nonnull
 ForkedProcessEventType eventType,
 @Nonnull
 AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>.Memento memento)
                         throws AbstractStreamDecoder.MalformedFrameException

Specified by:

toMessage in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

Throws:

AbstractStreamDecoder.MalformedFrameException

toReportEntry

@Nonnull
private static TestSetReportEntry toReportEntry(List<Object> args)

toStackTraceWriter

private static StackTraceWriter toStackTraceWriter(List<Object> args)

toTrace

private static StackTraceWriter toTrace(String traceMessage,
 String smartTrimmedStackTrace,
 String stackTrace)

newReportEntry

static TestSetReportEntry newReportEntry(RunMode runMode,
 long testRunId,
 String source,
 String sourceText,
 String name,
 String nameText,
 String group,
 String message,
 Integer timeElapsed,
 String traceMessage,
 String smartTrimmedStackTrace,
 String stackTrace)
                                  throws NumberFormatException

Throws:

NumberFormatException

segmentsToEvents

private static Map<AbstractStreamDecoder.Segment,ForkedProcessEventType> segmentsToEvents()

segmentsToRunModes

private static Map<AbstractStreamDecoder.Segment,RunMode> segmentsToRunModes()

debugStream

protected void debugStream(byte[] array,
 int position,
 int remaining)

Overrides:

debugStream in class AbstractStreamDecoder<Event,ForkedProcessEventType,SegmentType>

newDebugSink

private OutputStream newDebugSink(ForkNodeArguments arguments)

close

public void close()
           throws IOException

Throws:

IOException