Lines Matching refs:now
128 fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, now: Instant) { in on_packet_sent()
135 let delta = now - last_sent_time; in on_packet_sent()
148 cubic.last_sent_time = Some(now); in on_packet_sent()
150 reno::on_packet_sent(r, sent_bytes, now); in on_packet_sent()
154 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
171 let (cwnd, ssthresh) = r.hystart_on_packet_acked(packet, now); in on_packet_acked()
201 ca_start_time = now; in on_packet_acked()
202 r.congestion_recovery_start_time = Some(now); in on_packet_acked()
210 let t = now - ca_start_time; in on_packet_acked()
237 let (lss_cwnd, _) = r.hystart_on_packet_acked(packet, now); in on_packet_acked()
256 r: &mut Recovery, time_sent: Instant, epoch: packet::Epoch, now: Instant, in congestion_event()
263 r.congestion_recovery_start_time = Some(now); in congestion_event()
312 r.on_packet_sent_cc(1000, Instant::now()); in cubic_send()
323 let now = Instant::now(); in cubic_slow_start() localVariable
328 time_sent: now, in cubic_slow_start()
335 delivered_time: now, in cubic_slow_start()
336 recent_delivered_packet_sent_time: now, in cubic_slow_start()
343 r.on_packet_sent_cc(p.size, now); in cubic_slow_start()
344 r.on_packet_sent_cc(p.size, now); in cubic_slow_start()
345 r.on_packet_sent_cc(p.size, now); in cubic_slow_start()
346 r.on_packet_sent_cc(p.size, now); in cubic_slow_start()
356 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now); in cubic_slow_start()
368 let now = Instant::now(); in cubic_congestion_event() localVariable
371 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_congestion_event()
384 let now = Instant::now(); in cubic_congestion_avoidance() localVariable
388 r.on_packet_sent_cc(20000, now); in cubic_congestion_avoidance()
391 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_congestion_avoidance()
402 time_sent: now + rtt, in cubic_congestion_avoidance()
407 r.update_rtt(rtt, Duration::from_millis(0), now); in cubic_congestion_avoidance()
408 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now + rtt * 3); in cubic_congestion_avoidance()
420 let now = Instant::now(); in cubic_collapse_cwnd_and_restart() localVariable
423 r.on_packet_sent_cc(30000, now); in cubic_collapse_cwnd_and_restart()
426 r.congestion_event(now, packet::EPOCH_APPLICATION, now); in cubic_collapse_cwnd_and_restart()
435 time_sent: now + Duration::from_millis(1), in cubic_collapse_cwnd_and_restart()
444 r.on_packets_acked(acked.clone(), packet::EPOCH_APPLICATION, now); in cubic_collapse_cwnd_and_restart()
448 r.on_packets_acked(acked, packet::EPOCH_APPLICATION, now); in cubic_collapse_cwnd_and_restart()
460 let now = Instant::now(); in cubic_hystart_limited_slow_start() localVariable
467 time_sent: now, in cubic_hystart_limited_slow_start()
474 delivered_time: now, in cubic_hystart_limited_slow_start()
475 recent_delivered_packet_sent_time: now, in cubic_hystart_limited_slow_start()
489 r.on_packet_sent_cc(p.size, now); in cubic_hystart_limited_slow_start()
493 let now = now + Duration::from_millis(rtt_1st); in cubic_hystart_limited_slow_start() localVariable
498 now, in cubic_hystart_limited_slow_start()
507 r.on_packets_acked(acked, epoch, now); in cubic_hystart_limited_slow_start()
517 let now = now + Duration::from_millis(rtt_2nd); in cubic_hystart_limited_slow_start() localVariable
521 r.on_packet_sent_cc(p.size, now); in cubic_hystart_limited_slow_start()
533 now, in cubic_hystart_limited_slow_start()
542 r.on_packets_acked(acked, epoch, now); in cubic_hystart_limited_slow_start()
559 r.on_packets_acked(acked, epoch, now); in cubic_hystart_limited_slow_start()