gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-21 02:33:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

quinn-proto: inline single-use record_sent_max_data() method

Browse Source
This commit is contained in:
Dirkjan Ochtman
2021-02-24 15:33:46 +01:00
committed by Benjamin Saunders
parent a11abc648e
commit afe8a6cfee
1 changed files with 7 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams/state.rs
+7 -12
View File
@@ -357,7 +357,13 @@ impl StreamsState {
let max = VarInt::try_from(self.local_max_data).unwrap_or(VarInt::MAX);
trace!(value = max.into_inner(), "MAX_DATA");
self.record_sent_max_data(max);
if max > self.sent_max_data {
// Record that a `MAX_DATA` announcing a certain window was sent. This will
// suppress enqueuing further `MAX_DATA` frames unless either the previous
// transmission was not acknowledged or the window further increased.
self.sent_max_data = max;
}
retransmits.get_or_create().max_data = true;
buf.write(frame::Type::MAX_DATA);
buf.write(max);
@@ -719,17 +725,6 @@ impl StreamsState {
ShouldTransmit(diff >= (self.receive_window / 8))
}
/// Records that a `MAX_DATA` announcing a certain window was sent
///
/// This will suppress enqueuing further `MAX_DATA` frames unless
/// either the previous transmission was not acknowledged or the window
/// further increased.
fn record_sent_max_data(&mut self, sent_value: VarInt) {
if sent_value > self.sent_max_data {
self.sent_max_data = sent_value;
}
}
/// Update counters for removal of a stream
pub(super) fn stream_freed(&mut self, id: StreamId, half: StreamHalf) {
if id.initiator() != self.side {