APIdia Launch Partner

Top Fields Constructors Methods

jdk.jfr.internal.management

public final Class StreamManager

Class Inheritance

extends Object

java.lang.Object
jdk.jfr.internal.management.StreamManager

Imports

java.io.IOException, .InputStream, java.time.Instant, java.util.Date, .HashMap, .Map, .Timer, java.util.concurrent.TimeUnit, jdk.jfr.Recording

Field Summary

Modifier and Type	Field and Description
public static final int	DEFAULT_BLOCK_SIZE
private final Map<Long, EventByteStream>	streams
public static final long	TIME_OUT
private Timer	timer

Constructor Summary

Access	Constructor and Description
public	StreamManager()

Method Summary

Modifier and Type	Method and Description
public synchronized EventByteStream	create(InputStream is, int blockSize)
public synchronized EventByteStream	createOngoing(Recording recording, int blockSize, Instant startTime, Instant endTime)
public synchronized void	destroy(EventByteStream stream)
public synchronized EventByteStream	getStream(long streamIdentifer)
public synchronized void	scheduleAbort(EventByteStream s, long when)

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

Field Detail

DEFAULT_BLOCK_SIZE	back to summary
public static final int DEFAULT_BLOCK_SIZE

streams	back to summary
private final Map<Long, EventByteStream> streams

TIME_OUT	back to summary
public static final long TIME_OUT

timer	back to summary
private Timer timer

Constructor Detail

StreamManager	back to summary
public StreamManager()

Method Detail

create	back to summary
public synchronized EventByteStream create(InputStream is, int blockSize)

createOngoing	back to summary
public synchronized EventByteStream createOngoing(Recording recording, int blockSize, Instant startTime, Instant endTime)

destroy	back to summary
public synchronized void destroy(EventByteStream stream)

getStream	back to summary
public synchronized EventByteStream getStream(long streamIdentifer)

scheduleAbort	back to summary
public synchronized void scheduleAbort(EventByteStream s, long when)