| 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 611 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 622 false); | 622 false); |
| 623 send_bucket_->InsertPacket(PacedSender::kHighPriority, ssrc_high_priority, | 623 send_bucket_->InsertPacket(PacedSender::kHighPriority, ssrc_high_priority, |
| 624 sequence_number++, second_capture_time_ms, 250, | 624 sequence_number++, second_capture_time_ms, 250, |
| 625 false); | 625 false); |
| 626 } | 626 } |
| 627 | 627 |
| 628 // Expect everything to be queued. | 628 // Expect everything to be queued. |
| 629 EXPECT_EQ(second_capture_time_ms - capture_time_ms, | 629 EXPECT_EQ(second_capture_time_ms - capture_time_ms, |
| 630 send_bucket_->QueueInMs()); | 630 send_bucket_->QueueInMs()); |
| 631 | 631 |
| 632 // Expect only high priority packets to come out while paused. | |
| 633 EXPECT_CALL(callback_, TimeToSendPadding(_, _)).Times(0); | |
| 634 EXPECT_CALL(callback_, TimeToSendPacket(_, _, _, _, _)).Times(0); | |
| 635 EXPECT_CALL(callback_, | |
| 636 TimeToSendPacket(ssrc_high_priority, _, capture_time_ms, _, _)) | |
| 637 .Times(packets_to_send_per_interval) | |
| 638 .WillRepeatedly(Return(true)); | |
| 639 EXPECT_CALL(callback_, TimeToSendPacket(ssrc_high_priority, _, | |
| 640 second_capture_time_ms, _, _)) | |
| 641 .Times(packets_to_send_per_interval) | |
| 642 .WillRepeatedly(Return(true)); | |
| 643 | |
| 644 for (int i = 0; i < 10; ++i) { | 632 for (int i = 0; i < 10; ++i) { |
| 645 clock_.AdvanceTimeMilliseconds(5); | 633 clock_.AdvanceTimeMilliseconds(5); |
| 646 EXPECT_EQ(0, send_bucket_->TimeUntilNextProcess()); | 634 EXPECT_EQ(0, send_bucket_->TimeUntilNextProcess()); |
| 647 send_bucket_->Process(); | 635 send_bucket_->Process(); |
| 648 } | 636 } |
| 649 | 637 |
| 650 // Expect normal prio packets to come out first (in capture order) | 638 // Expect high prio packets to come out first followed by normal |
| 651 // followed by all low prio packets (in capture order). | 639 // prio packets and low prio packets (all in capture order). |
| 652 { | 640 { |
| 653 ::testing::InSequence sequence; | 641 ::testing::InSequence sequence; |
| 642 EXPECT_CALL(callback_, |
| 643 TimeToSendPacket(ssrc_high_priority, _, capture_time_ms, _, _)) |
| 644 .Times(packets_to_send_per_interval) |
| 645 .WillRepeatedly(Return(true)); |
| 646 EXPECT_CALL(callback_, TimeToSendPacket(ssrc_high_priority, _, |
| 647 second_capture_time_ms, _, _)) |
| 648 .Times(packets_to_send_per_interval) |
| 649 .WillRepeatedly(Return(true)); |
| 650 |
| 654 for (size_t i = 0; i < packets_to_send_per_interval; ++i) { | 651 for (size_t i = 0; i < packets_to_send_per_interval; ++i) { |
| 655 EXPECT_CALL(callback_, TimeToSendPacket(ssrc, _, capture_time_ms, _, _)) | 652 EXPECT_CALL(callback_, TimeToSendPacket(ssrc, _, capture_time_ms, _, _)) |
| 656 .Times(1) | 653 .Times(1) |
| 657 .WillRepeatedly(Return(true)); | 654 .WillRepeatedly(Return(true)); |
| 658 } | 655 } |
| 659 for (size_t i = 0; i < packets_to_send_per_interval; ++i) { | 656 for (size_t i = 0; i < packets_to_send_per_interval; ++i) { |
| 660 EXPECT_CALL(callback_, | 657 EXPECT_CALL(callback_, |
| 661 TimeToSendPacket(ssrc, _, second_capture_time_ms, _, _)) | 658 TimeToSendPacket(ssrc, _, second_capture_time_ms, _, _)) |
| 662 .Times(1) | 659 .Times(1) |
| 663 .WillRepeatedly(Return(true)); | 660 .WillRepeatedly(Return(true)); |
| (...skipping 369 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1033 | 1030 |
| 1034 // No more probing packets. | 1031 // No more probing packets. |
| 1035 EXPECT_CALL(callback_, TimeToSendPadding(_, PacketInfo::kNotAProbe)) | 1032 EXPECT_CALL(callback_, TimeToSendPadding(_, PacketInfo::kNotAProbe)) |
| 1036 .Times(1) | 1033 .Times(1) |
| 1037 .WillRepeatedly(Return(500)); | 1034 .WillRepeatedly(Return(500)); |
| 1038 send_bucket_->Process(); | 1035 send_bucket_->Process(); |
| 1039 } | 1036 } |
| 1040 | 1037 |
| 1041 } // namespace test | 1038 } // namespace test |
| 1042 } // namespace webrtc | 1039 } // namespace webrtc |
| OLD | NEW |