OpenJDK 27 · jdk.jfr.internal.management.StreamBarrier

Purpose of this class is to provide a synchronization point when stopping a recording. Without it, a race can happen where a stream advances beyond the last chunk of the recording. Code that is processing the stream calls check() and Unless the recording is in the process of being stopped, it will just return. On the other hand, if the recording is stopping, the thread waits and when it wakes up an end position should have been set (last chunk position) beyond which the stream processing should not continue.

Field Summary

Modifier and Type	Field and Description
private boolean	activated
private long	end
private final HiddenWait	lock
private boolean	used

Constructor Summary

Access	Constructor and Description
public	StreamBarrier()

Method Summary

Modifier and Type	Method and Description
public void	activate()
public void	check()
public synchronized void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
public long	getStreamEnd()
public void	setStreamEnd(long timestamp)
public boolean	used() Returns {@code true) if barrier is, or has been, in active state, {@code false) otherwise.

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

Field Detail

activated	back to summary
private boolean activated

end	back to summary
private long end

lock	back to summary
private final HiddenWait lock

used	back to summary
private boolean used

Constructor Detail

StreamBarrier	back to summary
public StreamBarrier()

Method Detail

activate	back to summary
public void activate()

check	back to summary
public void check()

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

getStreamEnd	back to summary
public long getStreamEnd()

setStreamEnd	back to summary
public void setStreamEnd(long timestamp)