gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-24 12:13:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

streams: extract max_send_data() helper

Browse Source
This commit is contained in:
Jerome Gravel-Niquet
2023-10-13 16:48:17 +02:00
committed by Dirkjan Ochtman
parent 7723cbc03f
commit e1e9768bd4
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams/state.rs
+12 -8
View File
@@ -800,14 +800,7 @@ impl StreamsState {
pub(super) fn insert(&mut self, remote: bool, id: StreamId) {
let bi = id.dir() == Dir::Bi;
if bi || !remote {
let max_data = match id.dir() {
Dir::Uni => self.initial_max_stream_data_uni,
// Remote/local appear reversed here because the transport parameters are named from
// the perspective of the peer.
Dir::Bi if remote => self.initial_max_stream_data_bidi_local,
Dir::Bi => self.initial_max_stream_data_bidi_remote,
};
let stream = Send::new(max_data);
let stream = Send::new(self.max_send_data(id));
assert!(self.send.insert(id, stream).is_none());
}
if bi || remote {
@@ -865,6 +858,17 @@ impl StreamsState {
self.send_streams -= 1;
}
}
pub(super) fn max_send_data(&self, id: StreamId) -> VarInt {
let remote = self.side != id.initiator();
match id.dir() {
Dir::Uni => self.initial_max_stream_data_uni,
// Remote/local appear reversed here because the transport parameters are named from
// the perspective of the peer.
Dir::Bi if remote => self.initial_max_stream_data_bidi_local,
Dir::Bi => self.initial_max_stream_data_bidi_remote,
}
}
}
#[cfg(test)]