| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 707 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 718 EXPECT_EQ(0, send_bucket_->QueueInMs()); | 718 EXPECT_EQ(0, send_bucket_->QueueInMs()); |
| 719 } | 719 } |
| 720 | 720 |
| 721 TEST_F(PacedSenderTest, ProbingWithInitialFrame) { | 721 TEST_F(PacedSenderTest, ProbingWithInitialFrame) { |
| 722 const int kNumPackets = 11; | 722 const int kNumPackets = 11; |
| 723 const int kNumDeltas = kNumPackets - 1; | 723 const int kNumDeltas = kNumPackets - 1; |
| 724 const size_t kPacketSize = 1200; | 724 const size_t kPacketSize = 1200; |
| 725 const int kInitialBitrateKbps = 300; | 725 const int kInitialBitrateKbps = 300; |
| 726 uint32_t ssrc = 12346; | 726 uint32_t ssrc = 12346; |
| 727 uint16_t sequence_number = 1234; | 727 uint16_t sequence_number = 1234; |
| 728 const int expected_deltas[kNumDeltas] = { | 728 const int expected_deltas[kNumDeltas] = {10, 10, 10, 10, 10, 5, 5, 5, 5, 5}; |
| 729 10, 10, 10, 10, 10, 5, 5, 5, 5, 5}; | |
| 730 std::list<int> expected_deltas_list(expected_deltas, | 729 std::list<int> expected_deltas_list(expected_deltas, |
| 731 expected_deltas + kNumPackets - 1); | 730 expected_deltas + kNumDeltas); |
| 732 PacedSenderProbing callback(expected_deltas_list, &clock_); | 731 PacedSenderProbing callback(expected_deltas_list, &clock_); |
| 733 send_bucket_.reset( | 732 send_bucket_.reset( |
| 734 new PacedSender(&clock_, | 733 new PacedSender(&clock_, |
| 735 &callback, | 734 &callback, |
| 736 kInitialBitrateKbps, | 735 kInitialBitrateKbps, |
| 737 kPaceMultiplier * kInitialBitrateKbps, | 736 kPaceMultiplier * kInitialBitrateKbps, |
| 738 0)); | 737 0)); |
| 739 | 738 |
| 740 for (int i = 0; i < kNumPackets; ++i) { | 739 for (int i = 0; i < kNumPackets; ++i) { |
| 741 send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc, | 740 send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc, |
| (...skipping 12 matching lines...) Expand all Loading... |
| 754 | 753 |
| 755 TEST_F(PacedSenderTest, ProbingWithTooSmallInitialFrame) { | 754 TEST_F(PacedSenderTest, ProbingWithTooSmallInitialFrame) { |
| 756 const int kNumPackets = 11; | 755 const int kNumPackets = 11; |
| 757 const int kNumDeltas = kNumPackets - 1; | 756 const int kNumDeltas = kNumPackets - 1; |
| 758 const size_t kPacketSize = 1200; | 757 const size_t kPacketSize = 1200; |
| 759 const int kInitialBitrateKbps = 300; | 758 const int kInitialBitrateKbps = 300; |
| 760 uint32_t ssrc = 12346; | 759 uint32_t ssrc = 12346; |
| 761 uint16_t sequence_number = 1234; | 760 uint16_t sequence_number = 1234; |
| 762 const int expected_deltas[kNumDeltas] = {10, 10, 10, 10, 10, 5, 5, 5, 5, 5}; | 761 const int expected_deltas[kNumDeltas] = {10, 10, 10, 10, 10, 5, 5, 5, 5, 5}; |
| 763 std::list<int> expected_deltas_list(expected_deltas, | 762 std::list<int> expected_deltas_list(expected_deltas, |
| 764 expected_deltas + kNumPackets - 1); | 763 expected_deltas + kNumDeltas); |
| 765 PacedSenderProbing callback(expected_deltas_list, &clock_); | 764 PacedSenderProbing callback(expected_deltas_list, &clock_); |
| 766 send_bucket_.reset(new PacedSender(&clock_, &callback, kInitialBitrateKbps, | 765 send_bucket_.reset(new PacedSender(&clock_, &callback, kInitialBitrateKbps, |
| 767 kPaceMultiplier * kInitialBitrateKbps, 0)); | 766 kPaceMultiplier * kInitialBitrateKbps, 0)); |
| 768 | 767 |
| 769 for (int i = 0; i < kNumPackets - 5; ++i) { | 768 for (int i = 0; i < kNumPackets - 5; ++i) { |
| 770 send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc, | 769 send_bucket_->InsertPacket(PacedSender::kNormalPriority, ssrc, |
| 771 sequence_number++, clock_.TimeInMilliseconds(), | 770 sequence_number++, clock_.TimeInMilliseconds(), |
| 772 kPacketSize, false); | 771 kPacketSize, false); |
| 773 } | 772 } |
| 774 while (callback.packets_sent() < kNumPackets) { | 773 while (callback.packets_sent() < kNumPackets) { |
| (...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 900 for (int i = 0; i < 3; ++i) { | 899 for (int i = 0; i < 3; ++i) { |
| 901 clock_.AdvanceTimeMilliseconds(30); // Max delta. | 900 clock_.AdvanceTimeMilliseconds(30); // Max delta. |
| 902 send_bucket_->Process(); | 901 send_bucket_->Process(); |
| 903 } | 902 } |
| 904 | 903 |
| 905 EXPECT_EQ(0, send_bucket_->AverageQueueTimeMs()); | 904 EXPECT_EQ(0, send_bucket_->AverageQueueTimeMs()); |
| 906 } | 905 } |
| 907 | 906 |
| 908 } // namespace test | 907 } // namespace test |
| 909 } // namespace webrtc | 908 } // namespace webrtc |
| OLD | NEW |