Home
last modified time | relevance | path

Searched refs:SendTask (Results 1 – 25 of 54) sorted by relevance

123

/external/webrtc/modules/video_coding/utility/
Dquality_scaler_unittest.cc75 task_queue_.SendTask( in QualityScalerTest()
83 task_queue_.SendTask([this] { qs_ = nullptr; }); in ~QualityScalerTest()
122 task_queue_.SendTask([this] { TriggerScale(kScaleDown); }); in TEST_P()
129 task_queue_.SendTask([this] { TriggerScale(kKeepScaleAtHighQp); }); in TEST_P()
136 task_queue_.SendTask([this] { TriggerScale(kScaleDownAboveHighQp); }); in TEST_P()
143 task_queue_.SendTask([this] { in TEST_P()
156 task_queue_.SendTask([this] { in TEST_P()
170 task_queue_.SendTask([this] { in TEST_P()
183 task_queue_.SendTask([this] { TriggerScale(kKeepScaleAboveLowQp); }); in TEST_P()
190 task_queue_.SendTask([this] { TriggerScale(kScaleUp); }); in TEST_P()
[all …]
Dbandwidth_quality_scaler_unittest.cc100 task_queue_.SendTask( in BandwidthQualityScalerTest()
114 task_queue_.SendTask([this] { bandwidth_quality_scaler_ = nullptr; }); in ~BandwidthQualityScalerTest()
153 task_queue_.SendTask( in TriggerBandwidthQualityScalerTest()
/external/webrtc/modules/video_coding/codecs/test/
Dvideoprocessor_unittest.cc57 q_.SendTask( in VideoProcessorTest()
66 q_.SendTask([this] { video_processor_.reset(); }); in ~VideoProcessorTest()
108 q_.SendTask([=] { video_processor_->SetRates(kBitrateKbps, kFramerateFps); }); in TEST_F()
116 q_.SendTask([this] { video_processor_->ProcessFrame(); }); in TEST_F()
122 q_.SendTask([this] { video_processor_->ProcessFrame(); }); in TEST_F()
136 q_.SendTask( in TEST_F()
144 q_.SendTask([this] { video_processor_->ProcessFrame(); }); in TEST_F()
152 q_.SendTask( in TEST_F()
160 q_.SendTask([this] { video_processor_->ProcessFrame(); }); in TEST_F()
179 q_.SendTask([=] { video_processor_->SetRates(kBitrateKbps, kFramerateFps); }); in TEST_F()
[all …]
/external/webrtc/test/scenario/
Daudio_stream.cc130 sender_->SendTask([&] { in SendAudioStream()
138 sender_->SendTask( in ~SendAudioStream()
143 sender_->SendTask([this] { in Start()
150 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
154 sender_->SendTask([this, mute] { send_stream_->SetMuted(mute); }); in SetMuted()
161 sender_->SendTask([this, &sb] { in StatsPrinter()
190 receiver_->SendTask([&] { in ReceiveAudioStream()
195 receiver_->SendTask( in ~ReceiveAudioStream()
200 receiver_->SendTask([&] { in Start()
207 receiver_->SendTask([&] { receive_stream_->Stop(); }); in Stop()
[all …]
Dcall_client.cc223 SendTask([this, config] { in CallClient()
236 SendTask([&] { in ~CallClient()
260 SendTask([this, &stats] { stats = call_->GetStats(); }); in GetStats()
286 SendTask([this, &constraints]() { in UpdateBitrateConstraints()
336 void CallClient::SendTask(std::function<void()> task) { in SendTask() function in webrtc::test::CallClient
337 task_queue_.SendTask(std::move(task)); in SendTask()
Dvideo_stream.cc417 sender_->SendTask([&] { in SendVideoStream()
440 sender_->SendTask( in ~SendVideoStream()
445 sender_->SendTask([this] { in Start()
452 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
457 sender_->SendTask([&] { in UpdateConfig()
510 sender_->SendTask([&] { video_capturer_->ChangeFramerate(framerate); }); in SetCaptureFramerate()
575 receiver_->SendTask([this, &flexfec] { in ReceiveVideoStream()
583 receiver_->SendTask([this, &recv_config] { in ReceiveVideoStream()
591 receiver_->SendTask([this] { in ~ReceiveVideoStream()
600 receiver_->SendTask([this] { in Start()
[all …]
Dstats_collection_unittest.cc38 caller->SendTask([&]() { send_stats = video->send()->GetStats(); }); in CreateAnalyzedStream()
42 caller->SendTask([&]() { receive_stats = audio->receive()->GetStats(); }); in CreateAnalyzedStream()
50 callee->SendTask([&video_stream, &video_receive_stats]() { in CreateAnalyzedStream()
/external/webrtc/api/
Dsequence_checker_unittest.cc83 queue.SendTask([&] { EXPECT_TRUE(sequence_checker.IsCurrent()); }); in TEST()
88 queue.SendTask([] { in TEST()
104 queue.SendTask( in TEST()
113 queue1.SendTask([&] { EXPECT_TRUE(sequence_checker.IsCurrent()); }); in TEST()
118 queue2.SendTask( in TEST()
176 queue.SendTask([&] { annotations.ModifyTestVar(); }); in TestAnnotationsOnWrongQueue()
/external/webrtc/test/network/
Dnetwork_emulation_unittest.cc217 SendTask(t1, [&] { in TEST()
220 SendTask(t2, [&] { in TEST()
230 SendTask(t1, [&] { in TEST()
234 SendTask(t2, [&] { in TEST()
239 SendTask(t1, [&] { s1->Connect(a2); }); in TEST()
240 SendTask(t2, [&] { s2->Connect(a1); }); in TEST()
252 SendTask(t1, [&] { delete s1; }); in TEST()
253 SendTask(t2, [&] { delete s2; }); in TEST()
371 SendTask(t1, [&] { in TEST()
374 SendTask(t2, [&] { in TEST()
[all …]
Demulated_turn_server.cc125 SendTask(thread_.get(), [=]() { in EmulatedTURNServer()
146 SendTask(thread_.get(), [=]() { in Stop()
153 SendTask(thread_.get(), [=]() { in ~EmulatedTURNServer()
Dnetwork_emulation_pc_unittest.cc151 SendTask(signaling_thread.get(), [&]() { in TEST()
172 SendTask(signaling_thread.get(), [&]() { in TEST()
262 SendTask(signaling_thread.get(), [&]() { in TEST()
283 SendTask(signaling_thread.get(), [&]() { in TEST()
/external/webrtc/rtc_base/
Dtask_queue_for_test.h27 inline void SendTask(TaskQueueBase* task_queue, in SendTask() function
52 void SendTask(rtc::FunctionView<void()> task) { in SendTask() function
53 ::webrtc::SendTask(Get(), task); in SendTask()
62 SendTask([]() {}); in WaitForPreviouslyPostedTasks()
/external/webrtc/api/task_queue/
Dpending_task_safety_flag_unittest.cc88 tq1.SendTask([&owner]() { in TEST()
93 tq2.SendTask([&owner]() { owner->DoStuff(); }); in TEST()
94 tq1.SendTask([&owner]() { in TEST()
128 tq1.SendTask([&owner, &stuff_done]() { in TEST()
141 tq2.SendTask([&owner]() { owner->DoStuff(); }); in TEST()
157 tq.SendTask([&flag]() { EXPECT_FALSE(flag->alive()); }); in TEST()
/external/webrtc/call/
Dbitrate_estimator_tests.cc113 SendTask(task_queue(), [this]() { in SetUp()
157 SendTask(task_queue(), [this]() { in TearDown()
260 SendTask(task_queue(), [this]() { in TEST_F()
271 SendTask(task_queue(), [this]() { in TEST_F()
284 SendTask(task_queue(), [this]() { in TEST_F()
293 SendTask(task_queue(), [this]() { in TEST_F()
305 SendTask(task_queue(), [this]() { in TEST_F()
315 SendTask(task_queue(), [this]() { in TEST_F()
324 SendTask(task_queue(), [this]() { in TEST_F()
/external/webrtc/video/
Dpicture_id_tests.cc220 SendTask(task_queue(), [this]() { in ~PictureIdTest()
256 SendTask( in SetupEncoder()
302 SendTask(task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
320 SendTask(task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
327 SendTask(task_queue(), [this]() { in TestPictureIdContinuousAfterReconfigure()
335 SendTask(task_queue(), [this]() { in TestPictureIdIncreaseAfterRecreateStreams()
350 SendTask(task_queue(), [this, &ssrc_count]() { in TestPictureIdIncreaseAfterRecreateStreams()
365 SendTask(task_queue(), [this]() { in TestPictureIdIncreaseAfterRecreateStreams()
/external/webrtc/video/end_to_end_tests/
Drtp_rtcp_tests.cc286 SendTask( in TestRtpStatePreservation()
338 SendTask(task_queue(), [&]() { in TestRtpStatePreservation()
360 SendTask(task_queue(), [this]() { in TestRtpStatePreservation()
369 SendTask(task_queue(), [this, &one_stream]() { in TestRtpStatePreservation()
376 SendTask(task_queue(), [this]() { in TestRtpStatePreservation()
385 SendTask(task_queue(), [this, &send_transport, &receive_transport]() { in TestRtpStatePreservation()
485 SendTask(task_queue(), [&]() { in TEST_F()
564 SendTask(task_queue(), [this, &observer]() { in TEST_F()
573 SendTask(task_queue(), [this, &observer]() { in TEST_F()
585 SendTask(task_queue(), [this, &send_transport, &receive_transport]() { in TEST_F()
Dnetwork_state_tests.cc97 SendTask(task_queue(), in VerifyNewVideoSendStreamsRespectNetworkState()
115 SendTask(task_queue(), [this]() { in VerifyNewVideoSendStreamsRespectNetworkState()
127 SendTask( in VerifyNewVideoReceiveStreamsRespectNetworkState()
150 SendTask(task_queue(), [this, &sender_transport]() { in VerifyNewVideoReceiveStreamsRespectNetworkState()
232 SendTask(e2e_test_task_queue_, [call, media_type, network_state] { in TEST_F()
241 SendTask(task_queue_.get(), [this]() { in TEST_F()
Dcall_operation_tests.cc100 SendTask( in TEST_F()
148 SendTask(task_queue(), [this, &sender_transport, &receiver_transport]() { in TEST_F()
173 SendTask( in TEST_F()
216 SendTask(task_queue(), [this, &sender_transport, &receiver_transport]() { in TEST_F()
Dmulti_codec_receive_tests.cc132 SendTask(task_queue(), [this]() { in MultiCodecReceiveTest()
154 SendTask(task_queue(), [this]() { in ~MultiCodecReceiveTest()
246 SendTask(task_queue(), in RunTestWithCodecs()
264 SendTask(task_queue(), [this, i, &configs, &encoder_factory]() { in RunTestWithCodecs()
277 SendTask(task_queue(), [this]() { in RunTestWithCodecs()
Dstats_tests.cc150 SendTask(task_queue_, [&]() { stats = send_stream_->GetStats(); }); in TEST_F()
306 SendTask(task_queue_, [&]() { receive_ok = CheckReceiveStats(); }); in TEST_F()
381 SendTask(task_queue_, [&]() { in TEST_F()
389 SendTask(task_queue_, [&]() { in TEST_F()
512 SendTask( in TEST_F()
552 SendTask(task_queue(), [this, &encoder_config_with_screenshare]() { in TEST_F()
562 SendTask(task_queue(), [this]() { in TEST_F()
704 SendTask(task_queue(), in TEST_F()
737 SendTask(task_queue(), in TEST_F()
752 SendTask(task_queue(), [this, &sender_transport, &receiver_transport]() { in TEST_F()
Dssrc_tests.cc83 SendTask( in TEST_F()
120 SendTask(task_queue(), [this, &send_transport, &receive_transport]() { in TEST_F()
205 SendTask(task_queue_, [&]() { in TestSendsSetSsrcs()
/external/webrtc/modules/desktop_capture/win/
Dwindow_capture_utils_unittest.cc38 SendTask(window_thread.get(), [&] { info = CreateTestWindow(kWindowTitle); }); in SetUpUnresponsiveWindow()
85 SendTask(window_thread.get(), [&info]() { DestroyTestWindow(info); }); in TEST()
108 SendTask(window_thread.get(), [&info]() { DestroyTestWindow(info); }); in TEST()
/external/webrtc/test/pc/e2e/
Dpeer_connection_quality_test.cc369 SendTask(signaling_thread.get(), in Run()
374 SendTask(signaling_thread.get(), [this, &signaling_interceptor] { in Run()
379 SendTask(signaling_thread.get(), [this, &signaling_interceptor] { in Run()
402 task_queue_->SendTask([&stats_poller]() { in Run()
411 SendTask(signaling_thread.get(), [this] { TearDownCallOnSignalingThread(); }); in Run()
622 SendTask(signaling_thread, [&]() { in WaitUntilIceCandidatesGathered()
636 SendTask(signaling_thread, [&] { result = alice_->IsIceConnected(); }); in WaitUntilPeersAreConnected()
643 SendTask(signaling_thread, [&] { result = bob_->IsIceConnected(); }); in WaitUntilPeersAreConnected()
/external/webrtc/pc/
Dchannel_unittest.cc137 SendTask(network_thread_, [this]() { in ~ChannelTest()
288 SendTask(network_thread_, [this]() { in DeinitChannels()
306 SendTask(network_thread_, in CreateUnencryptedTransport()
322 SendTask(network_thread_, in CreateDtlsSrtpTransport()
331 SendTask(network_thread_, [this] { in ConnectFakeTransports()
538 SendTask(network_thread_, [&] { result = channel->srtp_active(); }); in IsSrtpActive()
547 SendTask(network_thread_, [&] { in IsRtcpMuxEnabled()
867 SendTask(network_thread_, [this] { in TestNetworkRouteChanges()
878 SendTask(network_thread_, [this] { in TestNetworkRouteChanges()
1038 SendTask(network_thread_, in SendWithWritabilityLoss()
[all …]
Dvideo_rtp_receiver_unittest.cc84 SendTask(worker_thread_.get(), in SetMediaChannel()
185 SendTask(worker_thread_.get(), [&] { broadcast(frame); }); in TEST_F()

123