| /external/webrtc/modules/video_coding/utility/ |
| D | quality_scaler_unittest.cc | 87 task_queue_.SendTask( in QualityScalerTest()
96 task_queue_.SendTask([this] { qs_ = nullptr; }, RTC_FROM_HERE); in ~QualityScalerTest()
135 task_queue_.SendTask([this] { TriggerScale(kScaleDown); }, RTC_FROM_HERE); in TEST_P()
142 task_queue_.SendTask([this] { TriggerScale(kKeepScaleAtHighQp); }, in TEST_P()
150 task_queue_.SendTask([this] { TriggerScale(kScaleDownAboveHighQp); }, in TEST_P()
158 task_queue_.SendTask( in TEST_P()
173 task_queue_.SendTask( in TEST_P()
188 task_queue_.SendTask( in TEST_P()
203 task_queue_.SendTask([this] { TriggerScale(kKeepScaleAboveLowQp); }, in TEST_P()
211 task_queue_.SendTask([this] { TriggerScale(kScaleUp); }, RTC_FROM_HERE); in TEST_P()
[all …]
|
| /external/webrtc/modules/video_coding/codecs/test/ |
| D | videoprocessor_unittest.cc | 57 q_.SendTask( in VideoProcessorTest()
67 q_.SendTask([this] { video_processor_.reset(); }, RTC_FROM_HERE); in ~VideoProcessorTest()
109 q_.SendTask([=] { video_processor_->SetRates(kBitrateKbps, kFramerateFps); }, in TEST_F()
118 q_.SendTask([this] { video_processor_->ProcessFrame(); }, RTC_FROM_HERE); in TEST_F()
124 q_.SendTask([this] { video_processor_->ProcessFrame(); }, RTC_FROM_HERE); in TEST_F()
138 q_.SendTask( in TEST_F()
147 q_.SendTask([this] { video_processor_->ProcessFrame(); }, RTC_FROM_HERE); in TEST_F()
155 q_.SendTask( in TEST_F()
164 q_.SendTask([this] { video_processor_->ProcessFrame(); }, RTC_FROM_HERE); in TEST_F()
183 q_.SendTask([=] { video_processor_->SetRates(kBitrateKbps, kFramerateFps); }, in TEST_F()
[all …]
|
| D | videocodec_test_fixture_impl.cc | 453 task_queue->SendTask([] {}, RTC_FROM_HERE); in ProcessAllFrames()
697 task_queue->SendTask( in SetUpAndInitObjects()
710 task_queue->SendTask( in ReleaseAndCloseObjects()
739 task_queue->SendTask( in PrintSettings()
|
| /external/webrtc/test/scenario/ |
| D | audio_stream.cc | 130 sender_->SendTask([&] { in SendAudioStream()
140 sender_->SendTask( in ~SendAudioStream()
145 sender_->SendTask([this] { in Start()
152 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
156 sender_->SendTask([this, mute] { send_stream_->SetMuted(mute); }); in SetMuted()
163 sender_->SendTask([this, &sb] { in StatsPrinter()
193 receiver_->SendTask([&] { in ReceiveAudioStream()
198 receiver_->SendTask( in ~ReceiveAudioStream()
203 receiver_->SendTask([&] { in Start()
210 receiver_->SendTask([&] { receive_stream_->Stop(); }); in Stop()
[all …]
|
| D | video_stream.cc | 414 sender_->SendTask([&] { in SendVideoStream()
437 sender_->SendTask( in ~SendVideoStream()
442 sender_->SendTask([this] { in Start()
449 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
454 sender_->SendTask([&] { in UpdateConfig()
508 sender_->SendTask([&] { video_capturer_->ChangeFramerate(framerate); }); in SetCaptureFramerate()
576 receiver_->SendTask([this, &flexfec] { in ReceiveVideoStream()
584 receiver_->SendTask([this, &recv_config] { in ReceiveVideoStream()
592 receiver_->SendTask([this] { in ~ReceiveVideoStream()
601 receiver_->SendTask([this] { in Start()
[all …]
|
| D | call_client.cc | 213 SendTask([this, config] { in CallClient()
230 SendTask([&] { in ~CallClient()
255 SendTask([this, &stats] { stats = call_->GetStats(); }); in GetStats()
324 void CallClient::SendTask(std::function<void()> task) { in SendTask() function in webrtc::test::CallClient
325 task_queue_.SendTask(std::move(task), RTC_FROM_HERE); in SendTask()
|
| /external/webrtc/rtc_base/synchronization/ |
| D | sequence_checker_unittest.cc | 87 queue.SendTask([&] { EXPECT_TRUE(sequence_checker.IsCurrent()); }, in TEST()
93 queue.SendTask( in TEST()
112 queue.SendTask( in TEST()
122 queue1.SendTask([&] { EXPECT_TRUE(sequence_checker.IsCurrent()); }, in TEST()
128 queue2.SendTask( in TEST()
157 queue.SendTask([&] { annotations.ModifyTestVar(); }, RTC_FROM_HERE); in TestAnnotationsOnWrongQueue()
|
| /external/webrtc/rtc_base/task_utils/ |
| D | pending_task_safety_flag_unittest.cc | 95 tq1.SendTask( in TEST()
102 tq2.SendTask([&owner]() { owner->DoStuff(); }, RTC_FROM_HERE); in TEST()
103 tq1.SendTask( in TEST()
141 tq1.SendTask([&owner, &stuff_done]() { owner.reset(new Owner(&stuff_done)); }, in TEST()
153 tq2.SendTask([&owner]() { owner->DoStuff(); }, RTC_FROM_HERE); in TEST()
159 tq1.SendTask([]() {}, RTC_FROM_HERE); in TEST()
|
| /external/webrtc/call/ |
| D | bitrate_estimator_tests.cc | 108 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in SetUp()
151 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TearDown()
254 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
265 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
278 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
287 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
299 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
309 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
318 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
|
| /external/webrtc/video/end_to_end_tests/ |
| D | probing_tests.cc | 84 SendTask(RTC_FROM_HERE, task_queue_,
136 SendTask(RTC_FROM_HERE, task_queue_,
144 SendTask(RTC_FROM_HERE, task_queue_, [this, &bitrate_config]() {
155 SendTask(RTC_FROM_HERE, task_queue_, [this, &bitrate_config]() {
241 SendTask(RTC_FROM_HERE, task_queue_,
282 SendTask(RTC_FROM_HERE, task_queue_, [this]() {
|
| D | rtp_rtcp_tests.cc | 286 SendTask( in TestRtpStatePreservation()
339 SendTask(RTC_FROM_HERE, task_queue(), [&]() { in TestRtpStatePreservation()
361 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestRtpStatePreservation()
370 SendTask(RTC_FROM_HERE, task_queue(), [this, &one_stream]() { in TestRtpStatePreservation()
377 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestRtpStatePreservation()
386 SendTask(RTC_FROM_HERE, task_queue(), in TestRtpStatePreservation()
487 SendTask(RTC_FROM_HERE, task_queue(), [&]() { in TEST_F()
565 SendTask(RTC_FROM_HERE, task_queue(), [this, &observer]() { in TEST_F()
574 SendTask(RTC_FROM_HERE, task_queue(), [this, &observer]() { in TEST_F()
586 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
|
| D | call_operation_tests.cc | 100 SendTask( in TEST_F()
149 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
175 SendTask( in TEST_F()
219 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
|
| D | multi_codec_receive_tests.cc | 132 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in MultiCodecReceiveTest()
154 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in ~MultiCodecReceiveTest()
213 SendTask(RTC_FROM_HERE, task_queue(), [this, &configs]() { in RunTestWithCodecs()
229 SendTask(RTC_FROM_HERE, task_queue(), [this, i, &configs]() { in RunTestWithCodecs()
242 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in RunTestWithCodecs()
|
| D | network_state_tests.cc | 93 SendTask(RTC_FROM_HERE, task_queue(), in VerifyNewVideoSendStreamsRespectNetworkState()
111 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in VerifyNewVideoSendStreamsRespectNetworkState()
123 SendTask( in VerifyNewVideoReceiveStreamsRespectNetworkState()
146 SendTask(RTC_FROM_HERE, task_queue(), [this, &sender_transport]() { in VerifyNewVideoReceiveStreamsRespectNetworkState()
226 SendTask(RTC_FROM_HERE, task_queue_, [this]() { in TEST_F()
|
| D | stats_tests.cc | 313 SendTask(RTC_FROM_HERE, task_queue_, in TEST_F()
390 SendTask(RTC_FROM_HERE, task_queue_, [&]() { in TEST_F()
398 SendTask(RTC_FROM_HERE, task_queue_, [&]() { in TEST_F()
524 SendTask( in TEST_F()
565 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
576 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
726 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
759 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
773 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
|
| D | bandwidth_tests.cc | 98 SendTask(RTC_FROM_HERE, task_queue_, [] {}); in ~BandwidthStatsTest()
211 SendTask(RTC_FROM_HERE, task_queue_, [this]() { rtp_rtcp_ = nullptr; }); in TEST_F()
366 SendTask(RTC_FROM_HERE, task_queue_, [this]() { in TEST_F()
|
| D | multi_stream_tester.cc | 70 SendTask(RTC_FROM_HERE, task_queue.get(), [&]() { in RunTest()
131 SendTask(RTC_FROM_HERE, task_queue.get(), [&]() { in RunTest()
|
| D | ssrc_tests.cc | 82 SendTask( in TEST_F()
119 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
|
| /external/webrtc/video/ |
| D | picture_id_tests.cc | 216 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in ~PictureIdTest()
245 SendTask( in SetupEncoder()
291 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
309 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
316 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
324 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestPictureIdIncreaseAfterRecreateStreams()
339 SendTask(RTC_FROM_HERE, task_queue(), [this, &ssrc_count]() { in TestPictureIdIncreaseAfterRecreateStreams()
354 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestPictureIdIncreaseAfterRecreateStreams()
|
| D | video_send_stream_impl_unittest.cc | 180 test_queue_.SendTask( in TEST_F()
205 test_queue_.SendTask( in TEST_F()
270 test_queue_.SendTask( in TEST_F()
342 test_queue_.SendTask( in TEST_F()
402 test_queue_.SendTask( in TEST_F()
421 test_queue_.SendTask( in TEST_F()
434 test_queue_.SendTask( in TEST_F()
483 test_queue_.SendTask( in TEST_F()
542 test_queue_.SendTask( in TEST_F()
587 test_queue_.SendTask( in TEST_F()
[all …]
|
| D | video_send_stream_tests.cc | 128 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
142 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
1639 SendTask(RTC_FROM_HERE, task_queue_, [this]() { rtp_rtcp_ = nullptr; }); in TEST_F()
1728 SendTask(RTC_FROM_HERE, task_queue_, [] {}); in TEST_F()
1786 SendTask(RTC_FROM_HERE, task_queue_, in TEST_F()
1799 SendTask( in TEST_F()
1854 SendTask(RTC_FROM_HERE, task_queue_, [] {}); in TEST_F()
1890 SendTask(RTC_FROM_HERE, task_queue_, [this, &route]() { in TEST_F()
1906 SendTask(RTC_FROM_HERE, task_queue_, [this, &route]() { in TEST_F()
1964 SendTask(RTC_FROM_HERE, task_queue_, [this]() { in TEST_F()
[all …]
|
| /external/webrtc/audio/ |
| D | audio_send_stream_unittest.cc | 599 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
617 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
635 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
653 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
676 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
698 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
720 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
739 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
843 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
852 helper.worker()->SendTask([&] { send_stream->OnBitrateUpdated(update); }, in TEST()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | task_queue_for_test.h | 28 void SendTask(rtc::Location loc, TaskQueueBase* task_queue, Closure&& task) { function
|
| D | weak_ptr_unittest.cc | 207 queue.SendTask([&] { obj = std::make_unique<T>(); }, RTC_FROM_HERE); in NewObjectCreatedOnTaskQueue()
229 queue.SendTask( in TEST()
|
| /external/webrtc/test/pc/e2e/ |
| D | test_activities_executor.cc | 40 task_queue_->SendTask( in Stop()
|