OpenJDK 27 · jdk.internal.net.http.WindowUpdateSender

Modifier and Type	Field and Description
pack-priv final Http2Connection	connection
pack-priv volatile String	dbgString
pack-priv final Logger	debug
pack-priv final int	limit
pack-priv final AtomicLong	received
pack-priv final ReentrantLock	sendLock
pack-priv final AtomicLong	unprocessed
pack-priv final int	windowSize

Access	Constructor and Description
pack-priv	WindowUpdateSender(Http2Connection connection)
pack-priv	WindowUpdateSender(Http2Connection connection, int initWindowSize)
pack-priv	WindowUpdateSender(Http2Connection connection, int maxFrameSize, int initWindowSize)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	Returns: `true` if buffering the given amount of flow controlled data would not exceed the flow control window canBufferUnprocessedBytes(int a number of unprocessed bytes, which the caller wants to buffer. len) Returns `true` if buffering the given amount of flow controlled data would not exceed the flow control window.
private boolean	checkWindowSizeExceeded(long processed, long len)
pack-priv String	dbgString()
pack-priv abstract int	getStreamId()
pack-priv void	processed(int the amount of processed bytes to release delta) Called after unprocessed buffered bytes have been processed, to release part of the flow control window
pack-priv long	Returns: the amount of remaining unprocessed bytes released(int the amount of bytes to release from the window delta) Called when it is desired to release unprocessed bytes without processing them, or without triggering the sending of a window update.
pack-priv void	sendWindowUpdate(int delta)
pack-priv void	update(int the amount of bytes released from the window. delta) This method is called to update the flow control window, and possibly send a window update
protected abstract boolean	Returns: `true` if the error was reported to the peer and no further window update should be sent. windowSizeExceeded(long the amount of data received, which is greater than `windowSize` received) Called when the flow control window size is exceeded This method may return false if flow control is disabled in this endpoint.

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

connection	back to summary
pack-priv final Http2Connection connection

dbgString	back to summary
pack-priv volatile String dbgString

debug	back to summary
pack-priv final Logger debug

limit	back to summary
pack-priv final int limit

received	back to summary
pack-priv final AtomicLong received

sendLock	back to summary
pack-priv final ReentrantLock sendLock

unprocessed	back to summary
pack-priv final AtomicLong unprocessed

windowSize	back to summary
pack-priv final int windowSize

WindowUpdateSender	back to summary
pack-priv WindowUpdateSender(Http2Connection connection)

WindowUpdateSender	back to summary
pack-priv WindowUpdateSender(Http2Connection connection, int initWindowSize)

WindowUpdateSender	back to summary
pack-priv WindowUpdateSender(Http2Connection connection, int maxFrameSize, int initWindowSize)

Method Detail

canBufferUnprocessedBytes back to summary

canBufferUnprocessedBytes	back to summary
pack-priv boolean canBufferUnprocessedBytes(int len) Returns `true` if buffering the given amount of flow controlled data would not exceed the flow control window. This method is called before buffering and processing a DataFrame. The count of unprocessed bytes is incremented by the given amount, and checked against the number of available bytes in the flow control window. This method returns `true` if the bytes can be buffered without exceeding the flow control window, `false` if the flow control window is exceeded and corrective action (close/reset) has been taken. When this method returns true, either `processed(int)` or `released(int)` must eventually be called to release the bytes from the flow control window. Implementation Specification an HTTP/2 endpoint may disable its own flow control (see RFC 9113, section 5.2.1), in which case this method may return true even if the flow control window would be exceeded: that is, the flow control window is exceeded but the endpoint decided to take no corrective action. Parameters len:int a number of unprocessed bytes, which the caller wants to buffer. Returns:boolean `true` if buffering the given amount of flow controlled data would not exceed the flow control window

pack-priv boolean canBufferUnprocessedBytes(int len)

Returns true if buffering the given amount of flow controlled data would not exceed the flow control window.

This method is called before buffering and processing a DataFrame. The count of unprocessed bytes is incremented by the given amount, and checked against the number of available bytes in the flow control window.

This method returns true if the bytes can be buffered without exceeding the flow control window, false if the flow control window is exceeded and corrective action (close/reset) has been taken.

When this method returns true, either processed(int) or released(int) must eventually be called to release the bytes from the flow control window.

Implementation Specification

an HTTP/2 endpoint may disable its own flow control (see RFC 9113, section 5.2.1), in which case this method may return true even if the flow control window would be exceeded: that is, the flow control window is exceeded but the endpoint decided to take no corrective action.

Parameters

len:int: a number of unprocessed bytes, which the caller wants to buffer.

Returns:boolean

true if buffering the given amount of flow controlled data would not exceed the flow control window

checkWindowSizeExceeded	back to summary
private boolean checkWindowSizeExceeded(long processed, long len)

dbgString	back to summary
pack-priv String dbgString()

getStreamId	back to summary
pack-priv abstract int getStreamId()

processed back to summary

processed	back to summary
pack-priv void processed(int delta) Called after unprocessed buffered bytes have been processed, to release part of the flow control window API Note this method is called only when releasing bytes that where buffered after calling `canBufferUnprocessedBytes(int)`. Parameters delta:int the amount of processed bytes to release

pack-priv void processed(int delta)

Called after unprocessed buffered bytes have been processed, to release part of the flow control window

API Note

this method is called only when releasing bytes that where buffered after calling canBufferUnprocessedBytes(int).

Parameters

delta:int: the amount of processed bytes to release

released back to summary

released	back to summary
pack-priv long released(int delta) Called when it is desired to release unprocessed bytes without processing them, or without triggering the sending of a window update. This method can be called instead of calling `processed(int)`. When this method is called instead of calling `processed(int)`, it should generally be followed by a call to `update(int)`, unless the stream or connection is being closed. API Note this method should only be called to release bytes that have been buffered after calling `canBufferUnprocessedBytes(int)`. Parameters delta:int the amount of bytes to release from the window Returns:long the amount of remaining unprocessed bytes

pack-priv long released(int delta)

Called when it is desired to release unprocessed bytes without processing them, or without triggering the sending of a window update. This method can be called instead of calling processed(int). When this method is called instead of calling processed(int), it should generally be followed by a call to update(int), unless the stream or connection is being closed.

API Note

this method should only be called to release bytes that have been buffered after calling canBufferUnprocessedBytes(int).

Parameters

delta:int: the amount of bytes to release from the window

Returns:long

the amount of remaining unprocessed bytes

sendWindowUpdate	back to summary
pack-priv void sendWindowUpdate(int delta)

update back to summary

update	back to summary
pack-priv void update(int delta) This method is called to update the flow control window, and possibly send a window update API Note this method can be called directly if a frame is dropped before calling `canBufferUnprocessedBytes(int)`. Otherwise, either `processed(int)` or `released(int)` should be called, depending on whether sending a window update is desired or not. It is typically not desired to send an update if the stream or connection is being closed. Parameters delta:int the amount of bytes released from the window.

pack-priv void update(int delta)

This method is called to update the flow control window, and possibly send a window update

API Note

this method can be called directly if a frame is dropped before calling canBufferUnprocessedBytes(int). Otherwise, either processed(int) or released(int) should be called, depending on whether sending a window update is desired or not. It is typically not desired to send an update if the stream or connection is being closed.

Parameters

delta:int: the amount of bytes released from the window.

windowSizeExceeded back to summary

windowSizeExceeded	back to summary
protected abstract boolean windowSizeExceeded(long received) Called when the flow control window size is exceeded This method may return false if flow control is disabled in this endpoint. Parameters received:long the amount of data received, which is greater than `windowSize` Returns:boolean `true` if the error was reported to the peer and no further window update should be sent.

protected abstract boolean windowSizeExceeded(long received)

Called when the flow control window size is exceeded This method may return false if flow control is disabled in this endpoint.

Parameters

received:long: the amount of data received, which is greater than windowSize

Returns:boolean

true if the error was reported to the peer and no further window update should be sent.

pack-priv abstract Class WindowUpdateSender

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail