| 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 810 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 821 send_bucket_->Process(); | 821 send_bucket_->Process(); |
| 822 } | 822 } |
| 823 int packets_sent = packet_sender.packets_sent(); | 823 int packets_sent = packet_sender.packets_sent(); |
| 824 // Validate first cluster bitrate. Note that we have to account for number | 824 // Validate first cluster bitrate. Note that we have to account for number |
| 825 // of intervals and hence (packets_sent - 1) on the first cluster. | 825 // of intervals and hence (packets_sent - 1) on the first cluster. |
| 826 EXPECT_NEAR((packets_sent - 1) * kPacketSize * 8000 / | 826 EXPECT_NEAR((packets_sent - 1) * kPacketSize * 8000 / |
| 827 (clock_.TimeInMilliseconds() - start), | 827 (clock_.TimeInMilliseconds() - start), |
| 828 kFirstClusterBps, kBitrateProbingError); | 828 kFirstClusterBps, kBitrateProbingError); |
| 829 EXPECT_EQ(0, packet_sender.padding_sent()); | 829 EXPECT_EQ(0, packet_sender.padding_sent()); |
| 830 | 830 |
| 831 clock_.AdvanceTimeMilliseconds(send_bucket_->TimeUntilNextProcess()); | |
| 832 start = clock_.TimeInMilliseconds(); | 831 start = clock_.TimeInMilliseconds(); |
| 833 while (packet_sender.packets_sent() < 10) { | 832 while (packet_sender.packets_sent() < 10) { |
| 834 int time_until_process = send_bucket_->TimeUntilNextProcess(); | 833 int time_until_process = send_bucket_->TimeUntilNextProcess(); |
| 835 clock_.AdvanceTimeMilliseconds(time_until_process); | 834 clock_.AdvanceTimeMilliseconds(time_until_process); |
| 836 send_bucket_->Process(); | 835 send_bucket_->Process(); |
| 837 } | 836 } |
| 838 packets_sent = packet_sender.packets_sent() - packets_sent; | 837 packets_sent = packet_sender.packets_sent() - packets_sent; |
| 839 // Validate second cluster bitrate. | 838 // Validate second cluster bitrate. |
| 840 EXPECT_NEAR((packets_sent - 1) * kPacketSize * 8000 / | 839 EXPECT_NEAR( |
| 841 (clock_.TimeInMilliseconds() - start), | 840 packets_sent * kPacketSize * 8000 / (clock_.TimeInMilliseconds() - start), |
| 842 kSecondClusterBps, kBitrateProbingError); | 841 kSecondClusterBps, kBitrateProbingError); |
| 843 } | 842 } |
| 844 | 843 |
| 845 TEST_F(PacedSenderTest, ProbingWithPaddingSupport) { | 844 TEST_F(PacedSenderTest, ProbingWithPaddingSupport) { |
| 846 const size_t kPacketSize = 1200; | 845 const size_t kPacketSize = 1200; |
| 847 const int kInitialBitrateBps = 300000; | 846 const int kInitialBitrateBps = 300000; |
| 848 uint32_t ssrc = 12346; | 847 uint32_t ssrc = 12346; |
| 849 uint16_t sequence_number = 1234; | 848 uint16_t sequence_number = 1234; |
| 850 | 849 |
| 851 PacedSenderProbing packet_sender; | 850 PacedSenderProbing packet_sender; |
| 852 send_bucket_.reset(new PacedSender(&clock_, &packet_sender)); | 851 send_bucket_.reset(new PacedSender(&clock_, &packet_sender)); |
| (...skipping 180 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1033 | 1032 |
| 1034 // No more probing packets. | 1033 // No more probing packets. |
| 1035 EXPECT_CALL(callback_, TimeToSendPadding(_, PacketInfo::kNotAProbe)) | 1034 EXPECT_CALL(callback_, TimeToSendPadding(_, PacketInfo::kNotAProbe)) |
| 1036 .Times(1) | 1035 .Times(1) |
| 1037 .WillRepeatedly(Return(500)); | 1036 .WillRepeatedly(Return(500)); |
| 1038 send_bucket_->Process(); | 1037 send_bucket_->Process(); |
| 1039 } | 1038 } |
| 1040 | 1039 |
| 1041 } // namespace test | 1040 } // namespace test |
| 1042 } // namespace webrtc | 1041 } // namespace webrtc |
| OLD | NEW |