Home
last modified time | relevance | path

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

12

/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_sustained_bandwidth_recorder_test.cc23 QuicTime::Delta srtt = QuicTime::Delta::FromMilliseconds(150); in TEST_F() local
33 wall_time, srtt); in TEST_F()
38 estimate_time = estimate_time + srtt; in TEST_F()
40 wall_time, srtt); in TEST_F()
44 estimate_time = estimate_time + srtt; in TEST_F()
45 estimate_time = estimate_time + srtt; in TEST_F()
47 wall_time, srtt); in TEST_F()
59 wall_time, srtt); in TEST_F()
62 wall_time, srtt); in TEST_F()
65 estimate_time = estimate_time + 3 * srtt; in TEST_F()
[all …]
Dquic_sustained_bandwidth_recorder.cc24 QuicTime estimate_time, QuicWallTime wall_time, QuicTime::Delta srtt) { in RecordEstimate() argument
42 if (estimate_time - start_time_ >= 3 * srtt) { in RecordEstimate()
Dquic_sent_packet_manager_test.cc988 QuicTime::Delta srtt = rtt_stats->initial_rtt(); in TEST_F() local
989 QuicTime expected_time = clock_.Now() + 1.5 * srtt; in TEST_F()
993 clock_.AdvanceTime(1.5 * srtt); in TEST_F()
1002 expected_time = crypto_packet_send_time + srtt * 2 * 1.5; in TEST_F()
1006 clock_.AdvanceTime(2 * 1.5 * srtt); in TEST_F()
1015 expected_time = crypto_packet_send_time + srtt * 4 * 1.5; in TEST_F()
1046 QuicTime::Delta srtt = rtt_stats->initial_rtt(); in TEST_F() local
1047 QuicTime expected_time = clock_.Now() + 2 * srtt; in TEST_F()
1051 clock_.AdvanceTime(2 * srtt); in TEST_F()
1059 expected_time = crypto_packet_send_time + srtt * 2 * 2; in TEST_F()
[all …]
Dquic_time_wait_list_manager.cc61 std::vector<QuicConnectionId> active_connection_ids, QuicTime::Delta srtt) in TimeWaitConnectionInfo() argument
64 srtt(srtt) { in TimeWaitConnectionInfo()
180 connection_data->info.srtt); in ProcessPacket()
Dquic_time_wait_list_manager.h43 QuicTime::Delta srtt);
53 QuicTime::Delta srtt; member
Dquic_sustained_bandwidth_recorder.h39 QuicWallTime wall_time, QuicTime::Delta srtt);
Dquic_sent_packet_manager.cc1055 QuicTime::Delta srtt = rtt_stats_.SmoothedOrInitialRtt(); in GetCryptoRetransmissionDelay() local
1061 static_cast<int64_t>(2 * srtt.ToMilliseconds())); in GetCryptoRetransmissionDelay()
1064 static_cast<int64_t>(1.5 * srtt.ToMilliseconds())); in GetCryptoRetransmissionDelay()
1388 const QuicTime::Delta srtt = rtt_stats_.SmoothedOrInitialRtt(); in GetNConsecutiveRetransmissionTimeoutDelay() local
1394 2 * srtt, in GetNConsecutiveRetransmissionTimeoutDelay()
1397 : (1.5 * srtt + in GetNConsecutiveRetransmissionTimeoutDelay()
1410 srtt + 4 * rtt_stats_.mean_deviation(), in GetNConsecutiveRetransmissionTimeoutDelay()
Dquic_connection.cc2571 QuicTime::Delta srtt = rtt_stats->SmoothedOrInitialRtt(); in GetStats() local
2572 stats_.srtt_us = srtt.ToMicroseconds(); in GetStats()
/external/bcc/libbpf-tools/
Dtcprtt.bpf.c39 u32 srtt; in BPF_PROG() local
60 srtt = BPF_CORE_READ(ts, srtt_us) >> 3; in BPF_PROG()
62 srtt /= 1000U; in BPF_PROG()
63 slot = log2l(srtt); in BPF_PROG()
68 __sync_fetch_and_add(&histp->latency, srtt); in BPF_PROG()
78 u32 srtt, saddr, daddr; in BPF_KPROBE() local
112 bpf_probe_read_kernel(&srtt, sizeof(srtt), &ts->srtt_us); in BPF_KPROBE()
113 srtt >>= 3; in BPF_KPROBE()
115 srtt /= 1000U; in BPF_KPROBE()
116 slot = log2l(srtt); in BPF_KPROBE()
[all …]
/external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/tcp/tcp_probe/
Dformat20 field:__u32 srtt; offset:96; size:4; signed:0;
24 …srtt=%u rcv_wnd=%u sock_cookie=%llx", REC->saddr, REC->daddr, REC->mark, REC->data_len, REC->snd_n…
/external/cronet/net/third_party/quiche/src/quiche/quic/core/congestion_control/
Dtcp_cubic_sender_bytes.cc172 QuicTime::Delta srtt = rtt_stats_->SmoothedOrInitialRtt(); in PacingRate() local
174 QuicBandwidth::FromBytesAndTimeDelta(GetCongestionWindow(), srtt); in PacingRate()
179 QuicTime::Delta srtt = rtt_stats_->smoothed_rtt(); in BandwidthEstimate() local
180 if (srtt.IsZero()) { in BandwidthEstimate()
184 return QuicBandwidth::FromBytesAndTimeDelta(GetCongestionWindow(), srtt); in BandwidthEstimate()
/external/rust/crates/quiche/src/recovery/bbr/
Dinit.rs66 let srtt = r in bbr_init_pacing_rate() localVariable
72 let nominal_bandwidth = r.congestion_window as f64 / srtt; in bbr_init_pacing_rate()
/external/webrtc/net/dcsctp/tx/
Dretransmission_timeout.h41 DurationMs srtt() const { return DurationMs(scaled_srtt_ >> kRttShift); } in srtt() function
Dretransmission_timeout_test.cc42 EXPECT_EQ(rto_.srtt(), kInitialRto); in TEST()
/external/cronet/net/http/
Dhttp_server_properties.h69 return srtt == other.srtt && bandwidth_estimate == other.bandwidth_estimate;
76 base::TimeDelta srtt; member
Dhttp_server_properties_manager_unittest.cc896 stats1.srtt = base::Microseconds(10); in TEST_F()
917 EXPECT_EQ(10, stats2->srtt.ToInternalValue()); in TEST_F()
990 stats.srtt = base::Microseconds(10); in TEST_F()
1012 EXPECT_EQ(10, stats1->srtt.ToInternalValue()); in TEST_F()
1149 stats.srtt = base::TimeDelta::FromInternalValue(42); in TEST_F()
1498 stats.srtt = base::TimeDelta::FromInternalValue(42); in TEST_F()
1983 EXPECT_EQ(server_network_stats->srtt, base::TimeDelta::FromInternalValue(42)); in TEST_F()
Dhttp_server_properties_manager.cc631 server_network_stats.srtt = base::Microseconds(maybe_srtt.value()); in ParseNetworkStats()
828 kSrttKey, static_cast<int>(server_network_stats.srtt.InMicroseconds())); in SaveNetworkStatsToServerPrefs()
Dhttp_server_properties_unittest.cc2573 stats_google.srtt = base::Microseconds(10); in TEST_F()
2593 stats_docs.srtt = base::Microseconds(20); in TEST_F()
2605 new_stats_docs.srtt = base::Microseconds(25); in TEST_F()
2613 stats_mail.srtt = base::Microseconds(30); in TEST_F()
2651 stats1.srtt = base::Microseconds(10); in TEST_F()
2658 EXPECT_EQ(10, stats2->srtt.ToInternalValue()); in TEST_F()
2673 stats.srtt = base::Microseconds(10); in TEST_F()
Dhttp_stream_factory_job_controller_unittest.cc2723 stats1.srtt = base::Microseconds(10); in TEST_P()
2800 stats1.srtt = base::Microseconds(10); in TEST_P()
2878 stats1.srtt = base::Seconds(100); in TEST_P()
2941 stats1.srtt = base::Microseconds(10); in TEST_P()
3172 stats1.srtt = base::Milliseconds(100); in TEST_P()
/external/cronet/net/quic/
Dquic_stream_factory.cc2009 int64_t srtt = 1.5 * GetServerNetworkStatsSmoothedRttInMicroseconds( in GetTimeDelayForWaitingJob() local
2015 if (!srtt) in GetTimeDelayForWaitingJob()
2016 srtt = kDefaultRTT; in GetTimeDelayForWaitingJob()
2017 return base::Microseconds(srtt); in GetTimeDelayForWaitingJob()
2349 const base::TimeDelta* srtt = in ConfigureInitialRttEstimate() local
2354 if (srtt && srtt->is_positive()) { in ConfigureInitialRttEstimate()
2355 SetInitialRttEstimate(*srtt, INITIAL_RTT_CACHED, config); in ConfigureInitialRttEstimate()
2384 const base::TimeDelta* srtt = in GetServerNetworkStatsSmoothedRttInMicroseconds() local
2386 return srtt == nullptr ? 0 : srtt->InMicroseconds(); in GetServerNetworkStatsSmoothedRttInMicroseconds()
2398 return &(stats->srtt); in GetServerNetworkStatsSmoothedRtt()
[all …]
/external/webrtc/net/dcsctp/socket/
Dtransmission_control_block.cc116 << ", srtt=" << *rto_.srtt() << ", rto=" << *rto_.rto() in ObserveRTT()
173 limit_forward_tsn_until_ = now + std::min(DurationMs(200), rto_.srtt()); in MaybeSendForwardTsn()
Dtransmission_control_block.h93 DurationMs current_srtt() const { return rto_.srtt(); } in current_srtt()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dbuffer_list.h64 absl::optional<uint32_t> srtt; member
Dbuffer_list.cc143 metrics->srtt.emplace(read_unaligned<uint32_t>(val)); in extract_opt_stats_from_cmsg()
/external/rust/crates/quiche/src/recovery/
Dmod.rs364 if let Some(srtt) = self.smoothed_rtt { in on_packet_sent()
366 srtt.as_secs_f64(); in on_packet_sent()
751 Some(srtt) => { in update_rtt()
765 sub_abs(srtt, adjusted_rtt).mul_f64(1.0 / 4.0); in update_rtt()
768 srtt.mul_f64(7.0 / 8.0) + adjusted_rtt.mul_f64(1.0 / 8.0), in update_rtt()

12