Chromium Code Reviews| Index: webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
| diff --git a/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc b/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
| index 6bc122201adfd64881afffed7b28dae40fa29990..3211dfc81e34d9210814ee557ec3f1905b87b59e 100644 |
| --- a/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
| +++ b/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
| @@ -125,8 +125,6 @@ class RtpSenderTest : public ::testing::Test { |
| payload_(kPayload), |
| transport_(), |
| kMarkerBit(true) { |
| - EXPECT_CALL(mock_paced_sender_, InsertPacket(_, _, _, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| } |
| void SetUp() override { SetUpRtpSender(true); } |
| @@ -628,7 +626,7 @@ TEST_F(RtpSenderTestWithoutPacer, BuildRTPPacketWithHeaderExtensions) { |
| TEST_F(RtpSenderTest, TrafficSmoothingWithExtensions) { |
| EXPECT_CALL(mock_paced_sender_, InsertPacket(RtpPacketSender::kNormalPriority, |
| _, kSeqNum, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| + .WillOnce(testing::Return()); |
|
stefan-webrtc
2016/01/14 15:03:42
I _think_ you don't need this if the method is voi
terelius
2016/01/14 15:41:01
You're right. Done.
|
| rtp_sender_->SetStorePacketsStatus(true, 10); |
| EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
| @@ -680,7 +678,7 @@ TEST_F(RtpSenderTest, TrafficSmoothingWithExtensions) { |
| TEST_F(RtpSenderTest, TrafficSmoothingRetransmits) { |
| EXPECT_CALL(mock_paced_sender_, InsertPacket(RtpPacketSender::kNormalPriority, |
| _, kSeqNum, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| + .WillOnce(testing::Return()); |
| rtp_sender_->SetStorePacketsStatus(true, 10); |
| EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
| @@ -703,9 +701,9 @@ TEST_F(RtpSenderTest, TrafficSmoothingRetransmits) { |
| EXPECT_EQ(0, transport_.packets_sent_); |
| - EXPECT_CALL(mock_paced_sender_, |
| - InsertPacket(RtpPacketSender::kHighPriority, _, kSeqNum, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| + EXPECT_CALL(mock_paced_sender_, InsertPacket(RtpPacketSender::kNormalPriority, |
| + _, kSeqNum, _, _, _)) |
| + .WillOnce(testing::Return()); |
| const int kStoredTimeInMs = 100; |
| fake_clock_.AdvanceTimeMilliseconds(kStoredTimeInMs); |
| @@ -741,9 +739,9 @@ TEST_F(RtpSenderTest, TrafficSmoothingRetransmits) { |
| // 1 more regular packet. |
| TEST_F(RtpSenderTest, SendPadding) { |
| // Make all (non-padding) packets go to send queue. |
| - EXPECT_CALL(mock_paced_sender_, |
| - InsertPacket(RtpPacketSender::kNormalPriority, _, _, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| + EXPECT_CALL(mock_paced_sender_, InsertPacket(RtpPacketSender::kNormalPriority, |
| + _, kSeqNum, _, _, _)) |
| + .WillOnce(testing::Return()); |
| uint16_t seq_num = kSeqNum; |
| uint32_t timestamp = kTimestamp; |
| @@ -832,6 +830,10 @@ TEST_F(RtpSenderTest, SendPadding) { |
| ASSERT_NE(-1, rtp_length_int); |
| rtp_length = static_cast<size_t>(rtp_length_int); |
| + EXPECT_CALL(mock_paced_sender_, |
| + InsertPacket(RtpPacketSender::kNormalPriority, _, _, _, _, _)) |
| + .WillOnce(testing::Return()); |
| + |
| // Packet should be stored in a send bucket. |
| EXPECT_EQ(0, rtp_sender_->SendToNetwork(packet_, 0, rtp_length, |
| capture_time_ms, kAllowRetransmission, |
| @@ -862,10 +864,6 @@ TEST_F(RtpSenderTest, SendRedundantPayloads) { |
| nullptr, nullptr, nullptr)); |
| rtp_sender_->SetSequenceNumber(kSeqNum); |
| rtp_sender_->SetRtxPayloadType(kRtxPayload, kPayload); |
| - // Make all packets go through the pacer. |
| - EXPECT_CALL(mock_paced_sender_, |
| - InsertPacket(RtpPacketSender::kNormalPriority, _, _, _, _, _)) |
| - .WillRepeatedly(testing::Return()); |
| uint16_t seq_num = kSeqNum; |
| rtp_sender_->SetStorePacketsStatus(true, 10); |
| @@ -891,6 +889,11 @@ TEST_F(RtpSenderTest, SendRedundantPayloads) { |
| const size_t kNumPayloadSizes = 10; |
| const size_t kPayloadSizes[kNumPayloadSizes] = {500, 550, 600, 650, 700, |
| 750, 800, 850, 900, 950}; |
| + // Expect all packets go through the pacer. |
| + EXPECT_CALL(mock_paced_sender_, |
| + InsertPacket(RtpPacketSender::kNormalPriority, _, _, _, _, _)) |
| + .Times(kNumPayloadSizes) |
| + .WillRepeatedly(testing::Return()); |
| // Send 10 packets of increasing size. |
| for (size_t i = 0; i < kNumPayloadSizes; ++i) { |
| int64_t capture_time_ms = fake_clock_.TimeInMilliseconds(); |
| @@ -1003,6 +1006,10 @@ TEST_F(RtpSenderTest, FrameCountCallbacks) { |
| rtp_sender_->SetStorePacketsStatus(true, 1); |
| uint32_t ssrc = rtp_sender_->SSRC(); |
| + EXPECT_CALL(mock_paced_sender_, InsertPacket(_, _, _, _, _, _)) |
| + .Times(::testing::AtLeast(2)) |
| + .WillRepeatedly(testing::Return()); |
| + |
| ASSERT_EQ( |
| 0, rtp_sender_->SendOutgoingData(kVideoFrameKey, payload_type, 1234, 4321, |
| payload, sizeof(payload), nullptr)); |