| /external/webrtc/modules/congestion_controller/goog_cc/test/ |
| D | goog_cc_printer.cc | 74 controller_->delay_based_bwe_->rate_control_.link_capacity_ in CreateLoggers()
79 controller_->delay_based_bwe_->rate_control_.rate_control_state_); in CreateLoggers()
83 controller_->delay_based_bwe_->active_delay_detector_); in CreateLoggers()
86 return controller_->acknowledged_bitrate_estimator_->bitrate(); in CreateLoggers()
89 return &controller_->bandwidth_estimation_ in CreateLoggers()
127 Log("data_window", [=] { return controller_->current_data_window_; }), in CreateLoggers()
129 [=] { return controller_->last_pushback_target_rate_; }), in CreateLoggers()
149 controller_ = controller; in PrintState()
150 auto state_update = controller_->GetNetworkState(at_time); in PrintState()
155 if (controller_->network_estimator_) { in PrintState()
[all …]
|
| D | goog_cc_printer.h | 50 GoogCcNetworkController* controller_ = nullptr; variable
70 GoogCcNetworkController* controller_ = nullptr; variable
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_bootstrap.cc | 365 : controller_(controller), value_(std::move(message)) {} in MessageWrapper()
368 : controller_(other.controller_), value_(std::move(other.value_)) {} in MessageWrapper()
374 controller_->lock_.AssertAcquired(); in ~MessageWrapper()
376 base::AutoUnlock unlocker(controller_->lock_); in ~MessageWrapper()
382 controller_ = other.controller_; in operator =()
390 ChannelAssociatedGroupController* controller_ = nullptr; member in IPC::__anon75e303610111::ChannelAssociatedGroupController::MessageWrapper
400 : controller_(controller), id_(id) {} in Endpoint()
405 controller_->lock_.AssertAcquired(); in closed()
410 controller_->lock_.AssertAcquired(); in set_closed()
415 controller_->lock_.AssertAcquired(); in peer_closed()
[all …]
|
| /external/webrtc/call/ |
| D | rtp_transport_controller_send.cc | 343 if (controller_) { in OnNetworkRouteChanged()
344 PostUpdates(controller_->OnNetworkRouteChange(msg)); in OnNetworkRouteChanged()
370 if (controller_) { in OnNetworkAvailability()
372 PostUpdates(controller_->OnNetworkAvailability(msg)); in OnNetworkAvailability()
408 if (packet_msg && controller_) in OnSentPacket()
409 PostUpdates(controller_->OnSentPacket(*packet_msg)); in OnSentPacket()
417 if (controller_) in OnReceivedPacket()
418 PostUpdates(controller_->OnReceivedPacket(packet_msg)); in OnReceivedPacket()
427 if (controller_) { in UpdateBitrateConstraints()
428 PostUpdates(controller_->OnTargetRateConstraints(msg)); in UpdateBitrateConstraints()
[all …]
|
| D | rtp_stream_receiver_controller.cc | 23 : controller_(controller), sink_(sink) { in Receiver()
24 const bool sink_added = controller_->AddSink(ssrc, sink_); in Receiver()
37 controller_->RemoveSink(sink_); in ~Receiver()
|
| D | rtp_stream_receiver_controller.h | 57 RtpStreamReceiverController* const controller_;
|
| /external/webrtc/modules/audio_coding/audio_network_adaptor/ |
| D | frame_length_controller_v2_unittest.cc | 32 controller_->MakeDecision(&config); in GetDecision()
40 controller_->UpdateNetworkMetrics(metrics); in SetOverhead()
47 controller_->UpdateNetworkMetrics(metrics); in SetTargetBitrate()
53 controller_->UpdateNetworkMetrics(metrics); in SetUplinkBandwidth()
61 std::unique_ptr<FrameLengthControllerV2> controller_ = member in webrtc::FrameLengthControllerV2Test
106 controller_ = std::make_unique<FrameLengthControllerV2>( in TEST_F()
|
| /external/webrtc/test/scenario/ |
| D | call_client.cc | 91 : controller_(std::move(controller)) {} in NetworkControleUpdateCache()
94 return Update(controller_->OnNetworkAvailability(msg)); in OnNetworkAvailability()
98 return Update(controller_->OnNetworkRouteChange(msg)); in OnNetworkRouteChange()
102 return Update(controller_->OnProcessInterval(msg)); in OnProcessInterval()
106 return Update(controller_->OnRemoteBitrateReport(msg)); in OnRemoteBitrateReport()
110 return Update(controller_->OnRoundTripTimeUpdate(msg)); in OnRoundTripTimeUpdate()
113 return Update(controller_->OnSentPacket(msg)); in OnSentPacket()
117 return Update(controller_->OnReceivedPacket(msg)); in OnReceivedPacket()
121 return Update(controller_->OnStreamsConfig(msg)); in OnStreamsConfig()
125 return Update(controller_->OnTargetRateConstraints(msg)); in OnTargetRateConstraints()
[all …]
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_controller.cc | 112 Controller* const controller_; member in openscreen::osp::Controller::MessageGroupStreams
134 : controller_(controller), in MessageGroupStreams()
150 controller_->receiver_endpoints_[service_id_], this); in SendStartRequest()
178 controller_->presentations_[request->request.presentation_id]; in OnMatchedResponse()
184 request->presentation_connection_delegate, controller_); in OnMatchedResponse()
185 controller_->OpenConnection(response->connection_id, endpoint_id, service_id_, in OnMatchedResponse()
204 controller_->receiver_endpoints_[service_id_], this); in SendConnectionOpenRequest()
236 request->presentation_connection_delegate, controller_); in OnMatchedResponse()
244 controller_->AddConnection(request->connection.get()); in OnMatchedResponse()
259 controller_->receiver_endpoints_[service_id_], this); in SendConnectionCloseRequest()
[all …]
|
| D | presentation_controller_unittest.cc | 95 controller_ = std::make_unique<Controller>(FakeClock::now); in SetUp()
109 controller_.reset(); in TearDown()
272 Controller::ConnectRequest connect_request = controller_->StartPresentation( in StartPresentation()
301 std::unique_ptr<Controller> controller_; member in openscreen::osp::ControllerTest
311 Controller::ReceiverWatch watch1(controller_.get(), urls, &mock_observer); in TEST_F()
327 Controller::ConnectRequest request1(controller_.get(), service_id, false, in TEST_F()
343 controller_->RegisterReceiverWatch({kTestUrl}, &mock_receiver_observer_); in TEST_F()
358 controller_->RegisterReceiverWatch({kTestUrl}, &mock_receiver_observer2); in TEST_F()
364 controller_->RegisterReceiverWatch({kTestUrl}, &mock_receiver_observer_); in TEST_F()
379 controller_->RegisterReceiverWatch({kTestUrl}, &mock_receiver_observer2); in TEST_F()
[all …]
|
| /external/libchrome/mojo/public/js/lib/ |
| D | interface_endpoint_client.js | 10 this.controller_ = null;
36 if (this.controller_ || this.handle_.pendingAssociation()) {
40 this.controller_ = this.handle_.groupController().attachEndpointClient(
63 if (this.controller_) {
64 this.controller_ = null;
88 return this.controller_.sendMessage(message);
110 var result = this.controller_.sendMessage(message);
|
| /external/libchrome/base/message_loop/ |
| D | message_pump_libevent_unittest.cc | 96 : controller_(controller) { in BaseWatcher()
97 DCHECK(controller_); in BaseWatcher()
107 MessagePumpLibevent::FdWatchController* controller_; member in base::__anonb35f069d0111::BaseWatcher
115 ~DeleteWatcher() override { DCHECK(!controller_); } in ~DeleteWatcher()
118 DCHECK(controller_); in OnFileCanWriteWithoutBlocking()
119 delete controller_; in OnFileCanWriteWithoutBlocking()
120 controller_ = nullptr; in OnFileCanWriteWithoutBlocking()
144 controller_->StopWatchingFileDescriptor(); in OnFileCanWriteWithoutBlocking()
|
| /external/webrtc/rtc_tools/rtc_event_log_visualizer/ |
| D | log_simulation.cc | 39 controller_ = factory_->Create(config); in ProcessUntil()
47 HandleStateUpdate(controller_->OnProcessInterval(msg)); in ProcessUntil()
54 HandleStateUpdate(controller_->OnProcessInterval(msg)); in ProcessUntil()
104 HandleStateUpdate(controller_->OnSentPacket(*msg)); in OnPacketSent()
114 HandleStateUpdate(controller_->OnTransportPacketsFeedback(*msg)); in OnFeedback()
142 HandleStateUpdate(controller_->OnTransportLossReport(msg)); in OnReceiverReport()
159 HandleStateUpdate(controller_->OnRoundTripTimeUpdate(msg)); in OnReceiverReport()
173 HandleStateUpdate(controller_->OnNetworkRouteChange(msg)); in OnIceConfig()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | sequence_manager_impl.cc | 71 controller_(std::move(controller)), in SequenceManagerImpl()
76 DCHECK(controller_->RunsTasksInCurrentSequence()); in SequenceManagerImpl()
91 controller_->SetSequencedTaskSource(this); in SequenceManagerImpl()
92 controller_->AddNestingObserver(this); in SequenceManagerImpl()
101 controller_->RestoreDefaultTaskRunner(); in ~SequenceManagerImpl()
114 controller_->RemoveNestingObserver(this); in ~SequenceManagerImpl()
282 controller_->ScheduleWork(); in OnQueueHasIncomingImmediateWork()
287 controller_->ScheduleWork(); in MaybeScheduleImmediateWork()
292 controller_->SetNextDelayedDoWork(lazy_now, run_time); in SetNextDelayedDoWork()
318 LazyNow lazy_now(controller_->GetClock()); in TakeTask()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | interface_endpoint_client.cc | 171 if (controller_) in ~InterfaceEndpointClient()
191 if (controller_) { in PassHandle()
192 controller_ = nullptr; in PassHandle()
242 return controller_->SendMessage(message); in Accept()
269 if (!controller_->SendMessage(message)) in AcceptWithResponder()
285 controller_->SyncWatch(&response_received); in AcceptWithResponder()
351 if (controller_ || handle_.pending_association()) in InitControllerIfNecessary()
354 controller_ = handle_.group_controller()->AttachEndpointClient(handle_, this, in InitControllerIfNecessary()
357 controller_->AllowWokenUpBySyncWatchOnSameThread(); in InitControllerIfNecessary()
|
| D | associated_group.cc | 15 : controller_(std::move(controller)) {} in AssociatedGroup()
28 if (controller_) in GetController()
29 return controller_.get(); in GetController()
|
| /external/webrtc/modules/audio_coding/neteq/ |
| D | neteq_impl.cc | 143 controller_(std::move(deps.neteq_controller)), in NetEqImpl()
174 controller_->SetMaximumDelay(config.max_delay_ms); in NetEqImpl()
179 controller_->SetSampleRate(fs_hz_, output_size_samples_); in NetEqImpl()
208 controller_->RegisterEmptyPacket(); in InsertEmptyPacket()
340 assert(controller_.get()); in SetMinimumDelay()
341 return controller_->SetMinimumDelay( in SetMinimumDelay()
350 assert(controller_.get()); in SetMaximumDelay()
351 return controller_->SetMaximumDelay( in SetMaximumDelay()
360 return controller_->SetBaseMinimumDelay(delay_ms); in SetBaseMinimumDelayMs()
367 return controller_->GetBaseMinimumDelay(); in GetBaseMinimumDelayMs()
[all …]
|
| /external/webrtc/modules/desktop_capture/win/ |
| D | screen_capturer_win_directx.cc | 102 : controller_(DxgiDuplicatorController::Instance()) {} in ScreenCapturerWinDirectx()
132 result = controller_->Duplicate(frames_.current_frame()); in CaptureFrame()
134 result = controller_->DuplicateMonitor(frames_.current_frame(), in CaptureFrame()
187 if (!controller_->GetDeviceNames(&device_names)) { in GetSourceList()
201 if (!controller_->GetDeviceNames(&device_names)) { in SelectSource()
|
| D | screen_capturer_win_directx.h | 85 const rtc::scoped_refptr<DxgiDuplicatorController> controller_;
|
| /external/openscreen/cast/standalone_receiver/ |
| D | mirroring_application.cc | 56 controller_ = in Launch()
59 controller_.get(), environment_.get(), message_port, in Launch()
78 controller_.reset(); in Stop()
|
| /external/webrtc/modules/congestion_controller/goog_cc/ |
| D | goog_cc_network_control_unittest.cc | 133 controller_ = factory_.Create(InitialConfig()); in SetUp()
135 controller_->OnProcessInterval(DefaultInterval()); in SetUp()
148 controller_ = factory_.Create(InitialConfig()); in TargetBitrateTrackingSetup()
149 OnUpdate(controller_->OnProcessInterval(DefaultInterval())); in TargetBitrateTrackingSetup()
222 OnUpdate(controller_->OnSentPacket(packet.sent_packet)); in PacketTransmissionAndFeedbackBlock()
226 OnUpdate(controller_->OnTransportPacketsFeedback(feedback)); in PacketTransmissionAndFeedbackBlock()
228 OnUpdate(controller_->OnProcessInterval(DefaultInterval())); in PacketTransmissionAndFeedbackBlock()
235 std::unique_ptr<NetworkControllerInterface> controller_; member in webrtc::test::GoogCcNetworkControllerTest
241 OnUpdate(controller_->OnProcessInterval(DefaultInterval())); in TEST_F()
244 OnUpdate(controller_->OnRemoteBitrateReport( in TEST_F()
[all …]
|
| /external/libchrome/base/files/ |
| D | file_descriptor_watcher_posix.cc | 73 WeakPtr<Controller> controller_; member in base::FileDescriptorWatcher::Controller::Watcher
98 controller_(controller), in Watcher()
135 FROM_HERE, BindOnce(&Controller::RunCallback, controller_)); in OnFileCanReadWithoutBlocking()
146 FROM_HERE, BindOnce(&Controller::RunCallback, controller_)); in OnFileCanWriteWithoutBlocking()
|
| /external/webrtc/modules/congestion_controller/pcc/ |
| D | pcc_network_controller_unittest.cc | 68 std::unique_ptr<NetworkControllerInterface> controller_; in TEST() local
69 controller_.reset(new pcc::PccNetworkController(InitialConfig())); in TEST()
72 controller_->OnProcessInterval(InitialProcessInterval()); in TEST()
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | associated_group.h | 46 scoped_refptr<AssociatedGroupController> controller_; in COMPONENT_EXPORT() local
|
| /external/openscreen/osp/public/presentation/ |
| D | presentation_controller.h | 73 Controller* controller_ = nullptr; variable
96 Controller* controller_; variable
|