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

Simplify state inspection

Browse Source
This commit is contained in:
Benjamin Saunders
2021-03-27 16:02:25 -07:00
committed by Dirkjan Ochtman
parent 4b2909ac1a
commit 08996a3676
1 changed files with 13 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams/recv.rs
+13 -15
View File
@@ -309,21 +309,19 @@ impl<'a> Chunks<'a> {
!drop || matches!(state, ChunksState::Finalized),
"finalize must be called before drop"
);
let mut should_transmit = match state {
ChunksState::Readable(mut rs) => {
let (_, max_stream_data) = rs.max_stream_data(self.streams.stream_receive_window);
self.pending
.post_read(self.id, ShouldTransmit(false), max_stream_data, false);
self.streams.recv.insert(self.id, rs);
max_stream_data.0
}
ChunksState::Finished => false,
ChunksState::Reset(_) => true,
ChunksState::Finalized => {
// Noop on repeated calls
return ShouldTransmit(false);
}
};
if let ChunksState::Finalized = state {
// Noop on repeated calls
return ShouldTransmit(false);
}
let mut should_transmit = matches!(state, ChunksState::Reset(_));
if let ChunksState::Readable(mut rs) = state {
let (_, max_stream_data) = rs.max_stream_data(self.streams.stream_receive_window);
self.pending
.post_read(self.id, ShouldTransmit(false), max_stream_data, false);
self.streams.recv.insert(self.id, rs);
should_transmit |= max_stream_data.0
}
// Issue connection-level flow control credit for any data we read regardless of state
let max_data = self.streams.add_read_credits(self.read);