OpenJDK 1.23 · jdk.jfr.internal.consumer.filter.ChunkWriter

Field Summary

Modifier and Type	Field and Description
private final Deque<CheckpointEvent>	checkpoints
private boolean	chunkComplete
private long	chunkStartPosition
private final Path	destination
private final Predicate<RecordedEvent>	filter
private final RecordingInput	input
private long	lastCheckpoint
private final RecordingOutput	output
private LongMap<Constants>	pools

Constructor Summary

Access	Constructor and Description
public	ChunkWriter(Path source, Path destination, Predicate<RecordedEvent> filter)

Method Summary

Modifier and Type	Method and Description
public boolean	accept(RecordedEvent event)
public void	beginChunk(ChunkHeader header)
public void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
public void	endChunk(ChunkHeader header)
public RecordingInput	getInput()
pack-priv Constants	getPool(Type type)
public CheckpointEvent	newCheckpointEvent(long startPosition)
public void	touch(Object object)
private void	touchRef(Reference ref)
private void	updateHeader(long size, long constantPosition, long metadataPosition)
public void	write(long startPosition, long endPosition)
private void	write(CheckpointEvent event, long delta)
private void	writeCheckpointEvents(long before)
public void	writeEvent(long startPosition, long endPosition)
private void	writeMetadataEvent(ChunkHeader header)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

checkpoints	back to summary
private final Deque<CheckpointEvent> checkpoints

chunkComplete	back to summary
private boolean chunkComplete

chunkStartPosition	back to summary
private long chunkStartPosition

destination	back to summary
private final Path destination

filter	back to summary
private final Predicate<RecordedEvent> filter

input	back to summary
private final RecordingInput input

lastCheckpoint	back to summary
private long lastCheckpoint

output	back to summary
private final RecordingOutput output

pools	back to summary
private LongMap<Constants> pools

Constructor Detail

ChunkWriter	back to summary
public ChunkWriter(Path source, Path destination, Predicate<RecordedEvent> filter) throws IOException

Method Detail

accept	back to summary
public boolean accept(RecordedEvent event)

beginChunk	back to summary
public void beginChunk(ChunkHeader header) throws IOException

close back to summary

close	back to summary
public 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 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

endChunk	back to summary
public void endChunk(ChunkHeader header) throws IOException

getInput	back to summary
public RecordingInput getInput()

getPool	back to summary
pack-priv Constants getPool(Type type)

newCheckpointEvent	back to summary
public CheckpointEvent newCheckpointEvent(long startPosition)

touch	back to summary
public void touch(Object object)

touchRef	back to summary
private void touchRef(Reference ref)

updateHeader	back to summary
private void updateHeader(long size, long constantPosition, long metadataPosition) throws IOException

write	back to summary
public void write(long startPosition, long endPosition) throws IOException

write	back to summary
private void write(CheckpointEvent event, long delta) throws IOException

writeCheckpointEvents	back to summary
private void writeCheckpointEvents(long before) throws IOException

writeEvent	back to summary
public void writeEvent(long startPosition, long endPosition) throws IOException