Lines Matching refs:epoch
197 &mut self, mut pkt: Sent, epoch: packet::Epoch, in on_packet_sent()
207 self.largest_sent_pkt[epoch] = in on_packet_sent()
208 cmp::max(self.largest_sent_pkt[epoch], pkt_num); in on_packet_sent()
210 self.sent[epoch].push_back(pkt); in on_packet_sent()
214 self.time_of_last_sent_ack_eliciting_pkt[epoch] = Some(now); in on_packet_sent()
217 self.in_flight_count[epoch] += 1; in on_packet_sent()
229 epoch == packet::EPOCH_APPLICATION && in on_packet_sent()
244 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
252 if largest_acked > self.largest_sent_pkt[epoch] { in on_ack_received()
260 if self.largest_acked_pkt[epoch] == std::u64::MAX { in on_ack_received()
261 self.largest_acked_pkt[epoch] = largest_acked; in on_ack_received()
263 self.largest_acked_pkt[epoch] = in on_ack_received()
264 cmp::max(self.largest_acked_pkt[epoch], largest_acked); in on_ack_received()
280 let unacked_iter = self.sent[epoch] in on_ack_received()
299 self.acked[epoch].append(&mut unacked.frames); in on_ack_received()
302 self.in_flight_count[epoch] = in on_ack_received()
303 self.in_flight_count[epoch].saturating_sub(1); in on_ack_received()
329 let ack_delay = if epoch == packet::EPOCH_APPLICATION { in on_ack_received()
340 self.detect_lost_packets(epoch, now, trace_id); in on_ack_received()
342 self.on_packets_acked(newly_acked, epoch, now); in on_ack_received()
348 self.drain_packets(epoch); in on_ack_received()
359 let (earliest_loss_time, epoch) = self.loss_time_and_space(); in on_loss_detection_timeout()
363 self.detect_lost_packets(epoch, now, trace_id); in on_loss_detection_timeout()
371 let epoch = if self.bytes_in_flight > 0 { in on_loss_detection_timeout() localVariable
390 self.loss_probes[epoch] = in on_loss_detection_timeout()
393 let unacked_iter = self.sent[epoch] in on_loss_detection_timeout()
400 .take(self.loss_probes[epoch]); in on_loss_detection_timeout()
410 self.lost[epoch].extend_from_slice(&unacked.frames); in on_loss_detection_timeout()
419 &mut self, epoch: packet::Epoch, handshake_status: HandshakeStatus, in on_pkt_num_space_discarded()
422 let unacked_bytes = self.sent[epoch] in on_pkt_num_space_discarded()
431 self.sent[epoch].clear(); in on_pkt_num_space_discarded()
432 self.lost[epoch].clear(); in on_pkt_num_space_discarded()
433 self.acked[epoch].clear(); in on_pkt_num_space_discarded()
435 self.time_of_last_sent_ack_eliciting_pkt[epoch] = None; in on_pkt_num_space_discarded()
436 self.loss_time[epoch] = None; in on_pkt_num_space_discarded()
437 self.loss_probes[epoch] = 0; in on_pkt_num_space_discarded()
438 self.in_flight_count[epoch] = 0; in on_pkt_num_space_discarded()
511 let mut epoch = packet::EPOCH_INITIAL; in loss_time_and_space() localVariable
512 let mut time = self.loss_time[epoch]; in loss_time_and_space()
521 epoch = e; in loss_time_and_space()
525 (time, epoch) in loss_time_and_space()
595 &mut self, epoch: packet::Epoch, now: Instant, trace_id: &str, in detect_lost_packets()
597 let largest_acked = self.largest_acked_pkt[epoch]; in detect_lost_packets()
599 self.loss_time[epoch] = None; in detect_lost_packets()
614 let unacked_iter = self.sent[epoch] in detect_lost_packets()
626 self.lost[epoch].append(&mut unacked.frames); in detect_lost_packets()
637 self.in_flight_count[epoch] = in detect_lost_packets()
638 self.in_flight_count[epoch].saturating_sub(1); in detect_lost_packets()
644 epoch in detect_lost_packets()
650 let loss_time = match self.loss_time[epoch] { in detect_lost_packets()
657 self.loss_time[epoch] = Some(loss_time); in detect_lost_packets()
662 self.on_packets_lost(lost_bytes, &pkt, epoch, now); in detect_lost_packets()
665 self.drain_packets(epoch); in detect_lost_packets()
668 fn drain_packets(&mut self, epoch: packet::Epoch) { in drain_packets()
669 let mut lowest_non_expired_pkt_index = self.sent[epoch].len(); in drain_packets()
681 for (i, pkt) in self.sent[epoch].iter().enumerate() { in drain_packets()
689 self.sent[epoch].drain(..lowest_non_expired_pkt_index); in drain_packets()
693 &mut self, acked: Vec<Acked>, epoch: packet::Epoch, now: Instant, in on_packets_acked()
696 (self.cc_ops.on_packet_acked)(self, &pkt, epoch, now); in on_packets_acked()
718 epoch: packet::Epoch, now: Instant, in on_packets_lost()
722 self.congestion_event(largest_lost_pkt.time_sent, epoch, now); in on_packets_lost()
730 &mut self, time_sent: Instant, epoch: packet::Epoch, now: Instant, in congestion_event()
732 (self.cc_ops.congestion_event)(self, time_sent, epoch, now); in congestion_event()
818 fn(r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant),
823 epoch: packet::Epoch,