| 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 183d33901323d1bb2cd3a6a157d912fb64878f21..fc80a9881349af92e35c06ed51941a35e404a391 100644
|
| --- a/webrtc/modules/pacing/paced_sender_unittest.cc
|
| +++ b/webrtc/modules/pacing/paced_sender_unittest.cc
|
| @@ -21,9 +21,7 @@ using testing::Return;
|
|
|
| namespace {
|
| constexpr unsigned kFirstClusterBps = 900000;
|
| -constexpr int kFirstClusterCount = 6;
|
| constexpr unsigned kSecondClusterBps = 1800000;
|
| -constexpr int kSecondClusterCount = 5;
|
|
|
| // The error stems from truncating the time interval of probe packets to integer
|
| // values. This results in probing slightly higher than the target bitrate.
|
| @@ -105,8 +103,8 @@ class PacedSenderTest : public ::testing::Test {
|
| srand(0);
|
| // Need to initialize PacedSender after we initialize clock.
|
| send_bucket_.reset(new PacedSender(&clock_, &callback_));
|
| - send_bucket_->CreateProbeCluster(kFirstClusterBps, kFirstClusterCount);
|
| - send_bucket_->CreateProbeCluster(kSecondClusterBps, kSecondClusterCount);
|
| + send_bucket_->CreateProbeCluster(kFirstClusterBps);
|
| + send_bucket_->CreateProbeCluster(kSecondClusterBps);
|
| // Default to bitrate probing disabled for testing purposes. Probing tests
|
| // have to enable probing, either by creating a new PacedSender instance or
|
| // by calling SetProbingEnabled(true).
|
| @@ -806,18 +804,18 @@ TEST_F(PacedSenderTest, ProbingWithInsertedPackets) {
|
|
|
| PacedSenderProbing packet_sender;
|
| send_bucket_.reset(new PacedSender(&clock_, &packet_sender));
|
| - send_bucket_->CreateProbeCluster(kFirstClusterBps, kFirstClusterCount);
|
| - send_bucket_->CreateProbeCluster(kSecondClusterBps, kSecondClusterCount);
|
| + send_bucket_->CreateProbeCluster(kFirstClusterBps);
|
| + send_bucket_->CreateProbeCluster(kSecondClusterBps);
|
| send_bucket_->SetEstimatedBitrate(kInitialBitrateBps);
|
|
|
| - for (int i = 0; i < kFirstClusterCount + kSecondClusterCount; ++i) {
|
| + for (int i = 0; i < 10; ++i) {
|
| send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc,
|
| sequence_number++, clock_.TimeInMilliseconds(),
|
| kPacketSize, false);
|
| }
|
|
|
| int64_t start = clock_.TimeInMilliseconds();
|
| - while (packet_sender.packets_sent() < kFirstClusterCount) {
|
| + while (packet_sender.packets_sent() < 5) {
|
| int time_until_process = send_bucket_->TimeUntilNextProcess();
|
| clock_.AdvanceTimeMilliseconds(time_until_process);
|
| send_bucket_->Process();
|
| @@ -831,8 +829,7 @@ TEST_F(PacedSenderTest, ProbingWithInsertedPackets) {
|
| EXPECT_EQ(0, packet_sender.padding_sent());
|
|
|
| start = clock_.TimeInMilliseconds();
|
| - while (packet_sender.packets_sent() <
|
| - kFirstClusterCount + kSecondClusterCount) {
|
| + while (packet_sender.packets_sent() < 10) {
|
| int time_until_process = send_bucket_->TimeUntilNextProcess();
|
| clock_.AdvanceTimeMilliseconds(time_until_process);
|
| send_bucket_->Process();
|
| @@ -852,10 +849,10 @@ TEST_F(PacedSenderTest, ProbingWithPaddingSupport) {
|
|
|
| PacedSenderProbing packet_sender;
|
| send_bucket_.reset(new PacedSender(&clock_, &packet_sender));
|
| - send_bucket_->CreateProbeCluster(kFirstClusterBps, kFirstClusterCount);
|
| + send_bucket_->CreateProbeCluster(kFirstClusterBps);
|
| send_bucket_->SetEstimatedBitrate(kInitialBitrateBps);
|
|
|
| - for (int i = 0; i < kFirstClusterCount - 2; ++i) {
|
| + for (int i = 0; i < 3; ++i) {
|
| send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc,
|
| sequence_number++, clock_.TimeInMilliseconds(),
|
| kPacketSize, false);
|
| @@ -863,7 +860,7 @@ TEST_F(PacedSenderTest, ProbingWithPaddingSupport) {
|
|
|
| int64_t start = clock_.TimeInMilliseconds();
|
| int process_count = 0;
|
| - while (process_count < kFirstClusterCount) {
|
| + while (process_count < 5) {
|
| int time_until_process = send_bucket_->TimeUntilNextProcess();
|
| clock_.AdvanceTimeMilliseconds(time_until_process);
|
| send_bucket_->Process();
|
| @@ -1009,7 +1006,7 @@ TEST_F(PacedSenderTest, ProbeClusterId) {
|
|
|
| send_bucket_->SetSendBitrateLimits(kTargetBitrateBps, kTargetBitrateBps);
|
| send_bucket_->SetProbingEnabled(true);
|
| - for (int i = 0; i < 11; ++i) {
|
| + for (int i = 0; i < 10; ++i) {
|
| send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc,
|
| sequence_number + i, clock_.TimeInMilliseconds(),
|
| kPacketSize, false);
|
| @@ -1017,9 +1014,9 @@ TEST_F(PacedSenderTest, ProbeClusterId) {
|
|
|
| // First probing cluster.
|
| EXPECT_CALL(callback_, TimeToSendPacket(_, _, _, _, 0))
|
| - .Times(6)
|
| + .Times(5)
|
| .WillRepeatedly(Return(true));
|
| - for (int i = 0; i < 6; ++i) {
|
| + for (int i = 0; i < 5; ++i) {
|
| clock_.AdvanceTimeMilliseconds(20);
|
| send_bucket_->Process();
|
| }
|
|
|