OpenJDK 1.22 · jdk.jfr.internal.consumer.OngoingStream

Field Summary

Modifier and Type	Field and Description
private final int	blockSize
private static final byte[]	EMPTY_ARRAY
private final long	endTimeNanos
private boolean	first
private ChunkHeader	header
private static final int	HEADER_FILE_STATE_POSITION
private static final int	HEADER_SIZE
private final byte[]	headerBytes
private RecordingInput	input
private static final byte	MODIFYING_STATE
private Path	path
private long	position
private final Recording	recording
private final RepositoryFiles	repositoryFiles
private long	startTimeNanos

Inherited from jdk.jfr.internal.management.EventByteStream:: NAME

Constructor Summary

Access	Constructor and Description
public	OngoingStream(Recording recording, int blockSize, long startTimeNanos, long endTimeNanos)

Method Summary

Modifier and Type	Method and Description
public synchronized void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
private void	closeInput()
private boolean	ensureInput()
private boolean	ensurePath()
private boolean	isRecordingClosed()
public synchronized byte[]	read() Implements abstract jdk.jfr.internal.management.EventByteStream.read.
private byte[]	readBytes()
private byte[]	readBytes(int size)
private byte[]	readNonHeader(int size)
private byte[]	readWithHeader(int size)
private void	takeNap()

Inherited from jdk.jfr.internal.management.EventByteStream:: getId getLastTouched newFinishedStream newOngoingStream touch

Field Detail

blockSize	back to summary
private final int blockSize

EMPTY_ARRAY	back to summary
private static final byte[] EMPTY_ARRAY

endTimeNanos	back to summary
private final long endTimeNanos

first	back to summary
private boolean first

header	back to summary
private ChunkHeader header

HEADER_FILE_STATE_POSITION	back to summary
private static final int HEADER_FILE_STATE_POSITION

HEADER_SIZE	back to summary
private static final int HEADER_SIZE

headerBytes	back to summary
private final byte[] headerBytes

input	back to summary
private RecordingInput input

MODIFYING_STATE	back to summary
private static final byte MODIFYING_STATE

path	back to summary
private Path path

position	back to summary
private long position

recording	back to summary
private final Recording recording

repositoryFiles	back to summary
private final RepositoryFiles repositoryFiles

startTimeNanos	back to summary
private long startTimeNanos

Constructor Detail

OngoingStream	back to summary
public OngoingStream(Recording recording, int blockSize, long startTimeNanos, long endTimeNanos)

Method Detail

close back to summary

close	back to summary
public synchronized void close() throws IOException Implements java.io.Closeable.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Annotations @Override Exceptions IOException: if an I/O error occurs

public synchronized void close() throws IOException

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs

closeInput	back to summary
private void closeInput()

ensureInput	back to summary
private boolean ensureInput() throws IOException

ensurePath	back to summary
private boolean ensurePath()

isRecordingClosed	back to summary
private boolean isRecordingClosed()

read	back to summary
public synchronized byte[] read() throws IOException Implements abstract jdk.jfr.internal.management.EventByteStream.read. Annotations @Override

read

back to summary

public synchronized byte[] read() throws IOException

Implements abstract jdk.jfr.internal.management.EventByteStream.read.