| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/congestion_control/ |
| D | tcp_cubic_sender_bytes_test.cc | 55 sender_(new TcpCubicSenderBytesPeer(&clock_, true)), in TcpCubicSenderBytesTest()
67 bool can_send = sender_->CanSend(bytes_in_flight_); in SendAvailableSendWindow()
69 sender_->OnPacketSent(clock_.Now(), bytes_in_flight_, in SendAvailableSendWindow()
74 can_send = sender_->CanSend(bytes_in_flight_); in SendAvailableSendWindow()
81 sender_->rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(60), in AckNPackets()
91 sender_->OnCongestionEvent(true, bytes_in_flight_, clock_.Now(), in AckNPackets()
107 sender_->OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LoseNPackets()
118 sender_->OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LosePacket()
125 std::unique_ptr<TcpCubicSenderBytesPeer> sender_; member in quic::test::TcpCubicSenderBytesTest
133 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); in TEST_F()
[all …]
|
| D | bbr_sender_test.cc | 106 sender_ = SetupBbrSender(&bbr_sender_);
152 BbrSender* sender_; member in quic::test::BbrSenderTest
240 QUIC_LOG(INFO) << "Simple transfer state: " << sender_->ExportDebugState(); in DoSimpleTransfer()
245 ASSERT_FALSE(sender_->ExportDebugState().is_at_full_bandwidth); in DriveOutOfStartup()
247 EXPECT_EQ(BbrSender::PROBE_BW, sender_->ExportDebugState().mode); in DriveOutOfStartup()
249 sender_->ExportDebugState().max_bandwidth, 0.02f); in DriveOutOfStartup()
277 sender_->SetFromConfig(config, Perspective::IS_SERVER); in SetConnectionOption()
282 EXPECT_NE(3u * kDefaultTCPMSS, sender_->GetCongestionWindow()); in TEST_F()
283 sender_->SetInitialCongestionWindowInPackets(3); in TEST_F()
284 EXPECT_EQ(3u * kDefaultTCPMSS, sender_->GetCongestionWindow()); in TEST_F()
[all …]
|
| D | prague_sender_test.cc | 49 sender_(&clock_), in PragueSenderTest()
54 EXPECT_TRUE(sender_.EnableECT1()); in PragueSenderTest()
64 bool can_send = sender_.CanSend(bytes_in_flight_); in SendAvailableSendWindow()
66 sender_.OnPacketSent(clock_.Now(), bytes_in_flight_, in SendAvailableSendWindow()
71 can_send = sender_.CanSend(bytes_in_flight_); in SendAvailableSendWindow()
79 sender_.rtt_stats_.UpdateRtt(kRtt, QuicTime::Delta::Zero(), clock_.Now()); in AckNPackets()
88 sender_.OnCongestionEvent(true, bytes_in_flight_, clock_.Now(), in AckNPackets()
104 sender_.OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LoseNPackets()
115 sender_.OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LosePacket()
133 PragueSenderPeer sender_; member in quic::test::PragueSenderTest
[all …]
|
| D | bbr2_simulator_test.cc | 174 sender_ = SetupBbr2Sender(&sender_endpoint_, /*old_sender=*/nullptr); in Bbr2DefaultTopologyTest()
180 const Bbr2Sender::DebugState& debug_state = sender_->ExportDebugState(); in ~Bbr2DefaultTopologyTest()
254 QUIC_LOG(INFO) << "Simple transfer state: " << sender_->ExportDebugState(); in DoSimpleTransfer()
259 ASSERT_FALSE(sender_->ExportDebugState().startup.full_bandwidth_reached); in DriveOutOfStartup()
261 EXPECT_EQ(Bbr2Mode::PROBE_BW, sender_->ExportDebugState().mode); in DriveOutOfStartup()
263 sender_->ExportDebugState().bandwidth_hi, 0.02f); in DriveOutOfStartup()
310 SetConnectionOption(std::move(option), sender_); in SetConnectionOption()
322 const Bbr2Mode mode = sender_->ExportDebugState().mode; in Bbr2ModeIsOneOf()
338 return sender_->ExportDebugState(); in sender_debug_state()
356 Bbr2Sender* sender_; member in quic::test::Bbr2DefaultTopologyTest
[all …]
|
| D | pacing_sender.cc | 24 : sender_(nullptr), in PacingSender()
37 sender_ = sender; in set_sender()
47 QUICHE_DCHECK(sender_ != nullptr); in OnCongestionEvent()
52 sender_->OnCongestionEvent(rtt_updated, bytes_in_flight, event_time, in OnCongestionEvent()
60 QUICHE_DCHECK(sender_ != nullptr); in OnPacketSent()
64 sender_->OnPacketSent(sent_time, bytes_in_flight, packet_number, bytes, in OnPacketSent()
74 if (bytes_in_flight == 0 && !sender_->InRecovery()) { in OnPacketSent()
80 static_cast<uint32_t>(sender_->GetCongestionWindow() / in OnPacketSent()
102 (sender_->GetCongestionWindow() * in OnPacketSent()
105 if (sender_->BandwidthEstimate() < in OnPacketSent()
[all …]
|
| D | bbr2_probe_bw.cc | 105 QUIC_DVLOG(3) << sender_ << " Postponing min_rtt_timestamp(" in OnExitQuiescence()
123 << sender_ in UpdateProbeDown()
143 QUIC_DVLOG(3) << sender_ << " Proportional time based PROBE_DOWN exit"; in UpdateProbeDown()
151 << sender_ in UpdateProbeDown()
165 QUIC_DVLOG(3) << sender_ << " Checking if drained to target. bytes_in_flight:" in UpdateProbeDown()
176 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
206 sender_->GetTargetBytesInflight() * (1.0 - Params().beta); in MaybeAdaptUpperBounds()
223 QUIC_DVLOG(3) << sender_ in MaybeAdaptUpperBounds()
237 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
245 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/congestion_control/ |
| D | tcp_cubic_sender_bytes_test.cc | 55 sender_(new TcpCubicSenderBytesPeer(&clock_, true)), in TcpCubicSenderBytesTest()
67 bool can_send = sender_->CanSend(bytes_in_flight_); in SendAvailableSendWindow()
69 sender_->OnPacketSent(clock_.Now(), bytes_in_flight_, in SendAvailableSendWindow()
74 can_send = sender_->CanSend(bytes_in_flight_); in SendAvailableSendWindow()
81 sender_->rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(60), in AckNPackets()
91 sender_->OnCongestionEvent(true, bytes_in_flight_, clock_.Now(), in AckNPackets()
107 sender_->OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LoseNPackets()
118 sender_->OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LosePacket()
125 std::unique_ptr<TcpCubicSenderBytesPeer> sender_; member in quic::test::TcpCubicSenderBytesTest
133 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); in TEST_F()
[all …]
|
| D | bbr_sender_test.cc | 106 sender_ = SetupBbrSender(&bbr_sender_);
152 BbrSender* sender_; member in quic::test::BbrSenderTest
240 QUIC_LOG(INFO) << "Simple transfer state: " << sender_->ExportDebugState(); in DoSimpleTransfer()
245 ASSERT_FALSE(sender_->ExportDebugState().is_at_full_bandwidth); in DriveOutOfStartup()
247 EXPECT_EQ(BbrSender::PROBE_BW, sender_->ExportDebugState().mode); in DriveOutOfStartup()
249 sender_->ExportDebugState().max_bandwidth, 0.02f); in DriveOutOfStartup()
277 sender_->SetFromConfig(config, Perspective::IS_SERVER); in SetConnectionOption()
282 EXPECT_NE(3u * kDefaultTCPMSS, sender_->GetCongestionWindow()); in TEST_F()
283 sender_->SetInitialCongestionWindowInPackets(3); in TEST_F()
284 EXPECT_EQ(3u * kDefaultTCPMSS, sender_->GetCongestionWindow()); in TEST_F()
[all …]
|
| D | prague_sender_test.cc | 49 sender_(&clock_), in PragueSenderTest()
54 EXPECT_TRUE(sender_.EnableECT1()); in PragueSenderTest()
64 bool can_send = sender_.CanSend(bytes_in_flight_); in SendAvailableSendWindow()
66 sender_.OnPacketSent(clock_.Now(), bytes_in_flight_, in SendAvailableSendWindow()
71 can_send = sender_.CanSend(bytes_in_flight_); in SendAvailableSendWindow()
79 sender_.rtt_stats_.UpdateRtt(kRtt, QuicTime::Delta::Zero(), clock_.Now()); in AckNPackets()
88 sender_.OnCongestionEvent(true, bytes_in_flight_, clock_.Now(), in AckNPackets()
104 sender_.OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LoseNPackets()
115 sender_.OnCongestionEvent(false, bytes_in_flight_, clock_.Now(), in LosePacket()
133 PragueSenderPeer sender_; member in quic::test::PragueSenderTest
[all …]
|
| D | bbr2_simulator_test.cc | 174 sender_ = SetupBbr2Sender(&sender_endpoint_, /*old_sender=*/nullptr); in Bbr2DefaultTopologyTest()
180 const Bbr2Sender::DebugState& debug_state = sender_->ExportDebugState(); in ~Bbr2DefaultTopologyTest()
254 QUIC_LOG(INFO) << "Simple transfer state: " << sender_->ExportDebugState(); in DoSimpleTransfer()
259 ASSERT_FALSE(sender_->ExportDebugState().startup.full_bandwidth_reached); in DriveOutOfStartup()
261 EXPECT_EQ(Bbr2Mode::PROBE_BW, sender_->ExportDebugState().mode); in DriveOutOfStartup()
263 sender_->ExportDebugState().bandwidth_hi, 0.02f); in DriveOutOfStartup()
310 SetConnectionOption(std::move(option), sender_); in SetConnectionOption()
322 const Bbr2Mode mode = sender_->ExportDebugState().mode; in Bbr2ModeIsOneOf()
338 return sender_->ExportDebugState(); in sender_debug_state()
356 Bbr2Sender* sender_; member in quic::test::Bbr2DefaultTopologyTest
[all …]
|
| D | pacing_sender.cc | 24 : sender_(nullptr), in PacingSender()
37 sender_ = sender; in set_sender()
47 QUICHE_DCHECK(sender_ != nullptr); in OnCongestionEvent()
52 sender_->OnCongestionEvent(rtt_updated, bytes_in_flight, event_time, in OnCongestionEvent()
60 QUICHE_DCHECK(sender_ != nullptr); in OnPacketSent()
64 sender_->OnPacketSent(sent_time, bytes_in_flight, packet_number, bytes, in OnPacketSent()
74 if (bytes_in_flight == 0 && !sender_->InRecovery()) { in OnPacketSent()
80 static_cast<uint32_t>(sender_->GetCongestionWindow() / in OnPacketSent()
102 (sender_->GetCongestionWindow() * in OnPacketSent()
105 if (sender_->BandwidthEstimate() < in OnPacketSent()
[all …]
|
| D | bbr2_probe_bw.cc | 105 QUIC_DVLOG(3) << sender_ << " Postponing min_rtt_timestamp(" in OnExitQuiescence()
123 << sender_ in UpdateProbeDown()
143 QUIC_DVLOG(3) << sender_ << " Proportional time based PROBE_DOWN exit"; in UpdateProbeDown()
151 << sender_ in UpdateProbeDown()
165 QUIC_DVLOG(3) << sender_ << " Checking if drained to target. bytes_in_flight:" in UpdateProbeDown()
176 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
206 sender_->GetTargetBytesInflight() * (1.0 - Params().beta); in MaybeAdaptUpperBounds()
223 QUIC_DVLOG(3) << sender_ in MaybeAdaptUpperBounds()
237 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
245 QUIC_DVLOG(3) << sender_ << " " << cycle_.phase in MaybeAdaptUpperBounds()
[all …]
|
| D | bbr2_startup.cc | 25 ++sender_->connection_stats_->slowstart_count; in Bbr2StartupMode()
26 if (!sender_->connection_stats_->slowstart_duration.IsRunning()) { in Bbr2StartupMode()
27 sender_->connection_stats_->slowstart_duration.Start(now); in Bbr2StartupMode()
41 sender_->connection_stats_->slowstart_duration.Stop(now); in Leave()
125 QUIC_DVLOG(3) << sender_ << " Exiting STARTUP due to loss at round " in CheckExcessiveLosses()
131 sender_->connection_stats_->bbr_exit_startup_due_to_loss = true; in CheckExcessiveLosses()
155 const Bbr2Params& Bbr2StartupMode::Params() const { return sender_->Params(); } in Params()
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_rtcp_impl_unittest.cc | 180 sender_(&clock_, /*is_sender=*/true), in RtpRtcpImplTest()
185 EXPECT_EQ(0, sender_.impl_->SetSendingStatus(true)); in SetUp()
186 sender_.impl_->SetSendingMediaStatus(true); in SetUp()
187 sender_.impl_->SetSequenceNumber(kSequenceNumber); in SetUp()
188 sender_.impl_->SetStorePacketsStatus(true, 100); in SetUp()
193 video_config.rtp_sender = sender_.impl_->RtpSender(); in SetUp()
201 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
202 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
206 RtpRtcpModule sender_; member in webrtc::RtpRtcpImplTest
250 EXPECT_EQ(0, sender_.RtpSent()); in TEST_F()
[all …]
|
| D | rtp_rtcp_impl2_unittest.cc | 270 sender_(&time_controller_, in RtpRtcpImpl2Test()
279 EXPECT_EQ(0, sender_.impl_->SetSendingStatus(true)); in SetUp()
280 sender_.impl_->SetSendingMediaStatus(true); in SetUp()
281 sender_.impl_->SetSequenceNumber(kSequenceNumber); in SetUp()
282 sender_.impl_->SetStorePacketsStatus(true, 100); in SetUp()
286 video_config.rtp_sender = sender_.impl_->RtpSender(); in SetUp()
294 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
295 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
304 sender_.ReinintWithFec(fec_generator); in ReinitWithFec()
305 EXPECT_EQ(0, sender_.impl_->SetSendingStatus(true)); in ReinitWithFec()
[all …]
|
| /external/pigweed/pw_async2/public/pw_async2/ |
| D | once_sender.h | 53 sender_ = other.sender_; in OnceReceiver()
54 other.sender_ = nullptr; in OnceReceiver()
55 if (sender_) { in OnceReceiver()
56 sender_->receiver_ = this; in OnceReceiver()
78 } else if (!sender_) { in Pend()
97 OnceSender<T>* sender_ PW_GUARDED_BY(sender_receiver_lock()) = nullptr;
115 receiver_->sender_ = nullptr; in ~OnceSender()
124 receiver_->sender_ = this; in OnceSender()
139 receiver_->sender_ = nullptr; in emplace()
169 if (sender_) { in ~OnceReceiver()
[all …]
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_publisher_unittest.cc | 80 sender_(&socket_), in MdnsPublisherTest()
81 publisher_(&sender_, in MdnsPublisherTest()
153 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
159 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
166 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
173 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
178 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
184 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
189 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
195 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
[all …]
|
| D | mdns_probe_unittest.cc | 49 sender_(&socket_), in MdnsProbeTests()
58 return std::make_unique<MdnsProbeImpl>(&sender_, &receiver_, &random_, in CreateProbe()
81 StrictMock<MockMdnsSender> sender_; member in openscreen::discovery::MdnsProbeTests
96 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
99 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
101 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
104 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
106 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
109 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
124 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
[all …]
|
| /external/webrtc/pc/ |
| D | rtp_transceiver_unittest.cc | 140 sender_), in RtpTransceiverUnifiedPlanTest()
165 rtc::scoped_refptr<MockRtpSenderInternal> sender_ = MockSender(); member in webrtc::__anonf088918d0111::RtpTransceiverUnifiedPlanTest
173 EXPECT_CALL(*sender_.get(), SetTransceiverAsStopped()); in TEST_F()
174 EXPECT_CALL(*sender_.get(), Stop()); in TEST_F()
207 sender_),
231 EXPECT_CALL(*sender_.get(), SetMediaChannel(_)); in ClearChannel()
237 rtc::scoped_refptr<MockRtpSenderInternal> sender_ = MockSender(); member in webrtc::__anonf088918d0111::RtpTransceiverTestForHeaderExtensions
246 EXPECT_CALL(*sender_.get(), SetTransceiverAsStopped()); in TEST_F()
247 EXPECT_CALL(*sender_.get(), Stop()); in TEST_F()
255 EXPECT_CALL(*sender_.get(), SetTransceiverAsStopped()); in TEST_F()
[all …]
|
| /external/cronet/stable/ipc/ |
| D | ipc_message_pipe_reader.cc | 76 sender_(std::move(sender), task_runner), in MessagePipeReader()
84 *sender_.internal_state()->associated_group()->GetController())); in MessagePipeReader()
96 sender_.set_disconnect_handler( in FinishInitializationOnIOThread()
103 sender_->SetPeerPid(self_pid); in FinishInitializationOnIOThread()
108 sender_.reset(); in Close()
123 if (!sender_) in Send()
128 sender_->Receive(MessageView(bytes, std::move(handles))); in Send()
135 if (!sender_.is_bound()) in GetRemoteInterface()
137 sender_->GetAssociatedInterface(std::move(receiver)); in GetRemoteInterface()
187 sender_.internal_state()->ForwardMessage(std::move(message)); in ForwardMessage()
|
| /external/cronet/tot/ipc/ |
| D | ipc_message_pipe_reader.cc | 76 sender_(std::move(sender), task_runner), in MessagePipeReader()
84 *sender_.internal_state()->associated_group()->GetController())); in MessagePipeReader()
96 sender_.set_disconnect_handler( in FinishInitializationOnIOThread()
103 sender_->SetPeerPid(self_pid); in FinishInitializationOnIOThread()
108 sender_.reset(); in Close()
123 if (!sender_) in Send()
128 sender_->Receive(MessageView(bytes, std::move(handles))); in Send()
135 if (!sender_.is_bound()) in GetRemoteInterface()
137 sender_->GetAssociatedInterface(std::move(receiver)); in GetRemoteInterface()
187 sender_.internal_state()->ForwardMessage(std::move(message)); in ForwardMessage()
|
| /external/cronet/stable/components/nacl/renderer/ |
| D | pnacl_translation_resource_host.cc | 18 : io_task_runner_(io_task_runner), sender_(nullptr) {} in PnaclTranslationResourceHost()
27 sender_ = channel; in OnFilterAdded()
32 sender_ = nullptr; in OnFilterRemoved()
37 sender_ = nullptr; in OnChannelClosing()
69 if (!sender_ || !sender_->Send(new NaClHostMsg_NexeTempFileRequest( in SendRequestNexeFd()
99 if (!sender_) in SendReportTranslationFinished()
102 sender_->Send(new NaClHostMsg_ReportTranslationFinished(instance, in SendReportTranslationFinished()
|
| /external/cronet/tot/components/nacl/renderer/ |
| D | pnacl_translation_resource_host.cc | 18 : io_task_runner_(io_task_runner), sender_(nullptr) {} in PnaclTranslationResourceHost()
27 sender_ = channel; in OnFilterAdded()
32 sender_ = nullptr; in OnFilterRemoved()
37 sender_ = nullptr; in OnChannelClosing()
69 if (!sender_ || !sender_->Send(new NaClHostMsg_NexeTempFileRequest( in SendRequestNexeFd()
99 if (!sender_) in SendReportTranslationFinished()
102 sender_->Send(new NaClHostMsg_ReportTranslationFinished(instance, in SendReportTranslationFinished()
|
| /external/webrtc/test/scenario/ |
| D | audio_stream.cc | 75 : sender_(sender), config_(config) { in SendAudioStream()
130 sender_->SendTask([&] { in SendAudioStream()
131 send_stream_ = sender_->call_->CreateAudioSendStream(send_config); in SendAudioStream()
133 sender_->transport_->packet_overhead().bytes()); in SendAudioStream()
138 sender_->SendTask( in ~SendAudioStream()
139 [this] { sender_->call_->DestroyAudioSendStream(send_stream_); }); in ~SendAudioStream()
143 sender_->SendTask([this] { in Start()
145 sender_->call_->SignalChannelNetworkState(MediaType::AUDIO, kNetworkUp); in Start()
150 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
154 sender_->SendTask([this, mute] { send_stream_->SetMuted(mute); }); in SetMuted()
[all …]
|
| /external/libchrome/ipc/ |
| D | ipc_message_pipe_reader.cc | 30 sender_(std::move(sender)), in MessagePipeReader()
32 sender_.set_connection_error_handler( in MessagePipeReader()
47 sender_.reset(); in Close()
63 if (!sender_) in Send()
66 sender_->Receive(MessageView(*message, std::move(handles))); in Send()
74 if (!sender_.is_bound()) in GetRemoteInterface()
76 sender_->GetAssociatedInterface( in GetRemoteInterface()
|