diff options
Diffstat (limited to 'chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc')
-rw-r--r-- | chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc | 46 |
1 files changed, 12 insertions, 34 deletions
diff --git a/chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc b/chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc index f8dcdfc6985..9763c80070d 100644 --- a/chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc +++ b/chromium/third_party/webrtc/modules/pacing/paced_sender_unittest.cc @@ -59,9 +59,8 @@ class PacedSenderTest : public ::testing::Test { srand(0); TickTime::UseFakeClock(123456); // Need to initialize PacedSender after we initialize clock. - send_bucket_.reset(new PacedSender(&callback_, kTargetBitrate, - kPaceMultiplier)); - send_bucket_->SetStatus(true); + send_bucket_.reset( + new PacedSender(&callback_, kPaceMultiplier * kTargetBitrate, 0)); } void SendAndExpectPacket(PacedSender::Priority priority, @@ -209,7 +208,7 @@ TEST_F(PacedSenderTest, Padding) { uint32_t ssrc = 12345; uint16_t sequence_number = 1234; - send_bucket_->UpdateBitrate(kTargetBitrate, kTargetBitrate, kTargetBitrate); + send_bucket_->UpdateBitrate(kPaceMultiplier * kTargetBitrate, kTargetBitrate); // Due to the multiplicative factor we can send 3 packets not 2 packets. SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, TickTime::MillisecondTimestamp(), 250, false); @@ -235,7 +234,7 @@ TEST_F(PacedSenderTest, Padding) { TEST_F(PacedSenderTest, NoPaddingWhenDisabled) { send_bucket_->SetStatus(false); - send_bucket_->UpdateBitrate(kTargetBitrate, kTargetBitrate, kTargetBitrate); + send_bucket_->UpdateBitrate(kPaceMultiplier * kTargetBitrate, kTargetBitrate); // No padding is expected since the pacer is disabled. EXPECT_CALL(callback_, TimeToSendPadding(_)).Times(0); EXPECT_EQ(5, send_bucket_->TimeUntilNextProcess()); @@ -255,7 +254,7 @@ TEST_F(PacedSenderTest, VerifyPaddingUpToBitrate) { int64_t capture_time_ms = 56789; const int kTimeStep = 5; const int64_t kBitrateWindow = 100; - send_bucket_->UpdateBitrate(kTargetBitrate, kTargetBitrate, kTargetBitrate); + send_bucket_->UpdateBitrate(kPaceMultiplier * kTargetBitrate, kTargetBitrate); int64_t start_time = TickTime::MillisecondTimestamp(); while (TickTime::MillisecondTimestamp() - start_time < kBitrateWindow) { SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, @@ -267,27 +266,6 @@ TEST_F(PacedSenderTest, VerifyPaddingUpToBitrate) { } } -TEST_F(PacedSenderTest, VerifyMaxPaddingBitrate) { - uint32_t ssrc = 12345; - uint16_t sequence_number = 1234; - int64_t capture_time_ms = 56789; - const int kTimeStep = 5; - const int64_t kBitrateWindow = 100; - const int kTargetBitrate = 1500; - const int kMaxPaddingBitrate = 800; - send_bucket_->UpdateBitrate(kTargetBitrate, kMaxPaddingBitrate, - kTargetBitrate); - int64_t start_time = TickTime::MillisecondTimestamp(); - while (TickTime::MillisecondTimestamp() - start_time < kBitrateWindow) { - SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, - capture_time_ms, 250, false); - TickTime::AdvanceFakeClock(kTimeStep); - EXPECT_CALL(callback_, TimeToSendPadding(500)).Times(1). - WillOnce(Return(250)); - send_bucket_->Process(); - } -} - TEST_F(PacedSenderTest, VerifyAverageBitrateVaryingMediaPayload) { uint32_t ssrc = 12345; uint16_t sequence_number = 1234; @@ -295,10 +273,9 @@ TEST_F(PacedSenderTest, VerifyAverageBitrateVaryingMediaPayload) { const int kTimeStep = 5; const int64_t kBitrateWindow = 10000; PacedSenderPadding callback; - send_bucket_.reset(new PacedSender(&callback, kTargetBitrate, - kPaceMultiplier)); - send_bucket_->SetStatus(true); - send_bucket_->UpdateBitrate(kTargetBitrate, kTargetBitrate, kTargetBitrate); + send_bucket_.reset( + new PacedSender(&callback, kPaceMultiplier * kTargetBitrate, 0)); + send_bucket_->UpdateBitrate(kPaceMultiplier * kTargetBitrate, kTargetBitrate); int64_t start_time = TickTime::MillisecondTimestamp(); int media_bytes = 0; while (TickTime::MillisecondTimestamp() - start_time < kBitrateWindow) { @@ -421,7 +398,8 @@ TEST_F(PacedSenderTest, Pause) { EXPECT_EQ(0, send_bucket_->TimeUntilNextProcess()); EXPECT_EQ(0, send_bucket_->Process()); - EXPECT_CALL(callback_, TimeToSendPacket(_, _, second_capture_time_ms, false)) + EXPECT_CALL( + callback_, TimeToSendPacket(_, _, second_capture_time_ms, false)) .Times(1) .WillRepeatedly(Return(true)); EXPECT_EQ(5, send_bucket_->TimeUntilNextProcess()); @@ -496,7 +474,7 @@ TEST_F(PacedSenderTest, MaxQueueLength) { uint16_t sequence_number = 1234; EXPECT_EQ(0, send_bucket_->QueueInMs()); - send_bucket_->UpdateBitrate(30, 0, 0); + send_bucket_->UpdateBitrate(kPaceMultiplier * 30, 0); for (int i = 0; i < 30; ++i) { SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, @@ -525,7 +503,7 @@ TEST_F(PacedSenderTest, QueueTimeGrowsOverTime) { uint16_t sequence_number = 1234; EXPECT_EQ(0, send_bucket_->QueueInMs()); - send_bucket_->UpdateBitrate(30, 0, 0); + send_bucket_->UpdateBitrate(kPaceMultiplier * 30, 0); SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number, |