| Index: webrtc/test/fake_network_pipe_unittest.cc
|
| diff --git a/webrtc/test/fake_network_pipe_unittest.cc b/webrtc/test/fake_network_pipe_unittest.cc
|
| index aa273995945be93715ce66427e3e6a0e2aea9dc2..c19b0014bb9f6cac21ce2a9d2bb1aa11bebb69e2 100644
|
| --- a/webrtc/test/fake_network_pipe_unittest.cc
|
| +++ b/webrtc/test/fake_network_pipe_unittest.cc
|
| @@ -96,7 +96,7 @@ TEST_F(FakeNetworkPipeTest, CapacityTest) {
|
| config.queue_length_packets = 20;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| // Add 10 packets of 1000 bytes, = 80 kb, and verify it takes one second to
|
| @@ -110,22 +110,22 @@ TEST_F(FakeNetworkPipeTest, CapacityTest) {
|
| kPacketSize);
|
|
|
| // Time haven't increased yet, so we souldn't get any packets.
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(0);
|
| pipe->Process();
|
|
|
| // Advance enough time to release one packet.
|
| fake_clock_.AdvanceTimeMilliseconds(kPacketTimeMs);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(1);
|
| pipe->Process();
|
|
|
| // Release all but one packet
|
| fake_clock_.AdvanceTimeMilliseconds(9 * kPacketTimeMs - 1);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(8);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(8);
|
| pipe->Process();
|
|
|
| // And the last one.
|
| fake_clock_.AdvanceTimeMilliseconds(1);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| @@ -136,7 +136,7 @@ TEST_F(FakeNetworkPipeTest, ExtraDelayTest) {
|
| config.queue_delay_ms = 100;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::AUDIO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| const int kNumPackets = 2;
|
| @@ -149,17 +149,17 @@ TEST_F(FakeNetworkPipeTest, ExtraDelayTest) {
|
|
|
| // Increase more than kPacketTimeMs, but not more than the extra delay.
|
| fake_clock_.AdvanceTimeMilliseconds(kPacketTimeMs);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(0);
|
| pipe->Process();
|
|
|
| // Advance the network delay to get the first packet.
|
| fake_clock_.AdvanceTimeMilliseconds(config.queue_delay_ms);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(1);
|
| pipe->Process();
|
|
|
| // Advance one more kPacketTimeMs to get the last packet.
|
| fake_clock_.AdvanceTimeMilliseconds(kPacketTimeMs);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| @@ -170,7 +170,7 @@ TEST_F(FakeNetworkPipeTest, QueueLengthTest) {
|
| config.queue_length_packets = 2;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| const int kPacketSize = 1000;
|
| @@ -183,7 +183,7 @@ TEST_F(FakeNetworkPipeTest, QueueLengthTest) {
|
| // Increase time enough to deliver all three packets, verify only two are
|
| // delivered.
|
| fake_clock_.AdvanceTimeMilliseconds(3 * kPacketTimeMs);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(2);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(2);
|
| pipe->Process();
|
| }
|
|
|
| @@ -194,7 +194,7 @@ TEST_F(FakeNetworkPipeTest, StatisticsTest) {
|
| config.queue_delay_ms = 20;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| const int kPacketSize = 1000;
|
| @@ -206,7 +206,7 @@ TEST_F(FakeNetworkPipeTest, StatisticsTest) {
|
| fake_clock_.AdvanceTimeMilliseconds(3 * kPacketTimeMs +
|
| config.queue_delay_ms);
|
|
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(2);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(2);
|
| pipe->Process();
|
|
|
| // Packet 1: kPacketTimeMs + config.queue_delay_ms,
|
| @@ -224,7 +224,7 @@ TEST_F(FakeNetworkPipeTest, ChangingCapacityWithEmptyPipeTest) {
|
| config.queue_length_packets = 20;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| // Add 10 packets of 1000 bytes, = 80 kb, and verify it takes one second to
|
| @@ -237,13 +237,13 @@ TEST_F(FakeNetworkPipeTest, ChangingCapacityWithEmptyPipeTest) {
|
| int packet_time_ms = PacketTimeMs(config.link_capacity_kbps, kPacketSize);
|
|
|
| // Time hasn't increased yet, so we souldn't get any packets.
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(0);
|
| pipe->Process();
|
|
|
| // Advance time in steps to release one packet at a time.
|
| for (int i = 0; i < kNumPackets; ++i) {
|
| fake_clock_.AdvanceTimeMilliseconds(packet_time_ms);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| @@ -259,20 +259,20 @@ TEST_F(FakeNetworkPipeTest, ChangingCapacityWithEmptyPipeTest) {
|
| packet_time_ms = PacketTimeMs(config.link_capacity_kbps, kPacketSize);
|
|
|
| // Time hasn't increased yet, so we souldn't get any packets.
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(0);
|
| pipe->Process();
|
|
|
| // Advance time in steps to release one packet at a time.
|
| for (int i = 0; i < kNumPackets; ++i) {
|
| fake_clock_.AdvanceTimeMilliseconds(packet_time_ms);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| // Check that all the packets were sent.
|
| EXPECT_EQ(static_cast<size_t>(2 * kNumPackets), pipe->sent_packets());
|
| fake_clock_.AdvanceTimeMilliseconds(pipe->TimeUntilNextProcess());
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::VIDEO, _, _, _)).Times(0);
|
| pipe->Process();
|
| }
|
|
|
| @@ -283,7 +283,7 @@ TEST_F(FakeNetworkPipeTest, ChangingCapacityWithPacketsInPipeTest) {
|
| config.queue_length_packets = 20;
|
| config.link_capacity_kbps = 80;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::AUDIO));
|
| pipe->SetReceiver(receiver_.get());
|
|
|
| // Add 10 packets of 1000 bytes, = 80 kb.
|
| @@ -306,27 +306,27 @@ TEST_F(FakeNetworkPipeTest, ChangingCapacityWithPacketsInPipeTest) {
|
| int packet_time_2_ms = PacketTimeMs(config.link_capacity_kbps, kPacketSize);
|
|
|
| // Time hasn't increased yet, so we souldn't get any packets.
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(0);
|
| pipe->Process();
|
|
|
| // Advance time in steps to release one packet at a time.
|
| for (int i = 0; i < kNumPackets; ++i) {
|
| fake_clock_.AdvanceTimeMilliseconds(packet_time_1_ms);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| // Advance time in steps to release one packet at a time.
|
| for (int i = 0; i < kNumPackets; ++i) {
|
| fake_clock_.AdvanceTimeMilliseconds(packet_time_2_ms);
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(1);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(1);
|
| pipe->Process();
|
| }
|
|
|
| // Check that all the packets were sent.
|
| EXPECT_EQ(static_cast<size_t>(2 * kNumPackets), pipe->sent_packets());
|
| fake_clock_.AdvanceTimeMilliseconds(pipe->TimeUntilNextProcess());
|
| - EXPECT_CALL(*receiver_, DeliverPacket(_, _, _, _)).Times(0);
|
| + EXPECT_CALL(*receiver_, DeliverPacket(MediaType::AUDIO, _, _, _)).Times(0);
|
| pipe->Process();
|
| }
|
|
|
| @@ -338,7 +338,7 @@ TEST_F(FakeNetworkPipeTest, DisallowReorderingThenAllowReordering) {
|
| config.queue_delay_ms = 100;
|
| config.delay_standard_deviation_ms = 10;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| ReorderTestReceiver* receiver = new ReorderTestReceiver();
|
| receiver_.reset(receiver);
|
| pipe->SetReceiver(receiver_.get());
|
| @@ -390,7 +390,7 @@ TEST_F(FakeNetworkPipeTest, BurstLoss) {
|
| config.loss_percent = kLossPercent;
|
| config.avg_burst_loss_length = kAvgBurstLength;
|
| std::unique_ptr<FakeNetworkPipe> pipe(
|
| - new FakeNetworkPipe(&fake_clock_, config));
|
| + new FakeNetworkPipe(&fake_clock_, config, MediaType::VIDEO));
|
| ReorderTestReceiver* receiver = new ReorderTestReceiver();
|
| receiver_.reset(receiver);
|
| pipe->SetReceiver(receiver_.get());
|
|
|