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/call/bitrate_estimator_tests.cc b/call/bitrate_estimator_tests.cc
index ae2a6b6..b5c4d8e 100644
--- a/call/bitrate_estimator_tests.cc
+++ b/call/bitrate_estimator_tests.cc
@@ -103,18 +103,18 @@
virtual ~BitrateEstimatorTest() { EXPECT_TRUE(streams_.empty()); }
virtual void SetUp() {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
CreateCalls();
send_transport_.reset(new test::DirectTransport(
- &task_queue_,
+ task_queue(),
std::make_unique<FakeNetworkPipe>(
Clock::GetRealTimeClock(), std::make_unique<SimulatedNetwork>(
BuiltInNetworkBehaviorConfig())),
sender_call_.get(), payload_type_map_));
send_transport_->SetReceiver(receiver_call_->Receiver());
receive_transport_.reset(new test::DirectTransport(
- &task_queue_,
+ task_queue(),
std::make_unique<FakeNetworkPipe>(
Clock::GetRealTimeClock(), std::make_unique<SimulatedNetwork>(
BuiltInNetworkBehaviorConfig())),
@@ -146,7 +146,7 @@
}
virtual void TearDown() {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
for (auto* stream : streams_) {
stream->StopSending();
delete stream;
@@ -249,7 +249,7 @@
"RemoteBitrateEstimatorSingleStream: Instantiating.";
TEST_F(BitrateEstimatorTest, InstantiatesTOFPerDefaultForVideo) {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions.push_back(
RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId));
receiver_log_.PushExpectedLogLine(kSingleStreamLog);
@@ -260,7 +260,7 @@
}
TEST_F(BitrateEstimatorTest, ImmediatelySwitchToASTForVideo) {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions.push_back(
RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId));
receiver_log_.PushExpectedLogLine(kSingleStreamLog);
@@ -273,7 +273,7 @@
}
TEST_F(BitrateEstimatorTest, SwitchesToASTForVideo) {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions.push_back(
RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId));
receiver_log_.PushExpectedLogLine(kSingleStreamLog);
@@ -282,7 +282,7 @@
});
EXPECT_TRUE(receiver_log_.Wait());
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions[0] =
RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId);
receiver_log_.PushExpectedLogLine("Switching to absolute send time RBE.");
@@ -294,7 +294,7 @@
// This test is flaky. See webrtc:5790.
TEST_F(BitrateEstimatorTest, DISABLED_SwitchesToASTThenBackToTOFForVideo) {
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions.push_back(
RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId));
receiver_log_.PushExpectedLogLine(kSingleStreamLog);
@@ -304,7 +304,7 @@
});
EXPECT_TRUE(receiver_log_.Wait());
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions[0] =
RtpExtension(RtpExtension::kAbsSendTimeUri, kASTExtensionId);
receiver_log_.PushExpectedLogLine(kAbsSendTimeLog);
@@ -313,7 +313,7 @@
});
EXPECT_TRUE(receiver_log_.Wait());
- SendTask(RTC_FROM_HERE, &task_queue_, [this]() {
+ SendTask(RTC_FROM_HERE, task_queue(), [this]() {
GetVideoSendConfig()->rtp.extensions[0] =
RtpExtension(RtpExtension::kTimestampOffsetUri, kTOFExtensionId);
receiver_log_.PushExpectedLogLine(kAbsSendTimeLog);