[−][src]Struct h2::ReleaseCapacity
A handle to release window capacity to a remote stream.
This type allows the caller to manage inbound data flow control. The
caller is expected to call release_capacity
after dropping data frames.
Overview
Each stream has a window size. This window size is the maximum amount of inbound data that can be in-flight. In-flight data is defined as data that has been received, but not yet released.
When a stream is created, the window size is set to the connection's initial
window size value. When a data frame is received, the window size is then
decremented by size of the data frame before the data is provided to the
caller. As the caller finishes using the data, release_capacity
must be
called. This will then increment the window size again, allowing the peer to
send more data.
There is also a connection level window as well as the stream level window.
Received data counts against the connection level window as well and calls
to release_capacity
will also increment the connection level window.
Sending WINDOW_UPDATE
frames
WINDOW_UPDATE
frames will not be sent out for every call to
release_capacity
, as this would end up slowing down the protocol. Instead,
h2
waits until the window size is increased to a certain threshold and
then sends out a single WINDOW_UPDATE
frame representing all the calls to
release_capacity
since the last WINDOW_UPDATE
frame.
This essentially batches window updating.
Scenarios
Following is a basic scenario with an HTTP/2.0 connection containing a single active stream.
- A new stream is activated. The receive window is initialized to 1024 (the value of the initial window size for this connection).
- A
DATA
frame is received containing a payload of 400 bytes. - The receive window size is reduced to 424 bytes.
release_capacity
is called with 200.- The receive window size is now 624 bytes. The peer may send no more than this.
- A
DATA
frame is received with a payload of 624 bytes. - The window size is now 0 bytes. The peer may not send any more data.
release_capacity
is called with 1024.- The receive window size is now 1024 bytes. The peer may now send more data.
Methods
impl ReleaseCapacity
[src]
impl ReleaseCapacity
pub fn stream_id(&self) -> StreamId
[src]
pub fn stream_id(&self) -> StreamId
Returns the stream ID of the stream whose capacity will
be released by this ReleaseCapacity
.
Panics
If the lock on the stream store has been poisoned.
pub fn release_capacity(&mut self, sz: usize) -> Result<(), Error>
[src]
pub fn release_capacity(&mut self, sz: usize) -> Result<(), Error>
Release window capacity back to remote stream.
This releases capacity back to the stream level and the connection level
windows. Both window sizes will be increased by sz
.
See struct level documentation for more details.
Panics
This function panics if increasing the receive window size by sz
would
result in a window size greater than the target window size set by
set_target_window_size
. In other words, the caller cannot release
more capacity than data has been received. If 1024 bytes of data have
been received, at most 1024 bytes can be released.
Trait Implementations
impl Clone for ReleaseCapacity
[src]
impl Clone for ReleaseCapacity
fn clone(&self) -> Self
[src]
fn clone(&self) -> Self
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
impl Debug for ReleaseCapacity
[src]
impl Debug for ReleaseCapacity
Auto Trait Implementations
impl Send for ReleaseCapacity
impl Send for ReleaseCapacity
impl Sync for ReleaseCapacity
impl Sync for ReleaseCapacity
Blanket Implementations
impl<T> From for T
[src]
impl<T> From for T
impl<T, U> Into for T where
U: From<T>,
[src]
impl<T, U> Into for T where
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
type Owned = T
fn to_owned(&self) -> T
[src]
fn to_owned(&self) -> T
Creates owned data from borrowed data, usually by cloning. Read more
fn clone_into(&self, target: &mut T)
[src]
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more
impl<T, U> TryFrom for T where
T: From<U>,
[src]
impl<T, U> TryFrom for T where
T: From<U>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
try_from
)Performs the conversion.
impl<T> Borrow for T where
T: ?Sized,
[src]
impl<T> Borrow for T where
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
impl<T> BorrowMut for T where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
try_from
)The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
try_from
)Performs the conversion.
impl<T> Any for T where
T: 'static + ?Sized,
[src]
impl<T> Any for T where
T: 'static + ?Sized,
fn get_type_id(&self) -> TypeId
[src]
fn get_type_id(&self) -> TypeId
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
Gets the TypeId
of self
. Read more