Index: webrtc/modules/pacing/paced_sender_unittest.cc |
diff --git a/webrtc/modules/pacing/paced_sender_unittest.cc b/webrtc/modules/pacing/paced_sender_unittest.cc |
index 063ec1e1947f566578850b24646b9e79c285a329..51394c72d198397c93a2c92355c380478a6ced28 100644 |
--- a/webrtc/modules/pacing/paced_sender_unittest.cc |
+++ b/webrtc/modules/pacing/paced_sender_unittest.cc |
@@ -322,7 +322,7 @@ TEST_F(PacedSenderTest, Padding) { |
uint16_t sequence_number = 1234; |
send_bucket_->SetEstimatedBitrate(kTargetBitrateBps); |
- send_bucket_->SetAllocatedSendBitrate(kTargetBitrateBps, kTargetBitrateBps); |
+ send_bucket_->SetSendBitrateLimits(kTargetBitrateBps, kTargetBitrateBps); |
// Due to the multiplicative factor we can send 5 packets during a send |
// interval. (network capacity * multiplier / (8 bits per byte * |
@@ -357,6 +357,29 @@ TEST_F(PacedSenderTest, Padding) { |
send_bucket_->Process(); |
} |
+TEST_F(PacedSenderTest, NoPaddingBeforeNormalPacket) { |
+ send_bucket_->SetEstimatedBitrate(kTargetBitrateBps); |
+ send_bucket_->SetSendBitrateLimits(kTargetBitrateBps, kTargetBitrateBps); |
+ |
+ EXPECT_CALL(callback_, TimeToSendPadding(_, _)).Times(0); |
+ send_bucket_->Process(); |
+ clock_.AdvanceTimeMilliseconds(send_bucket_->TimeUntilNextProcess()); |
+ |
+ send_bucket_->Process(); |
+ clock_.AdvanceTimeMilliseconds(send_bucket_->TimeUntilNextProcess()); |
+ |
+ uint32_t ssrc = 12345; |
+ uint16_t sequence_number = 1234; |
+ int64_t capture_time_ms = 56789; |
+ |
+ SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, |
+ capture_time_ms, 250, false); |
+ EXPECT_CALL(callback_, TimeToSendPadding(250, _)) |
+ .Times(1) |
+ .WillOnce(Return(250)); |
+ send_bucket_->Process(); |
+} |
+ |
TEST_F(PacedSenderTest, VerifyPaddingUpToBitrate) { |
uint32_t ssrc = 12345; |
uint16_t sequence_number = 1234; |
@@ -364,7 +387,7 @@ TEST_F(PacedSenderTest, VerifyPaddingUpToBitrate) { |
const int kTimeStep = 5; |
const int64_t kBitrateWindow = 100; |
send_bucket_->SetEstimatedBitrate(kTargetBitrateBps); |
- send_bucket_->SetAllocatedSendBitrate(kTargetBitrateBps, kTargetBitrateBps); |
+ send_bucket_->SetSendBitrateLimits(kTargetBitrateBps, kTargetBitrateBps); |
int64_t start_time = clock_.TimeInMilliseconds(); |
while (clock_.TimeInMilliseconds() - start_time < kBitrateWindow) { |
@@ -392,7 +415,10 @@ TEST_F(PacedSenderTest, VerifyAverageBitrateVaryingMediaPayload) { |
send_bucket_.reset(new PacedSender(&clock_, &callback)); |
send_bucket_->SetProbingEnabled(false); |
send_bucket_->SetEstimatedBitrate(kTargetBitrateBps); |
- send_bucket_->SetAllocatedSendBitrate(kTargetBitrateBps, kTargetBitrateBps); |
+ |
+ send_bucket_->SetSendBitrateLimits( |
+ 0 /*allocated_bitrate_bps*/, |
+ kTargetBitrateBps * 2 /* max_padding_bitrate_bps */); |
int64_t start_time = clock_.TimeInMilliseconds(); |
size_t media_bytes = 0; |
@@ -806,7 +832,7 @@ TEST_F(PacedSenderTest, PaddingOveruse) { |
send_bucket_->Process(); |
send_bucket_->SetEstimatedBitrate(60000); |
- send_bucket_->SetAllocatedSendBitrate(60000, 0); |
+ send_bucket_->SetSendBitrateLimits(60000, 0); |
SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, |
clock_.TimeInMilliseconds(), kPacketSize, false); |
@@ -815,7 +841,7 @@ TEST_F(PacedSenderTest, PaddingOveruse) { |
// Add 30kbit padding. When increasing budget, media budget will increase from |
// negative (overuse) while padding budget will increase from 0. |
clock_.AdvanceTimeMilliseconds(5); |
- send_bucket_->SetAllocatedSendBitrate(60000, 30000); |
+ send_bucket_->SetSendBitrateLimits(60000, 30000); |
SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, |
clock_.TimeInMilliseconds(), kPacketSize, false); |
@@ -875,7 +901,7 @@ TEST_F(PacedSenderTest, ProbeClusterId) { |
uint16_t sequence_number = 1234; |
const size_t kPacketSize = 1200; |
- send_bucket_->SetAllocatedSendBitrate(kTargetBitrateBps, kTargetBitrateBps); |
+ send_bucket_->SetSendBitrateLimits(kTargetBitrateBps, kTargetBitrateBps); |
send_bucket_->SetProbingEnabled(true); |
for (int i = 0; i < 11; ++i) { |
send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc, |