Hide deprecated SingleThreadedTaskQueueForTest behind an accessor
this change is intentionally noop.
Goal is to minimize change that would replace the
SingleThreadedTaskQueueForTest with a regular task queue.
Bug: webrtc:10933
Change-Id: I6da768941af048de3716af13e41b8f0f1ccd4cab
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/157892
Reviewed-by: Ilya Nikolaevskiy <ilnik@webrtc.org>
Reviewed-by: Sebastian Jansson <srte@webrtc.org>
Commit-Queue: Danil Chapovalov <danilchap@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#29569}
diff --git a/video/video_quality_test.cc b/video/video_quality_test.cc
index 091c1f3..8f7d612 100644
--- a/video/video_quality_test.cc
+++ b/video/video_quality_test.cc
@@ -1189,7 +1189,7 @@
network_behavior = std::move(injection_components_->sender_network);
}
return std::make_unique<test::LayerFilteringTransport>(
- &task_queue_,
+ task_queue(),
std::make_unique<FakeNetworkPipe>(clock_, std::move(network_behavior)),
sender_call_.get(), kPayloadTypeVP8, kPayloadTypeVP9,
params_.video[0].selected_tl, params_.ss[0].selected_sl,
@@ -1207,7 +1207,7 @@
network_behavior = std::move(injection_components_->receiver_network);
}
return std::make_unique<test::DirectTransport>(
- &task_queue_,
+ task_queue(),
std::make_unique<FakeNetworkPipe>(clock_, std::move(network_behavior)),
receiver_call_.get(), payload_type_map_);
}
@@ -1255,7 +1255,7 @@
recv_event_log_ = std::make_unique<RtcEventLogNull>();
}
- SendTask(RTC_FROM_HERE, &task_queue_,
+ SendTask(RTC_FROM_HERE, task_queue(),
[this, ¶ms, &send_transport, &recv_transport]() {
Call::Config send_call_config(send_event_log_.get());
Call::Config recv_call_config(recv_event_log_.get());
@@ -1286,9 +1286,9 @@
static_cast<size_t>(params_.ss[0].selected_stream),
params.ss[0].selected_sl, params_.video[0].selected_tl,
is_quick_test_enabled, clock_, params_.logging.rtp_dump_name,
- &task_queue_);
+ task_queue());
- SendTask(RTC_FROM_HERE, &task_queue_, [&]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [&]() {
analyzer_->SetCall(sender_call_.get());
analyzer_->SetReceiver(receiver_call_->Receiver());
send_transport->SetReceiver(analyzer_.get());
@@ -1334,7 +1334,7 @@
analyzer_->Wait();
- SendTask(RTC_FROM_HERE, &task_queue_, [&]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [&]() {
StopThumbnails();
Stop();
@@ -1477,7 +1477,7 @@
recv_event_log_ = std::make_unique<RtcEventLogNull>();
}
- SendTask(RTC_FROM_HERE, &task_queue_, [&]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [&]() {
params_ = params;
CheckParamsAndInjectionComponents();
@@ -1564,9 +1564,9 @@
Start();
});
- test::PressEnterToContinue(&task_queue_);
+ test::PressEnterToContinue(task_queue());
- SendTask(RTC_FROM_HERE, &task_queue_, [&]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [&]() {
Stop();
DestroyStreams();