Skip to content

Commit

Permalink
Fix?
Browse files Browse the repository at this point in the history
  • Loading branch information
larseggert committed Sep 11, 2024
1 parent c2e20ff commit ddabf57
Showing 1 changed file with 9 additions and 11 deletions.
20 changes: 9 additions & 11 deletions neqo-transport/src/recovery/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -829,18 +829,16 @@ impl LossRecovery {
// The spaces in which we will allow probing.
let mut allow_probes = PacketNumberSpaceSet::default();
for pn_space in PacketNumberSpace::iter() {
if self
.pto_time(path.borrow().rtt(), *pn_space)
.map_or(true, |t| now < t)
{
continue;
if let Some(t) = self.pto_time(path.borrow().rtt(), *pn_space) {
allow_probes[*pn_space] = true;
if t <= now {
qdebug!([self], "PTO timer fired for {}", pn_space);
let space = self.spaces.get_mut(*pn_space).unwrap();
lost.extend(space.pto_packets().cloned());

pto_space = pto_space.or(Some(*pn_space));
}
}
allow_probes[*pn_space] = true;
qdebug!([self], "PTO timer fired for {}", pn_space);
let space = self.spaces.get_mut(*pn_space).unwrap();
lost.extend(space.pto_packets().cloned());

pto_space = pto_space.or(Some(*pn_space));
}

// This has to happen outside the loop. Increasing the PTO count here causes the
Expand Down

0 comments on commit ddabf57

Please sign in to comment.