APIdia Launch Partner
Top Description Fields Constructors Methods
jdk.jfr.internal.consumer

public final Class EventFileStream

extends AbstractEventStream
Class Inheritance
Imports
java.io.IOException, java.nio.file.Path, java.util.Arrays, .Collections, .Comparator, jdk.jfr.consumer.RecordedEvent
Implementation of an event stream that operates against a recording file.

Field Summary

Modifier and TypeField and Description
private RecordedEvent[]
cacheSorted

private ChunkParser
currentParser

private static final Comparator<? super RecordedEvent>
EVENT_COMPARATOR

private final RecordingInput
input

Constructor Summary

AccessConstructor and Description
public
EventFileStream(Path file)

Method Summary

Modifier and TypeMethod and Description
public void
close()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.close.

Implements jdk.jfr.consumer.EventStream.close.

Releases all resources associated with this stream.

private void
dispatchOrdered(Dispatcher c, int index)

protected boolean
isRecordingStream()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.isRecordingStream.

protected void
process()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.process.

private void
processOrdered(Dispatcher c)

private void
processUnordered(Dispatcher c)

public void
start()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.start.

Implements jdk.jfr.consumer.EventStream.start.

Starts processing of actions.

public void
startAsync()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.startAsync.

Implements jdk.jfr.consumer.EventStream.startAsync.

Starts asynchronous processing of actions.

Inherited from jdk.jfr.internal.consumer.AbstractEventStream:
awaitTerminationawaitTerminationcloseParserdispatchergetFlushOperationgetWaitForChunksisClosedonCloseonErroronEventonEventonFlushonFlushonMetadataonMetadataparserStateremovesetCloseOnCompletesetDaemonsetEndTimesetOrderedsetReusesetStartTimesetWaitForChunksstartstartAsync

Field Detail

cacheSortedback to summary
private RecordedEvent[] cacheSorted
currentParserback to summary
private ChunkParser currentParser
EVENT_COMPARATORback to summary
private static final Comparator<? super RecordedEvent> EVENT_COMPARATOR
inputback to summary
private final RecordingInput input

Constructor Detail

EventFileStreamback to summary
public EventFileStream(Path file) throws IOException

Method Detail

closeback to summary
public void close()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.close.

Implements jdk.jfr.consumer.EventStream.close.

Doc from jdk.jfr.consumer.EventStream.close.

Releases all resources associated with this stream.

If a stream is started, asynchronously or synchronously, it is stopped immediately or after the next flush. This method does NOT guarantee that all registered actions are completed before return.

Closing a previously closed stream has no effect.

Annotations
@Override
dispatchOrderedback to summary
private void dispatchOrdered(Dispatcher c, int index)
isRecordingStreamback to summary
protected boolean isRecordingStream()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.isRecordingStream.

Annotations
@Override
processback to summary
protected void process() throws IOException

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.process.

Annotations
@Override
processOrderedback to summary
private void processOrdered(Dispatcher c) throws IOException
processUnorderedback to summary
private void processUnordered(Dispatcher c) throws IOException
startback to summary
public void start()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.start.

Implements jdk.jfr.consumer.EventStream.start.

Doc from jdk.jfr.consumer.EventStream.start.

Starts processing of actions.

Actions are performed in the current thread.

To stop the stream, use the close() method.

Annotations
@Override
startAsyncback to summary
public void startAsync()

Implements abstract jdk.jfr.internal.consumer.AbstractEventStream.startAsync.

Implements jdk.jfr.consumer.EventStream.startAsync.

Doc from jdk.jfr.consumer.EventStream.startAsync.

Starts asynchronous processing of actions.

Actions are performed in a single separate thread.

To stop the stream, use the close() method.

Annotations
@Override