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

Deduplicate asserts

Browse Source
This commit is contained in:
Benjamin Saunders
2021-03-27 15:49:59 -07:00
committed by Dirkjan Ochtman
parent ed6ddd46bd
commit 3d3a0aa849
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams/recv.rs
+5 -6
View File
@@ -304,9 +304,12 @@ impl<'a> Chunks<'a> {
fn finalize_inner(&mut self, drop: bool) -> ShouldTransmit {
let state = mem::replace(&mut self.state, ChunksState::Finalized);
debug_assert!(
!drop || matches!(state, ChunksState::Finalized),
"finalize must be called before drop"
);
match state {
ChunksState::Readable(mut rs) => {
debug_assert!(!drop);
let (_, max_stream_data) = rs.max_stream_data(self.streams.stream_receive_window);
let max_data = self.streams.add_read_credits(self.read);
self.pending
@@ -315,16 +318,12 @@ impl<'a> Chunks<'a> {
ShouldTransmit(max_stream_data.0 | max_data.0)
}
ChunksState::Finished => {
debug_assert!(!drop);
// MAX_DATA may need to be issued, but MAX_STREAM_DATA is pointless
let max_data = self.streams.add_read_credits(self.read);
self.pending.max_data |= max_data.0;
max_data
}
ChunksState::Reset(_) => {
debug_assert!(!drop);
ShouldTransmit(true)
}
ChunksState::Reset(_) => ShouldTransmit(true),
ChunksState::Finalized => ShouldTransmit(false),
}
}