Lines Matching refs:now
198 handshake_status: HandshakeStatus, now: Instant, trace_id: &str, in on_packet_sent()
205 self.delivery_rate.on_packet_sent(&mut pkt, now); in on_packet_sent()
214 self.time_of_last_sent_ack_eliciting_pkt[epoch] = Some(now); in on_packet_sent()
222 self.on_packet_sent_cc(sent_bytes, now); in on_packet_sent()
224 self.set_loss_detection_timer(handshake_status, now); in on_packet_sent()
238 fn on_packet_sent_cc(&mut self, sent_bytes: usize, now: Instant) { in on_packet_sent_cc()
239 (self.cc_ops.on_packet_sent)(self, sent_bytes, now); in on_packet_sent_cc()
244 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
270 let mut largest_newly_acked_sent_time = now; in on_ack_received()
290 unacked.time_acked = Some(now); in on_ack_received()
305 self.delivery_rate.on_packet_acked(&unacked, now); in on_ack_received()
327 let latest_rtt = now - largest_newly_acked_sent_time; in on_ack_received()
335 self.update_rtt(latest_rtt, ack_delay, now); 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()
346 self.set_loss_detection_timer(handshake_status, now); in on_ack_received()
356 &mut self, handshake_status: HandshakeStatus, now: Instant, in on_loss_detection_timeout()
363 self.detect_lost_packets(epoch, now, trace_id); in on_loss_detection_timeout()
365 self.set_loss_detection_timer(handshake_status, now); in on_loss_detection_timeout()
374 let (_, e) = self.pto_time_and_space(handshake_status, now); in on_loss_detection_timeout()
413 self.set_loss_detection_timer(handshake_status, now); in on_loss_detection_timeout()
420 now: Instant, in on_pkt_num_space_discarded()
440 self.set_loss_detection_timer(handshake_status, now); in on_pkt_num_space_discarded()
473 &mut self, latest_rtt: Duration, ack_delay: Duration, now: Instant, in update_rtt()
480 self.min_rtt = self.minmax_filter.reset(now, latest_rtt); in update_rtt()
489 self.minmax_filter.running_min(RTT_WINDOW, now, latest_rtt); in update_rtt()
529 &self, handshake_status: HandshakeStatus, now: Instant, in pto_time_and_space()
536 return (Some(now + duration), packet::EPOCH_HANDSHAKE); in pto_time_and_space()
538 return (Some(now + duration), packet::EPOCH_INITIAL); in pto_time_and_space()
574 &mut self, handshake_status: HandshakeStatus, now: Instant, in set_loss_detection_timer()
590 let (timeout, _) = self.pto_time_and_space(handshake_status, now); in set_loss_detection_timer()
595 &mut self, epoch: packet::Epoch, now: Instant, trace_id: &str, in detect_lost_packets()
608 let lost_send_time = now - loss_delay; in detect_lost_packets()
628 unacked.time_lost = Some(now); in detect_lost_packets()
662 self.on_packets_lost(lost_bytes, &pkt, epoch, now); in detect_lost_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()
746 &mut self, packet: &Acked, now: Instant, in hystart_on_packet_acked()
753 now, in hystart_on_packet_acked()
815 pub on_packet_sent: fn(r: &mut Recovery, sent_bytes: usize, now: Instant),
818 fn(r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant),
824 now: Instant,
843 let now = Instant::now(); in fmt() localVariable
845 if v > now { in fmt()
846 let d = v.duration_since(now); in fmt()
1007 let mut now = Instant::now(); in loss_on_pto() localVariable
1015 time_sent: now, in loss_on_pto()
1022 delivered_time: now, in loss_on_pto()
1023 recent_delivered_packet_sent_time: now, in loss_on_pto()
1032 now, in loss_on_pto()
1041 time_sent: now, in loss_on_pto()
1048 delivered_time: now, in loss_on_pto()
1049 recent_delivered_packet_sent_time: now, in loss_on_pto()
1058 now, in loss_on_pto()
1067 time_sent: now, in loss_on_pto()
1074 delivered_time: now, in loss_on_pto()
1075 recent_delivered_packet_sent_time: now, in loss_on_pto()
1084 now, in loss_on_pto()
1093 time_sent: now, in loss_on_pto()
1100 delivered_time: now, in loss_on_pto()
1101 recent_delivered_packet_sent_time: now, in loss_on_pto()
1110 now, in loss_on_pto()
1117 now += Duration::from_millis(10); in loss_on_pto()
1129 now, in loss_on_pto()
1140 now = r.loss_detection_timer().unwrap(); in loss_on_pto()
1143 r.on_loss_detection_timeout(HandshakeStatus::default(), now, ""); in loss_on_pto()
1151 time_sent: now, in loss_on_pto()
1158 delivered_time: now, in loss_on_pto()
1159 recent_delivered_packet_sent_time: now, in loss_on_pto()
1168 now, in loss_on_pto()
1177 time_sent: now, in loss_on_pto()
1184 delivered_time: now, in loss_on_pto()
1185 recent_delivered_packet_sent_time: now, in loss_on_pto()
1194 now, in loss_on_pto()
1202 now += Duration::from_millis(10); in loss_on_pto()
1214 now, in loss_on_pto()
1233 let mut now = Instant::now(); in loss_on_timer() localVariable
1241 time_sent: now, in loss_on_timer()
1248 delivered_time: now, in loss_on_timer()
1249 recent_delivered_packet_sent_time: now, in loss_on_timer()
1258 now, in loss_on_timer()
1267 time_sent: now, in loss_on_timer()
1274 delivered_time: now, in loss_on_timer()
1275 recent_delivered_packet_sent_time: now, in loss_on_timer()
1284 now, in loss_on_timer()
1293 time_sent: now, in loss_on_timer()
1300 delivered_time: now, in loss_on_timer()
1301 recent_delivered_packet_sent_time: now, in loss_on_timer()
1310 now, in loss_on_timer()
1319 time_sent: now, in loss_on_timer()
1326 delivered_time: now, in loss_on_timer()
1327 recent_delivered_packet_sent_time: now, in loss_on_timer()
1336 now, in loss_on_timer()
1343 now += Duration::from_millis(10); in loss_on_timer()
1356 now, in loss_on_timer()
1367 now = r.loss_detection_timer().unwrap(); in loss_on_timer()
1370 r.on_loss_detection_timeout(HandshakeStatus::default(), now, ""); in loss_on_timer()
1386 let mut now = Instant::now(); in loss_on_reordering() localVariable
1394 time_sent: now, in loss_on_reordering()
1401 delivered_time: now, in loss_on_reordering()
1402 recent_delivered_packet_sent_time: now, in loss_on_reordering()
1411 now, in loss_on_reordering()
1420 time_sent: now, in loss_on_reordering()
1427 delivered_time: now, in loss_on_reordering()
1428 recent_delivered_packet_sent_time: now, in loss_on_reordering()
1437 now, in loss_on_reordering()
1446 time_sent: now, in loss_on_reordering()
1453 delivered_time: now, in loss_on_reordering()
1454 recent_delivered_packet_sent_time: now, in loss_on_reordering()
1463 now, in loss_on_reordering()
1472 time_sent: now, in loss_on_reordering()
1479 delivered_time: now, in loss_on_reordering()
1480 recent_delivered_packet_sent_time: now, in loss_on_reordering()
1489 now, in loss_on_reordering()
1496 now += Duration::from_millis(10); in loss_on_reordering()
1508 now, in loss_on_reordering()
1514 now += Duration::from_millis(10); in loss_on_reordering()
1525 now, in loss_on_reordering()