Modifier and Type	Class and Description
pack-priv static class	DiskRepository.DiskChunk
pack-priv static enum	DiskRepository.State

Field Summary

Modifier and Type	Field and Description
private final StreamBarrier	barrier
private final ByteBuffer	buffer
private int	bufferIndex
pack-priv static final byte	CHECKPOINT_WITH_HEADER
private final ChunkFilename	chunkFilename
private final Deque<DiskRepository.DiskChunk>	chunks
pack-priv static final byte	COMPLETE_STATE
private byte[]	currentByteArray
private DiskRepository.DiskChunk	currentChunk
private final Deque<DiskRepository.DiskChunk>	deadChunks
private final boolean	deleteDirectory
private final Path	directory
private int	eventFieldSize
private final Deque<FileDump>	fileDumps
pack-priv static final int	HEADER_FILE_DURATION
pack-priv static final int	HEADER_FILE_STATE_POSITION
pack-priv static final int	HEADER_SIZE
pack-priv static final int	HEADER_START_NANOS_POSITION
private int	index
private int	lastFlush
private int	longValueshift
private Duration	maxAge
private long	maxSize
pack-priv static final byte	MODIFYING_STATE
private long	payLoadSize
private RandomAccessFile	previousRAF
private byte	previousRAFstate
private RandomAccessFile	raf
private long	size
private int	sizeShift
private DiskRepository.State	state
private long	typeId
private int	typeIdshift

Access	Constructor and Description
public	DiskRepository(Path path, boolean deleteDirectory)

Method Summary

Modifier and Type	Method and Description
public StreamBarrier	activateStreamBarrier()
private void	addChunk(DiskRepository.DiskChunk chunk)
private void	cleanUpDeadChunk(int maxCount)
public synchronized void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
public synchronized void	complete()
private void	completePrevious(DiskRepository.DiskChunk previous)
private void	flush()
public synchronized FileDump	newDump(long endTime)
private byte	nextByte(boolean inEvent)
private DiskRepository.DiskChunk	nextChunk()
public synchronized void	onChunkComplete(long endTimeNanos)
private void	processCheckpointHeader()
private void	processEvent()
private void	processEventSize()
private void	processEventTypeId()
private void	processFlush()
private void	processInitialHeader()
private void	processNumericValueInEvent()
private void	removeOldestChunk()
public synchronized void	setMaxAge(Duration maxAge)
public synchronized void	setMaxSize(long maxSize)
private void	trimToAge(Instant oldest)
private void	trimToSize()
public synchronized void	write(byte[] bytes)
private void	writeCheckpointHeader()
private void	writeInitialHeader()

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

Field Detail

barrier	back to summary
private final StreamBarrier barrier

buffer	back to summary
private final ByteBuffer buffer

bufferIndex	back to summary
private int bufferIndex

CHECKPOINT_WITH_HEADER	back to summary
pack-priv static final byte CHECKPOINT_WITH_HEADER

chunkFilename	back to summary
private final ChunkFilename chunkFilename

chunks	back to summary
private final Deque<DiskRepository.DiskChunk> chunks

COMPLETE_STATE	back to summary
pack-priv static final byte COMPLETE_STATE

currentByteArray	back to summary
private byte[] currentByteArray

currentChunk	back to summary
private DiskRepository.DiskChunk currentChunk

deadChunks	back to summary
private final Deque<DiskRepository.DiskChunk> deadChunks

deleteDirectory	back to summary
private final boolean deleteDirectory

directory	back to summary
private final Path directory

eventFieldSize	back to summary
private int eventFieldSize

fileDumps	back to summary
private final Deque<FileDump> fileDumps

HEADER_FILE_DURATION	back to summary
pack-priv static final int HEADER_FILE_DURATION

HEADER_FILE_STATE_POSITION	back to summary
pack-priv static final int HEADER_FILE_STATE_POSITION

HEADER_SIZE	back to summary
pack-priv static final int HEADER_SIZE

HEADER_START_NANOS_POSITION	back to summary
pack-priv static final int HEADER_START_NANOS_POSITION

index	back to summary
private int index

lastFlush	back to summary
private int lastFlush

longValueshift	back to summary
private int longValueshift

maxAge	back to summary
private Duration maxAge

maxSize	back to summary
private long maxSize

MODIFYING_STATE	back to summary
pack-priv static final byte MODIFYING_STATE

payLoadSize	back to summary
private long payLoadSize

previousRAF	back to summary
private RandomAccessFile previousRAF

previousRAFstate	back to summary
private byte previousRAFstate

raf	back to summary
private RandomAccessFile raf

size	back to summary
private long size

sizeShift	back to summary
private int sizeShift

state	back to summary
private DiskRepository.State state

typeId	back to summary
private long typeId

typeIdshift	back to summary
private int typeIdshift

DiskRepository	back to summary
public DiskRepository(Path path, boolean deleteDirectory) throws IOException

Method Detail

activateStreamBarrier	back to summary
public StreamBarrier activateStreamBarrier()

addChunk	back to summary
private void addChunk(DiskRepository.DiskChunk chunk)

cleanUpDeadChunk	back to summary
private void cleanUpDeadChunk(int maxCount)

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

complete	back to summary
public synchronized void complete()

completePrevious	back to summary
private void completePrevious(DiskRepository.DiskChunk previous) throws IOException

flush	back to summary
private void flush() throws IOException

newDump	back to summary
public synchronized FileDump newDump(long endTime)

nextByte	back to summary
private byte nextByte(boolean inEvent)

nextChunk	back to summary
private DiskRepository.DiskChunk nextChunk() throws IOException

onChunkComplete	back to summary
public synchronized void onChunkComplete(long endTimeNanos)

processCheckpointHeader	back to summary
private void processCheckpointHeader() throws IOException

processEvent	back to summary
private void processEvent()

processEventSize	back to summary
private void processEventSize() throws IOException

processEventTypeId	back to summary
private void processEventTypeId()

processFlush	back to summary
private void processFlush() throws IOException

processInitialHeader	back to summary
private void processInitialHeader() throws IOException

processNumericValueInEvent	back to summary
private void processNumericValueInEvent()

removeOldestChunk	back to summary
private void removeOldestChunk()

setMaxAge	back to summary
public synchronized void setMaxAge(Duration maxAge)

setMaxSize	back to summary
public synchronized void setMaxSize(long maxSize)

trimToAge	back to summary
private void trimToAge(Instant oldest)

trimToSize	back to summary
private void trimToSize()

write	back to summary
public synchronized void write(byte[] bytes) throws IOException

writeCheckpointHeader	back to summary
private void writeCheckpointHeader() throws IOException

writeInitialHeader	back to summary
private void writeInitialHeader() throws IOException

jdk.management.jfr back to summary

pack-priv final Class DiskRepository.DiskChunk

Class Inheritance

extends Object

java.lang.Object
jdk.management.jfr.DiskRepository.DiskChunk

Field Summary

Modifier and Type	Field and Description
pack-priv Instant	endTime
pack-priv long	endTimeNanos
pack-priv final Path	path
pack-priv int	referenceCount
pack-priv final DiskRepository	repository
pack-priv long	size
pack-priv final long	startTimeNanos

Constructor Summary

Access	Constructor and Description
pack-priv	DiskChunk(DiskRepository repository, Path path, long startNanos)

Method Summary

Modifier and Type	Method and Description
public void	acquire()
private void	destroy()
public boolean	isDead()
public Path	path()
public void	release()

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

Field Detail

endTime	back to summary
pack-priv Instant endTime

endTimeNanos	back to summary
pack-priv long endTimeNanos

path	back to summary
pack-priv final Path path

referenceCount	back to summary
pack-priv int referenceCount

repository	back to summary
pack-priv final DiskRepository repository

size	back to summary
pack-priv long size

startTimeNanos	back to summary
pack-priv final long startTimeNanos

Constructor Detail

DiskChunk	back to summary
pack-priv DiskChunk(DiskRepository repository, Path path, long startNanos)

Method Detail

acquire	back to summary
public void acquire()

destroy	back to summary
private void destroy()

isDead	back to summary
public boolean isDead()

path	back to summary
public Path path()

release	back to summary
public void release()

jdk.management.jfr back to summary

pack-priv final Enum DiskRepository.State

Class Inheritance

extends Enum<DiskRepository.State>

java.lang.Object
java.lang.Enum
jdk.management.jfr.DiskRepository.State

Field Summary

Modifier and Type	Field and Description
public static final DiskRepository.State	CHECKPOINT_EVENT_DELTA
public static final DiskRepository.State	CHECKPOINT_EVENT_DURATION
public static final DiskRepository.State	CHECKPOINT_EVENT_FLUSH_TYPE
public static final DiskRepository.State	CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_CONTENT
public static final DiskRepository.State	CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_LENGTH
public static final DiskRepository.State	CHECKPOINT_EVENT_HEADER_ITEM_COUNT
public static final DiskRepository.State	CHECKPOINT_EVENT_HEADER_KEY
public static final DiskRepository.State	CHECKPOINT_EVENT_HEADER_TYPE
public static final DiskRepository.State	CHECKPOINT_EVENT_POOL_COUNT
public static final DiskRepository.State	CHECKPOINT_EVENT_TIMESTAMP
public static final DiskRepository.State	EVENT_PAYLOAD
public static final DiskRepository.State	EVENT_SIZE
public static final DiskRepository.State	EVENT_TYPE
public static final DiskRepository.State	HEADER

Constructor Summary

Access	Constructor and Description
private	State()

Method Summary

Modifier and Type	Method and Description
public DiskRepository.State	next()
public static DiskRepository.State	valueOf(String name)
public static DiskRepository.State[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

CHECKPOINT_EVENT_DELTA	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_DELTA

CHECKPOINT_EVENT_DURATION	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_DURATION

CHECKPOINT_EVENT_FLUSH_TYPE	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_FLUSH_TYPE

CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_CONTENT	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_CONTENT

CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_LENGTH	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_LENGTH

CHECKPOINT_EVENT_HEADER_ITEM_COUNT	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_HEADER_ITEM_COUNT

CHECKPOINT_EVENT_HEADER_KEY	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_HEADER_KEY

CHECKPOINT_EVENT_HEADER_TYPE	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_HEADER_TYPE

CHECKPOINT_EVENT_POOL_COUNT	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_POOL_COUNT

CHECKPOINT_EVENT_TIMESTAMP	back to summary
public static final DiskRepository.State CHECKPOINT_EVENT_TIMESTAMP

EVENT_PAYLOAD	back to summary
public static final DiskRepository.State EVENT_PAYLOAD

EVENT_SIZE	back to summary
public static final DiskRepository.State EVENT_SIZE

EVENT_TYPE	back to summary
public static final DiskRepository.State EVENT_TYPE

Constructor Detail

State	back to summary
private State()

Method Detail

next	back to summary
public DiskRepository.State next()

valueOf	back to summary
public static DiskRepository.State valueOf(String name)

values	back to summary
public static DiskRepository.State[] values()

pack-priv final Class DiskRepository

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class DiskRepository.DiskChunk

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Enum DiskRepository.State

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail