Home
last modified time | relevance | path

Searched refs:bytes_in_flight (Results 1 – 25 of 34) sorted by relevance

12

/external/cronet/net/third_party/quiche/src/quiche/quic/core/congestion_control/
Dprr_sender_test.cc26 QuicByteCount bytes_in_flight = num_packets_in_flight * kMaxSegmentSize; in TEST_F() local
30 prr.OnPacketLost(bytes_in_flight); in TEST_F()
33 bytes_in_flight -= kMaxSegmentSize; in TEST_F()
34 EXPECT_TRUE(prr.CanSend(congestion_window, bytes_in_flight, in TEST_F()
39 EXPECT_FALSE(prr.CanSend(congestion_window, bytes_in_flight, in TEST_F()
48 bytes_in_flight -= kMaxSegmentSize; in TEST_F()
49 EXPECT_FALSE(prr.CanSend(congestion_window, bytes_in_flight, in TEST_F()
53 bytes_in_flight -= kMaxSegmentSize; in TEST_F()
54 EXPECT_TRUE(prr.CanSend(congestion_window, bytes_in_flight, in TEST_F()
58 bytes_in_flight += kMaxSegmentSize; in TEST_F()
[all …]
Dpacing_sender.cc39 QuicByteCount bytes_in_flight, in OnCongestionEvent() argument
50 sender_->OnCongestionEvent(rtt_updated, bytes_in_flight, event_time, in OnCongestionEvent()
55 QuicTime sent_time, QuicByteCount bytes_in_flight, in OnPacketSent() argument
59 sender_->OnPacketSent(sent_time, bytes_in_flight, packet_number, bytes, in OnPacketSent()
65 if (bytes_in_flight == 0 && !sender_->InRecovery()) { in OnPacketSent()
82 PacingRate(bytes_in_flight + bytes).TransferTime(bytes); in OnPacketSent()
99 if ((bytes_in_flight + bytes) >= sender_->GetCongestionWindow()) { in OnPacketSent()
113 pacing_limited_ = sender_->CanSend(bytes_in_flight + bytes); in OnPacketSent()
129 QuicTime now, QuicByteCount bytes_in_flight) const { in TimeUntilSend()
132 if (!sender_->CanSend(bytes_in_flight)) { in TimeUntilSend()
[all …]
Dbbr_sender.cc150 void BbrSender::OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight, in OnPacketSent() argument
161 if (bytes_in_flight == 0 && sampler_.is_app_limited()) { in OnPacketSent()
165 sampler_.OnPacketSent(sent_time, packet_number, bytes, bytes_in_flight, in OnPacketSent()
173 bool BbrSender::CanSend(QuicByteCount bytes_in_flight) { in CanSend() argument
174 return bytes_in_flight < GetCongestionWindow(); in CanSend()
521 const QuicByteCount bytes_in_flight = unacked_packets_->bytes_in_flight(); in UpdateGainCyclePhase() local
539 if (pacing_gain_ < 1.0 && bytes_in_flight <= GetTargetCongestionWindow(1)) { in UpdateGainCyclePhase()
553 bytes_in_flight > GetTargetCongestionWindow(1)) { in UpdateGainCyclePhase()
593 unacked_packets_->bytes_in_flight() <= GetTargetCongestionWindow(1)) { in MaybeExitStartupOrDrain()
613 const QuicByteCount inflight_at_send = last_packet_send_state.bytes_in_flight; in ShouldExitStartupDueToLoss()
[all …]
Dpacing_sender.h53 void OnCongestionEvent(bool rtt_updated, QuicByteCount bytes_in_flight,
59 void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
71 QuicByteCount bytes_in_flight) const;
73 QuicBandwidth PacingRate(QuicByteCount bytes_in_flight) const;
Dtcp_cubic_sender_bytes.h60 void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
65 bool CanSend(QuicByteCount bytes_in_flight) override;
66 QuicBandwidth PacingRate(QuicByteCount bytes_in_flight) const override;
75 void OnApplicationLimited(QuicByteCount bytes_in_flight) override;
87 bool IsCwndLimited(QuicByteCount bytes_in_flight) const;
Dtcp_cubic_sender_bytes.cc152 bool TcpCubicSenderBytes::CanSend(QuicByteCount bytes_in_flight) { in CanSend() argument
155 return prr_.CanSend(GetCongestionWindow(), bytes_in_flight, in CanSend()
158 if (GetCongestionWindow() > bytes_in_flight) { in CanSend()
161 if (min4_mode_ && bytes_in_flight < 4 * kDefaultTCPMSS) { in CanSend()
191 bool TcpCubicSenderBytes::IsCwndLimited(QuicByteCount bytes_in_flight) const { in IsCwndLimited()
193 if (bytes_in_flight >= congestion_window) { in IsCwndLimited()
196 const QuicByteCount available_bytes = congestion_window - bytes_in_flight; in IsCwndLimited()
198 InSlowStart() && bytes_in_flight > congestion_window / 2; in IsCwndLimited()
Dbbr2_misc.cc75 QuicByteCount bytes_in_flight, in OnPacketSent() argument
81 if (bytes_in_flight < min_bytes_in_flight_in_round_) { in OnPacketSent()
82 min_bytes_in_flight_in_round_ = bytes_in_flight; in OnPacketSent()
84 if (bytes_in_flight + bytes >= inflight_hi_) { in OnPacketSent()
90 bytes_in_flight, is_retransmittable); in OnPacketSent()
145 congestion_event->bytes_in_flight = in OnCongestionEventStart()
154 congestion_event->bytes_in_flight = 0; in OnCongestionEventStart()
174 if (congestion_event->bytes_in_flight < min_bytes_in_flight_in_round_) { in OnCongestionEventStart()
175 min_bytes_in_flight_in_round_ = congestion_event->bytes_in_flight; in OnCongestionEventStart()
Dbandwidth_sampler.h36 bytes_in_flight(0) {} in SendTimeState()
40 QuicByteCount bytes_in_flight) in SendTimeState()
46 bytes_in_flight(bytes_in_flight) {} in SendTimeState()
76 QuicByteCount bytes_in_flight; member
197 QuicByteCount bytes_in_flight,
346 QuicByteCount bytes, QuicByteCount bytes_in_flight,
484 QuicByteCount bytes_in_flight, in ConnectionStateOnSentPacket()
494 bytes_in_flight) {} in ConnectionStateOnSentPacket()
Dprr_sender.cc34 QuicByteCount bytes_in_flight, in CanSend() argument
37 if (bytes_sent_since_loss_ == 0 || bytes_in_flight < kMaxSegmentSize) { in CanSend()
40 if (congestion_window > bytes_in_flight) { in CanSend()
Dsend_algorithm_interface.h99 virtual void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
115 virtual bool CanSend(QuicByteCount bytes_in_flight) = 0;
118 virtual QuicBandwidth PacingRate(QuicByteCount bytes_in_flight) const = 0;
166 virtual void OnApplicationLimited(QuicByteCount bytes_in_flight) = 0;
Dbbr2_drain.cc24 if (congestion_event.bytes_in_flight <= drain_target) { in OnCongestionEvent()
26 << congestion_event.bytes_in_flight in OnCongestionEvent()
34 << congestion_event.bytes_in_flight << ", bdp:" << model_->BDP() in OnCongestionEvent()
Dbbr2_sender.cc344 if (congestion_event.bytes_in_flight == 0 && in OnCongestionEvent()
354 << ", BytesInFlight:" << congestion_event.bytes_in_flight in OnCongestionEvent()
439 void Bbr2Sender::OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight, in OnPacketSent() argument
445 << ", inflight:" << bytes_in_flight + bytes in OnPacketSent()
454 if (bytes_in_flight == 0 && params().avoid_unnecessary_probe_rtt) { in OnPacketSent()
457 model_.OnPacketSent(sent_time, bytes_in_flight, packet_number, bytes, in OnPacketSent()
465 bool Bbr2Sender::CanSend(QuicByteCount bytes_in_flight) { in CanSend() argument
466 const bool result = bytes_in_flight < GetCongestionWindow(); in CanSend()
479 void Bbr2Sender::OnApplicationLimited(QuicByteCount bytes_in_flight) { in OnApplicationLimited() argument
480 if (bytes_in_flight >= GetCongestionWindow()) { in OnApplicationLimited()
Dbbr2_probe_rtt.cc26 if (congestion_event.bytes_in_flight <= InflightTarget() || in OnCongestionEvent()
27 congestion_event.bytes_in_flight <= in OnCongestionEvent()
31 << ". bytes_inflight:" << congestion_event.bytes_in_flight in OnCongestionEvent()
Dbbr2_sender.h62 void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
72 bool CanSend(QuicByteCount bytes_in_flight) override;
74 QuicBandwidth PacingRate(QuicByteCount bytes_in_flight) const override;
94 void OnApplicationLimited(QuicByteCount bytes_in_flight) override;
Dbbr2_probe_bw.cc150 << congestion_event.bytes_in_flight in UpdateProbeDown()
152 QuicByteCount bytes_in_flight = congestion_event.bytes_in_flight; in UpdateProbeDown() local
154 if (bytes_in_flight > inflight_with_headroom) { in UpdateProbeDown()
162 << bytes_in_flight << ", bdp:" << bdp; in UpdateProbeDown()
163 if (bytes_in_flight < bdp) { in UpdateProbeDown()
479 is_queuing = congestion_event.bytes_in_flight >= queuing_threshold; in UpdateProbeUp()
484 << ", post_in_flight:" << congestion_event.bytes_in_flight in UpdateProbeUp()
Dbbr_sender.h117 void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
123 bool CanSend(QuicByteCount bytes_in_flight) override;
124 QuicBandwidth PacingRate(QuicByteCount bytes_in_flight) const override;
133 void OnApplicationLimited(QuicByteCount bytes_in_flight) override;
Dbbr2_misc.h305 QuicByteCount bytes_in_flight = 0; member
343 void OnPacketSent(QuicTime sent_time, QuicByteCount bytes_in_flight,
670 if (send_state.bytes_in_flight != 0) { in BytesInFlight()
671 return send_state.bytes_in_flight; in BytesInFlight()
Dbandwidth_sampler.cc22 << ", inflight:" << s.bytes_in_flight << "}"; in operator <<()
192 QuicByteCount bytes_in_flight, in OnPacketSent() argument
208 if (bytes_in_flight == 0) { in OnPacketSent()
261 bytes_in_flight + bytes, *this); in OnPacketSent()
/external/rust/crates/quiche/src/recovery/
Dprr.rs57 pub fn congestion_event(&mut self, bytes_in_flight: usize) { in congestion_event()
60 self.recoverfs = bytes_in_flight; in congestion_event()
105 let bytes_in_flight = 1000; in congestion_event() localVariable
107 prr.congestion_event(bytes_in_flight); in congestion_event()
109 assert_eq!(prr.recoverfs, bytes_in_flight); in congestion_event()
116 let bytes_in_flight = 1000; in on_packet_sent() localVariable
119 prr.congestion_event(bytes_in_flight); in on_packet_sent()
131 let bytes_in_flight = max_datagram_size * 10; in on_packet_acked_prr() localVariable
132 let ssthresh = bytes_in_flight / 2; in on_packet_acked_prr()
135 prr.congestion_event(bytes_in_flight); in on_packet_acked_prr()
[all …]
Dmod.rs132 bytes_in_flight: usize, field
246 bytes_in_flight: 0, in new_with_config()
344 (self.bytes_in_flight + sent_bytes) < self.congestion_window, in on_packet_sent()
377 .on_packet_sent(&mut pkt, self.bytes_in_flight - sent_bytes); in on_packet_sent()
594 let epoch = if self.bytes_in_flight > 0 { in on_loss_detection_timeout()
654 self.bytes_in_flight = self.bytes_in_flight.saturating_sub(unacked_bytes); in on_pkt_num_space_discarded()
683 self.congestion_window.saturating_sub(self.bytes_in_flight) + in cwnd_available()
799 if self.bytes_in_flight == 0 { in pto_time_and_space()
851 if self.bytes_in_flight == 0 && handshake_status.peer_verified_address { in set_loss_detection_timer()
1007 self.bytes_in_flight = self.bytes_in_flight.saturating_sub(lost_bytes); in on_packets_lost()
[all …]
Dreno.rs59 r.bytes_in_flight += sent_bytes; in on_packet_sent()
73 r.bytes_in_flight = r.bytes_in_flight.saturating_sub(packet.size); in on_packet_acked()
177 assert_eq!(r.bytes_in_flight, 0); in reno_init()
191 assert_eq!(r.bytes_in_flight, 1000); in reno_send()
/external/rust/crates/quiche/src/recovery/bbr/
Dmod.rs258 r.congestion_window = r.bytes_in_flight + in bbr_enter_recovery()
292 r.bytes_in_flight += sent_bytes; in on_packet_sent()
301 r.bbr_state.prior_bytes_in_flight = r.bytes_in_flight; in on_packets_acked()
305 r.bytes_in_flight = r.bytes_in_flight.saturating_sub(p.size); in on_packets_acked()
381 assert_eq!(r.bytes_in_flight, 0); in bbr_init()
397 assert_eq!(r.bytes_in_flight, 1000); in bbr_send()
459 assert_eq!(r.bytes_in_flight, 0); in bbr_startup()
528 assert_eq!(r.bytes_in_flight, mss * 2); in bbr_congestion_event()
Dper_ack.rs176 r.congestion_window.max(r.bytes_in_flight + acked_bytes); in bbr_modulate_cwnd_for_recovery()
260 r.bytes_in_flight <= bbr_inflight(r, 1.0) in bbr_check_drain()
367 } else if r.bytes_in_flight <= bbr_min_pipe_cwnd(r) { in bbr_handle_probe_rtt()
Dper_transmit.rs39 if r.bytes_in_flight == 0 && r.delivery_rate.app_limited() { in bbr_handle_restart_from_idle()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_sent_packet_manager.cc648 pacing_sender_.OnPacketSent(sent_time, unacked_packets_.bytes_in_flight(), in OnPacketSent()
652 send_algorithm_->OnPacketSent(sent_time, unacked_packets_.bytes_in_flight(), in OnPacketSent()
699 QuicByteCount prior_in_flight = unacked_packets_.bytes_in_flight(); in OnRetransmissionTimeout()
954 unacked_packets_.bytes_in_flight()); in TimeUntilSend()
957 return send_algorithm_->CanSend(unacked_packets_.bytes_in_flight()) in TimeUntilSend()
1100 QuicByteCount bytes_in_flight = GetBytesInFlight(); in GetAvailableCongestionWindowInBytes() local
1101 return congestion_window - std::min(congestion_window, bytes_in_flight); in GetAvailableCongestionWindowInBytes()
1233 QuicByteCount prior_bytes_in_flight = unacked_packets_.bytes_in_flight(); in OnAckFrameEnd()
1321 send_algorithm_->OnApplicationLimited(unacked_packets_.bytes_in_flight()); in OnApplicationLimited()

12