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

Improve robustness to large connection-level flow control

Browse Source
This commit is contained in:
Benjamin Saunders
2021-01-04 13:39:33 -08:00
committed by Dirkjan Ochtman
parent a2e9dfc374
commit bc3c07372a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams.rs
+4 -2
View File
@@ -291,7 +291,7 @@ impl Streams {
self.local_max_data,
self.stream_receive_window,
)?;
self.data_recvd += new_bytes;
self.data_recvd = self.data_recvd.saturating_add(new_bytes);
if !rs.assembler.is_stopped() {
self.on_stream_frame(true, stream);
@@ -355,7 +355,9 @@ impl Streams {
// Update flow control
Ok(if bytes_read != final_offset.into() {
// bytes_read is always <= end, so this won't underflow.
self.data_recvd += u64::from(final_offset) - end;
self.data_recvd = self
.data_recvd
.saturating_add(u64::from(final_offset) - end);
self.add_read_credits(u64::from(final_offset) - bytes_read)
} else {
ShouldTransmit::new(false)