| Index: talk/media/base/rtpdump_unittest.cc
|
| diff --git a/talk/media/base/rtpdump_unittest.cc b/talk/media/base/rtpdump_unittest.cc
|
| deleted file mode 100644
|
| index 63662436d6b069fc381cbb4092b739362b07cb3e..0000000000000000000000000000000000000000
|
| --- a/talk/media/base/rtpdump_unittest.cc
|
| +++ /dev/null
|
| @@ -1,298 +0,0 @@
|
| -/*
|
| - * libjingle
|
| - * Copyright 2004 Google Inc.
|
| - *
|
| - * Redistribution and use in source and binary forms, with or without
|
| - * modification, are permitted provided that the following conditions are met:
|
| - *
|
| - * 1. Redistributions of source code must retain the above copyright notice,
|
| - * this list of conditions and the following disclaimer.
|
| - * 2. Redistributions in binary form must reproduce the above copyright notice,
|
| - * this list of conditions and the following disclaimer in the documentation
|
| - * and/or other materials provided with the distribution.
|
| - * 3. The name of the author may not be used to endorse or promote products
|
| - * derived from this software without specific prior written permission.
|
| - *
|
| - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
|
| - * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
| - * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
|
| - * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
| - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
| - * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
|
| - * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
|
| - * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
|
| - * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
|
| - * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
| - */
|
| -
|
| -#include <string>
|
| -
|
| -#include "talk/media/base/rtpdump.h"
|
| -#include "talk/media/base/rtputils.h"
|
| -#include "talk/media/base/testutils.h"
|
| -#include "webrtc/base/bytebuffer.h"
|
| -#include "webrtc/base/gunit.h"
|
| -#include "webrtc/base/thread.h"
|
| -
|
| -namespace cricket {
|
| -
|
| -static const uint32_t kTestSsrc = 1;
|
| -
|
| -// Test that we read the correct header fields from the RTP/RTCP packet.
|
| -TEST(RtpDumpTest, ReadRtpDumpPacket) {
|
| - rtc::ByteBuffer rtp_buf;
|
| - RtpTestUtility::kTestRawRtpPackets[0].WriteToByteBuffer(kTestSsrc, &rtp_buf);
|
| - RtpDumpPacket rtp_packet(rtp_buf.Data(), rtp_buf.Length(), 0, false);
|
| -
|
| - int payload_type;
|
| - int seq_num;
|
| - uint32_t ts;
|
| - uint32_t ssrc;
|
| - int rtcp_type;
|
| - EXPECT_FALSE(rtp_packet.is_rtcp());
|
| - EXPECT_TRUE(rtp_packet.IsValidRtpPacket());
|
| - EXPECT_FALSE(rtp_packet.IsValidRtcpPacket());
|
| - EXPECT_TRUE(rtp_packet.GetRtpPayloadType(&payload_type));
|
| - EXPECT_EQ(0, payload_type);
|
| - EXPECT_TRUE(rtp_packet.GetRtpSeqNum(&seq_num));
|
| - EXPECT_EQ(0, seq_num);
|
| - EXPECT_TRUE(rtp_packet.GetRtpTimestamp(&ts));
|
| - EXPECT_EQ(0U, ts);
|
| - EXPECT_TRUE(rtp_packet.GetRtpSsrc(&ssrc));
|
| - EXPECT_EQ(kTestSsrc, ssrc);
|
| - EXPECT_FALSE(rtp_packet.GetRtcpType(&rtcp_type));
|
| -
|
| - rtc::ByteBuffer rtcp_buf;
|
| - RtpTestUtility::kTestRawRtcpPackets[0].WriteToByteBuffer(&rtcp_buf);
|
| - RtpDumpPacket rtcp_packet(rtcp_buf.Data(), rtcp_buf.Length(), 0, true);
|
| -
|
| - EXPECT_TRUE(rtcp_packet.is_rtcp());
|
| - EXPECT_FALSE(rtcp_packet.IsValidRtpPacket());
|
| - EXPECT_TRUE(rtcp_packet.IsValidRtcpPacket());
|
| - EXPECT_TRUE(rtcp_packet.GetRtcpType(&rtcp_type));
|
| - EXPECT_EQ(0, rtcp_type);
|
| -}
|
| -
|
| -// Test that we read only the RTP dump file.
|
| -TEST(RtpDumpTest, ReadRtpDumpFile) {
|
| - RtpDumpPacket packet;
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - rtc::scoped_ptr<RtpDumpReader> reader;
|
| -
|
| - // Write a RTP packet to the stream, which is a valid RTP dump. Next, we will
|
| - // change the first line to make the RTP dump valid or invalid.
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, false, kTestSsrc, &writer));
|
| - stream.Rewind();
|
| - reader.reset(new RtpDumpReader(&stream));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader->ReadPacket(&packet));
|
| -
|
| - // The first line is correct.
|
| - stream.Rewind();
|
| - const char new_line[] = "#!rtpplay1.0 1.1.1.1/1\n";
|
| - EXPECT_EQ(rtc::SR_SUCCESS,
|
| - stream.WriteAll(new_line, strlen(new_line), NULL, NULL));
|
| - stream.Rewind();
|
| - reader.reset(new RtpDumpReader(&stream));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader->ReadPacket(&packet));
|
| -
|
| - // The first line is not correct: not started with #!rtpplay1.0.
|
| - stream.Rewind();
|
| - const char new_line2[] = "#!rtpplaz1.0 0.0.0.0/0\n";
|
| - EXPECT_EQ(rtc::SR_SUCCESS,
|
| - stream.WriteAll(new_line2, strlen(new_line2), NULL, NULL));
|
| - stream.Rewind();
|
| - reader.reset(new RtpDumpReader(&stream));
|
| - EXPECT_EQ(rtc::SR_ERROR, reader->ReadPacket(&packet));
|
| -
|
| - // The first line is not correct: no port.
|
| - stream.Rewind();
|
| - const char new_line3[] = "#!rtpplay1.0 0.0.0.0//\n";
|
| - EXPECT_EQ(rtc::SR_SUCCESS,
|
| - stream.WriteAll(new_line3, strlen(new_line3), NULL, NULL));
|
| - stream.Rewind();
|
| - reader.reset(new RtpDumpReader(&stream));
|
| - EXPECT_EQ(rtc::SR_ERROR, reader->ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test that we read the same RTP packets that rtp dump writes.
|
| -TEST(RtpDumpTest, WriteReadSameRtp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer));
|
| - EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream(
|
| - RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc));
|
| -
|
| - // Check stream has only RtpTestUtility::GetTestPacketCount() packets.
|
| - RtpDumpPacket packet;
|
| - RtpDumpReader reader(&stream);
|
| - for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) {
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - uint32_t ssrc;
|
| - EXPECT_TRUE(GetRtpSsrc(&packet.data[0], packet.data.size(), &ssrc));
|
| - EXPECT_EQ(kTestSsrc, ssrc);
|
| - }
|
| - // No more packets to read.
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -
|
| - // Rewind the stream and read again with a specified ssrc.
|
| - stream.Rewind();
|
| - RtpDumpReader reader_w_ssrc(&stream);
|
| - const uint32_t send_ssrc = kTestSsrc + 1;
|
| - reader_w_ssrc.SetSsrc(send_ssrc);
|
| - for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) {
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader_w_ssrc.ReadPacket(&packet));
|
| - EXPECT_FALSE(packet.is_rtcp());
|
| - EXPECT_EQ(packet.original_data_len, packet.data.size());
|
| - uint32_t ssrc;
|
| - EXPECT_TRUE(GetRtpSsrc(&packet.data[0], packet.data.size(), &ssrc));
|
| - EXPECT_EQ(send_ssrc, ssrc);
|
| - }
|
| - // No more packets to read.
|
| - EXPECT_EQ(rtc::SR_EOS, reader_w_ssrc.ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test that we read the same RTCP packets that rtp dump writes.
|
| -TEST(RtpDumpTest, WriteReadSameRtcp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer));
|
| - EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream(
|
| - RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc));
|
| -
|
| - // Check stream has only RtpTestUtility::GetTestPacketCount() packets.
|
| - RtpDumpPacket packet;
|
| - RtpDumpReader reader(&stream);
|
| - reader.SetSsrc(kTestSsrc + 1); // Does not affect RTCP packet.
|
| - for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) {
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - EXPECT_TRUE(packet.is_rtcp());
|
| - EXPECT_EQ(0U, packet.original_data_len);
|
| - }
|
| - // No more packets to read.
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test dumping only RTP packet headers.
|
| -TEST(RtpDumpTest, WriteReadRtpHeadersOnly) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - writer.set_packet_filter(PF_RTPHEADER);
|
| -
|
| - // Write some RTP and RTCP packets. RTP packets should only have headers;
|
| - // RTCP packets should be eaten.
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer));
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer));
|
| - stream.Rewind();
|
| -
|
| - // Check that only RTP packet headers are present.
|
| - RtpDumpPacket packet;
|
| - RtpDumpReader reader(&stream);
|
| - for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) {
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - EXPECT_FALSE(packet.is_rtcp());
|
| - size_t len = 0;
|
| - packet.GetRtpHeaderLen(&len);
|
| - EXPECT_EQ(len, packet.data.size());
|
| - EXPECT_GT(packet.original_data_len, packet.data.size());
|
| - }
|
| - // No more packets to read.
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test dumping only RTCP packets.
|
| -TEST(RtpDumpTest, WriteReadRtcpOnly) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - writer.set_packet_filter(PF_RTCPPACKET);
|
| -
|
| - // Write some RTP and RTCP packets. RTP packets should be eaten.
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer));
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer));
|
| - stream.Rewind();
|
| -
|
| - // Check that only RTCP packets are present.
|
| - RtpDumpPacket packet;
|
| - RtpDumpReader reader(&stream);
|
| - for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) {
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - EXPECT_TRUE(packet.is_rtcp());
|
| - EXPECT_EQ(0U, packet.original_data_len);
|
| - }
|
| - // No more packets to read.
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test that RtpDumpLoopReader reads RTP packets continously and the elapsed
|
| -// time, the sequence number, and timestamp are maintained properly.
|
| -TEST(RtpDumpTest, LoopReadRtp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer));
|
| - EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream(
|
| - 3 * RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc));
|
| -}
|
| -
|
| -// Test that RtpDumpLoopReader reads RTCP packets continously and the elapsed
|
| -// time is maintained properly.
|
| -TEST(RtpDumpTest, LoopReadRtcp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(
|
| - RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer));
|
| - EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream(
|
| - 3 * RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc));
|
| -}
|
| -
|
| -// Test that RtpDumpLoopReader reads continously from stream with a single RTP
|
| -// packets.
|
| -TEST(RtpDumpTest, LoopReadSingleRtp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, false, kTestSsrc, &writer));
|
| -
|
| - // The regular reader can read only one packet.
|
| - RtpDumpPacket packet;
|
| - stream.Rewind();
|
| - RtpDumpReader reader(&stream);
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -
|
| - // The loop reader reads three packets from the input stream.
|
| - stream.Rewind();
|
| - RtpDumpLoopReader loop_reader(&stream);
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| -}
|
| -
|
| -// Test that RtpDumpLoopReader reads continously from stream with a single RTCP
|
| -// packets.
|
| -TEST(RtpDumpTest, LoopReadSingleRtcp) {
|
| - rtc::MemoryStream stream;
|
| - RtpDumpWriter writer(&stream);
|
| - ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, true, kTestSsrc, &writer));
|
| -
|
| - // The regular reader can read only one packet.
|
| - RtpDumpPacket packet;
|
| - stream.Rewind();
|
| - RtpDumpReader reader(&stream);
|
| - EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet));
|
| -
|
| - // The loop reader reads three packets from the input stream.
|
| - stream.Rewind();
|
| - RtpDumpLoopReader loop_reader(&stream);
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| - EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet));
|
| -}
|
| -
|
| -} // namespace cricket
|
|
|