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

Reduce coercion

Browse Source
This commit is contained in:
Benjamin Saunders
2024-01-22 18:45:05 -08:00
committed by Dirkjan Ochtman
parent eeb12911ac
commit ebc1b9d684
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/mod.rs
+6 -5
View File
@@ -617,9 +617,10 @@ impl Connection {
// for starting another datagram. If there is any anti-amplification
// budget left, we always allow a full MTU to be sent
// (see https://github.com/quinn-rs/quinn/issues/1082)
if self.path.anti_amplification_blocked(
self.path.current_mtu() as u64 * num_datagrams as u64 + 1,
) {
if self
.path
.anti_amplification_blocked(self.path.current_mtu() as u64 * num_datagrams + 1)
{
trace!("blocked by anti-amplification");
break;
}
@@ -728,7 +729,7 @@ impl Connection {
space_id,
buf,
buf_capacity,
(num_datagrams - 1) * (self.path.current_mtu() as usize),
(num_datagrams as usize - 1) * (self.path.current_mtu() as usize),
ack_eliciting,
self,
self.version,
@@ -898,7 +899,7 @@ impl Connection {
trace!("sending {} bytes in {} datagrams", buf.len(), num_datagrams);
self.path.total_sent = self.path.total_sent.saturating_add(buf.len() as u64);
self.stats.udp_tx.on_sent(num_datagrams as u64, buf.len());
self.stats.udp_tx.on_sent(num_datagrams, buf.len());
Some(Transmit {
destination: self.path.remote,