Remove unused NextFrame function from FrameBuffer.
Also updated FrameBuffer unittests to use the GlobalSimulatedTimeController.
Bug: webrtc:7408, webrtc:9378
Change-Id: I8ade27492f66cdd8950b38f5f4a268714dbc35fc
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/164536
Reviewed-by: Sam Zackrisson <saza@webrtc.org>
Reviewed-by: Rasmus Brandt <brandtr@webrtc.org>
Commit-Queue: Philip Eliasson <philipel@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#30422}
diff --git a/modules/video_coding/frame_buffer2_unittest.cc b/modules/video_coding/frame_buffer2_unittest.cc
index 09300fb..2c342d0 100644
--- a/modules/video_coding/frame_buffer2_unittest.cc
+++ b/modules/video_coding/frame_buffer2_unittest.cc
@@ -26,6 +26,7 @@
#include "test/field_trial.h"
#include "test/gmock.h"
#include "test/gtest.h"
+#include "test/time_controller/simulated_time_controller.h"
using ::testing::_;
using ::testing::Return;
@@ -134,20 +135,16 @@
TestFrameBuffer2()
: trial_("WebRTC-AddRttToPlayoutDelay/Enabled/"),
- clock_(0),
- timing_(&clock_),
- buffer_(new FrameBuffer(&clock_, &timing_, &stats_callback_)),
- rand_(0x34678213),
- tear_down_(false),
- extract_thread_(&ExtractLoop, this, "Extract Thread") {}
-
- void SetUp() override { extract_thread_.Start(); }
-
- void TearDown() override {
- tear_down_ = true;
- trigger_extract_event_.Set();
- extract_thread_.Stop();
- }
+ time_controller_(Timestamp::seconds(0)),
+ time_task_queue_(
+ time_controller_.GetTaskQueueFactory()->CreateTaskQueue(
+ "extract queue",
+ TaskQueueFactory::Priority::NORMAL)),
+ timing_(time_controller_.GetClock()),
+ buffer_(new FrameBuffer(time_controller_.GetClock(),
+ &timing_,
+ &stats_callback_)),
+ rand_(0x34678213) {}
template <typename... T>
std::unique_ptr<FrameObjectFake> CreateFrame(uint16_t picture_id,
@@ -198,25 +195,22 @@
}
void ExtractFrame(int64_t max_wait_time = 0, bool keyframe_required = false) {
- crit_.Enter();
+ time_task_queue_.PostTask([this, max_wait_time, keyframe_required]() {
+ buffer_->NextFrame(
+ max_wait_time, keyframe_required, &time_task_queue_,
+ [this](std::unique_ptr<video_coding::EncodedFrame> frame,
+ video_coding::FrameBuffer::ReturnReason reason) {
+ if (reason != FrameBuffer::ReturnReason::kStopped) {
+ frames_.emplace_back(std::move(frame));
+ }
+ });
+ });
if (max_wait_time == 0) {
- std::unique_ptr<EncodedFrame> frame;
- FrameBuffer::ReturnReason res =
- buffer_->NextFrame(0, &frame, keyframe_required);
- if (res != FrameBuffer::ReturnReason::kStopped)
- frames_.emplace_back(std::move(frame));
- crit_.Leave();
- } else {
- max_wait_time_ = max_wait_time;
- trigger_extract_event_.Set();
- crit_.Leave();
- // Make sure |crit_| is aquired by |extract_thread_| before returning.
- crit_acquired_event_.Wait(rtc::Event::kForever);
+ time_controller_.AdvanceTime(TimeDelta::ms(0));
}
}
void CheckFrame(size_t index, int picture_id, int spatial_layer) {
- rtc::CritScope lock(&crit_);
ASSERT_LT(index, frames_.size());
ASSERT_TRUE(frames_[index]);
ASSERT_EQ(picture_id, frames_[index]->id.picture_id);
@@ -224,54 +218,27 @@
}
void CheckFrameSize(size_t index, size_t size) {
- rtc::CritScope lock(&crit_);
ASSERT_LT(index, frames_.size());
ASSERT_TRUE(frames_[index]);
ASSERT_EQ(frames_[index]->size(), size);
}
void CheckNoFrame(size_t index) {
- rtc::CritScope lock(&crit_);
ASSERT_LT(index, frames_.size());
ASSERT_FALSE(frames_[index]);
}
- static void ExtractLoop(void* obj) {
- TestFrameBuffer2* tfb = static_cast<TestFrameBuffer2*>(obj);
- while (true) {
- tfb->trigger_extract_event_.Wait(rtc::Event::kForever);
- {
- rtc::CritScope lock(&tfb->crit_);
- tfb->crit_acquired_event_.Set();
- if (tfb->tear_down_)
- return;
-
- std::unique_ptr<EncodedFrame> frame;
- FrameBuffer::ReturnReason res =
- tfb->buffer_->NextFrame(tfb->max_wait_time_, &frame, false);
- if (res != FrameBuffer::ReturnReason::kStopped)
- tfb->frames_.emplace_back(std::move(frame));
- }
- }
- }
-
uint32_t Rand() { return rand_.Rand<uint32_t>(); }
// The ProtectionMode tests depends on rtt-multiplier experiment.
test::ScopedFieldTrials trial_;
- SimulatedClock clock_;
+ webrtc::GlobalSimulatedTimeController time_controller_;
+ rtc::TaskQueue time_task_queue_;
VCMTimingFake timing_;
std::unique_ptr<FrameBuffer> buffer_;
std::vector<std::unique_ptr<EncodedFrame>> frames_;
Random rand_;
::testing::NiceMock<VCMReceiveStatisticsCallbackMock> stats_callback_;
-
- int64_t max_wait_time_;
- bool tear_down_;
- rtc::PlatformThread extract_thread_;
- rtc::Event trigger_extract_event_;
- rtc::Event crit_acquired_event_;
- rtc::CriticalSection crit_;
};
// From https://en.cppreference.com/w/cpp/language/static: "If ... a constexpr
@@ -283,16 +250,13 @@
constexpr size_t TestFrameBuffer2::kFrameSize;
#endif
-// Following tests are timing dependent. Either the timeouts have to
-// be increased by a large margin, which would slow down all trybots,
-// or we disable them for the very slow ones, like we do here.
-#if !defined(ADDRESS_SANITIZER) && !defined(MEMORY_SANITIZER)
TEST_F(TestFrameBuffer2, WaitForFrame) {
uint16_t pid = Rand();
uint32_t ts = Rand();
ExtractFrame(50);
InsertFrame(pid, 0, ts, false, true, kFrameSize);
+ time_controller_.AdvanceTime(TimeDelta::ms(50));
CheckFrame(0, pid, 0);
}
@@ -308,8 +272,9 @@
}
TEST_F(TestFrameBuffer2, ZeroPlayoutDelay) {
- VCMTiming timing(&clock_);
- buffer_.reset(new FrameBuffer(&clock_, &timing, &stats_callback_));
+ VCMTiming timing(time_controller_.GetClock());
+ buffer_.reset(
+ new FrameBuffer(time_controller_.GetClock(), &timing, &stats_callback_));
const PlayoutDelay kPlayoutDelayMs = {0, 0};
std::unique_ptr<FrameObjectFake> test_frame(new FrameObjectFake());
test_frame->id.picture_id = 0;
@@ -328,7 +293,7 @@
ExtractFrame(50);
InsertFrame(pid, 1, ts, true, true, kFrameSize);
InsertFrame(pid, 0, ts, false, false, kFrameSize);
- ExtractFrame();
+ time_controller_.AdvanceTime(TimeDelta::ms(0));
CheckFrame(0, pid, 0);
CheckFrame(1, pid, 1);
@@ -345,16 +310,15 @@
ExtractFrame(50);
InsertFrame(pid + i + 1, 0, ts + (i + 1) * kFps10, false, true, kFrameSize,
pid + i);
- clock_.AdvanceTimeMilliseconds(kFps10);
+ time_controller_.AdvanceTime(TimeDelta::ms(kFps10));
InsertFrame(pid + i, 0, ts + i * kFps10, false, true, kFrameSize,
pid + i - 1);
- clock_.AdvanceTimeMilliseconds(kFps10);
+ time_controller_.AdvanceTime(TimeDelta::ms(kFps10));
ExtractFrame();
CheckFrame(i, pid + i, 0);
CheckFrame(i + 1, pid + i + 1, 0);
}
}
-#endif // Timing dependent tests.
TEST_F(TestFrameBuffer2, ExtractFromEmptyBuffer) {
ExtractFrame();
@@ -388,7 +352,7 @@
InsertFrame(pid + i, 0, ts + i * kFps10, false, true, kFrameSize,
pid + i - 1);
ExtractFrame();
- clock_.AdvanceTimeMilliseconds(kFps10);
+ time_controller_.AdvanceTime(TimeDelta::ms(kFps10));
CheckFrame(i, pid + i, 0);
}
}
@@ -410,7 +374,7 @@
for (int i = 0; i < 10; ++i) {
ExtractFrame();
- clock_.AdvanceTimeMilliseconds(70);
+ time_controller_.AdvanceTime(TimeDelta::ms(70));
}
CheckFrame(0, pid, 0);
@@ -436,7 +400,7 @@
ExtractFrame();
// Jump forward in time, simulating the system being stalled for some reason.
- clock_.AdvanceTimeMilliseconds(3 * kFps10);
+ time_controller_.AdvanceTime(TimeDelta::ms(3) * kFps10);
// Extract one more frame, expect second and third frame to be dropped.
EXPECT_CALL(stats_callback_, OnDroppedFrames(2)).Times(1);
ExtractFrame();
@@ -719,7 +683,7 @@
InsertFrame(pid + 2, 0, ts + kFps10, false, false, kFrameSize, pid);
InsertFrame(pid + 2, 1, ts + kFps10, true, true, kFrameSize, pid + 1);
- clock_.AdvanceTimeMilliseconds(1000);
+ time_controller_.AdvanceTime(TimeDelta::ms(1000));
// Frame pid+1 is decodable but too late.
// In superframe pid+2 frame sid=0 is decodable, but frame sid=1 is not.
// Incorrect implementation might skip pid+1 frame and output undecodable