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

public final Class EventDirectoryStream

extends AbstractEventStream
Class Inheritance
Imports
java.io.IOException, java.nio.file.Path, java.time.Instant, java.util.Arrays, .Comparator, .List, java.util.concurrent.atomic.AtomicLong, java.util.function.Consumer, jdk.jfr.Configuration, .RecordingState, jdk.jfr.consumer.RecordedEvent, jdk.jfr.internal.JVM, .LogLevel, .LogTag, .Logger, .PlatformRecording, jdk.jfr.internal.util.Utils, jdk.jfr.internal.management.StreamBarrier
Implementation of an EventStream} that operates against a directory with chunk files.

Field Summary

Modifier and TypeField and Description
private final StreamBarrier
barrier

private long
currentChunkStartNanos

private ChunkParser
currentParser

private static final Comparator<? super RecordedEvent>
EVENT_COMPARATOR

private volatile Consumer<Long>
onCompleteHandler

private final PlatformRecording
recording

private final RepositoryFiles
repositoryFiles

private RecordedEvent[]
sortedCache

private final AtomicLong
streamId

private int
threadExclusionLevel

Constructor Summary

AccessConstructor and Description
public
EventDirectoryStream(Path p, PlatformRecording recording, List<Configuration> configurations, boolean allowSubDirectories)

Method Summary

Modifier and TypeMethod and Description
public StreamBarrier
activateStreamBarrier()

public void
close()

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

Implements jdk.jfr.consumer.EventStream.close.

Releases all resources associated with this stream.

protected boolean
isRecordingStream()

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

private void
logStreamEnd(String text)

private void
onComplete(long epochNanos)

protected void
process()

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

private void
processOrdered(Dispatcher c)

protected void
processRecursionSafe()

private boolean
processUnordered(Dispatcher c)

public void
setChunkCompleteHandler(Consumer<Long> handler)

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

barrierback to summary
private final StreamBarrier barrier
currentChunkStartNanosback to summary
private long currentChunkStartNanos
currentParserback to summary
private ChunkParser currentParser
EVENT_COMPARATORback to summary
private static final Comparator<? super RecordedEvent> EVENT_COMPARATOR
onCompleteHandlerback to summary
private volatile Consumer<Long> onCompleteHandler
recordingback to summary
private final PlatformRecording recording
repositoryFilesback to summary
private final RepositoryFiles repositoryFiles
sortedCacheback to summary
private RecordedEvent[] sortedCache
streamIdback to summary
private final AtomicLong streamId
threadExclusionLevelback to summary
private int threadExclusionLevel

Constructor Detail

EventDirectoryStreamback to summary
public EventDirectoryStream(Path p, PlatformRecording recording, List<Configuration> configurations, boolean allowSubDirectories) throws IOException

Method Detail

activateStreamBarrierback to summary
public StreamBarrier activateStreamBarrier()
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
isRecordingStreamback to summary
protected boolean isRecordingStream()

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

logStreamEndback to summary
private void logStreamEnd(String text)
onCompleteback to summary
private void onComplete(long epochNanos)
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
processRecursionSafeback to summary
protected void processRecursionSafe() throws IOException
processUnorderedback to summary
private boolean processUnordered(Dispatcher c) throws IOException
setChunkCompleteHandlerback to summary
public void setChunkCompleteHandler(Consumer<Long> handler)
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