rtpdump_unittest.cc revision d324546ced76d4e792338af4f7d02a5cd8819f92
128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org/* 228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * libjingle 328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * Copyright 2004 Google Inc. 428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * Redistribution and use in source and binary forms, with or without 628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * modification, are permitted provided that the following conditions are met: 728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 1. Redistributions of source code must retain the above copyright notice, 928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * this list of conditions and the following disclaimer. 1028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 2. Redistributions in binary form must reproduce the above copyright notice, 1128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * this list of conditions and the following disclaimer in the documentation 1228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * and/or other materials provided with the distribution. 1328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 3. The name of the author may not be used to endorse or promote products 1428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * derived from this software without specific prior written permission. 1528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 1628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 1728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 1828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 1928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 2028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 2128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 2228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 2328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 2428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 2528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 2628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org */ 2728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 2828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include <string> 2928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/media/base/rtpdump.h" 3128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/media/base/rtputils.h" 3228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/media/base/testutils.h" 33a09a99950ec40aef6421e4ba35eee7196b7a6e68buildbot@webrtc.org#include "webrtc/base/bytebuffer.h" 34a09a99950ec40aef6421e4ba35eee7196b7a6e68buildbot@webrtc.org#include "webrtc/base/gunit.h" 35a09a99950ec40aef6421e4ba35eee7196b7a6e68buildbot@webrtc.org#include "webrtc/base/thread.h" 3628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgnamespace cricket { 3828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgstatic const uint32 kTestSsrc = 1; 4028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 4128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that we read the correct header fields from the RTP/RTCP packet. 4228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, ReadRtpDumpPacket) { 43d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::ByteBuffer rtp_buf; 4428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::kTestRawRtpPackets[0].WriteToByteBuffer(kTestSsrc, &rtp_buf); 4528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket rtp_packet(rtp_buf.Data(), rtp_buf.Length(), 0, false); 4628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 47d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org int payload_type; 4828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org int seq_num; 4928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org uint32 ts; 5028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org uint32 ssrc; 51d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org int rtcp_type; 5228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_FALSE(rtp_packet.is_rtcp()); 5328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtp_packet.IsValidRtpPacket()); 5428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_FALSE(rtp_packet.IsValidRtcpPacket()); 55d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org EXPECT_TRUE(rtp_packet.GetRtpPayloadType(&payload_type)); 56d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org EXPECT_EQ(0, payload_type); 5728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtp_packet.GetRtpSeqNum(&seq_num)); 5828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(0, seq_num); 5928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtp_packet.GetRtpTimestamp(&ts)); 6028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(0U, ts); 6128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtp_packet.GetRtpSsrc(&ssrc)); 6228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(kTestSsrc, ssrc); 63d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org EXPECT_FALSE(rtp_packet.GetRtcpType(&rtcp_type)); 6428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 65d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::ByteBuffer rtcp_buf; 6628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::kTestRawRtcpPackets[0].WriteToByteBuffer(&rtcp_buf); 6728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket rtcp_packet(rtcp_buf.Data(), rtcp_buf.Length(), 0, true); 6828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 6928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtcp_packet.is_rtcp()); 7028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_FALSE(rtcp_packet.IsValidRtpPacket()); 7128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(rtcp_packet.IsValidRtcpPacket()); 72d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org EXPECT_TRUE(rtcp_packet.GetRtcpType(&rtcp_type)); 73d324546ced76d4e792338af4f7d02a5cd8819f92pkasting@chromium.org EXPECT_EQ(0, rtcp_type); 7428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 7528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 7628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that we read only the RTP dump file. 7728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, ReadRtpDumpFile) { 7828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 79d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 8028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 81d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::scoped_ptr<RtpDumpReader> reader; 8228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 8328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Write a RTP packet to the stream, which is a valid RTP dump. Next, we will 8428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // change the first line to make the RTP dump valid or invalid. 8528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, false, kTestSsrc, &writer)); 8628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 8728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader.reset(new RtpDumpReader(&stream)); 88d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader->ReadPacket(&packet)); 8928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 9028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The first line is correct. 9128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 9228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const char new_line[] = "#!rtpplay1.0 1.1.1.1/1\n"; 93d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, 9428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.WriteAll(new_line, strlen(new_line), NULL, NULL)); 9528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 9628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader.reset(new RtpDumpReader(&stream)); 97d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader->ReadPacket(&packet)); 9828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 9928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The first line is not correct: not started with #!rtpplay1.0. 10028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 10128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const char new_line2[] = "#!rtpplaz1.0 0.0.0.0/0\n"; 102d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, 10328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.WriteAll(new_line2, strlen(new_line2), NULL, NULL)); 10428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 10528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader.reset(new RtpDumpReader(&stream)); 106d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_ERROR, reader->ReadPacket(&packet)); 10728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 10828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The first line is not correct: no port. 10928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 11028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const char new_line3[] = "#!rtpplay1.0 0.0.0.0//\n"; 111d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, 11228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.WriteAll(new_line3, strlen(new_line3), NULL, NULL)); 11328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 11428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader.reset(new RtpDumpReader(&stream)); 115d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_ERROR, reader->ReadPacket(&packet)); 11628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 11728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 11828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that we read the same RTP packets that rtp dump writes. 11928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, WriteReadSameRtp) { 120d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 12128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 12228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 12328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer)); 12428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream( 12528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc)); 12628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 12728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Check stream has only RtpTestUtility::GetTestPacketCount() packets. 12828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 12928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 13028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) { 131d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 13228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org uint32 ssrc; 13328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(GetRtpSsrc(&packet.data[0], packet.data.size(), &ssrc)); 13428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(kTestSsrc, ssrc); 13528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 13628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // No more packets to read. 137d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 13828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 13928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Rewind the stream and read again with a specified ssrc. 14028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 14128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader_w_ssrc(&stream); 14228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const uint32 send_ssrc = kTestSsrc + 1; 14328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader_w_ssrc.SetSsrc(send_ssrc); 14428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) { 145d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader_w_ssrc.ReadPacket(&packet)); 14628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_FALSE(packet.is_rtcp()); 14728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(packet.original_data_len, packet.data.size()); 14828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org uint32 ssrc; 14928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(GetRtpSsrc(&packet.data[0], packet.data.size(), &ssrc)); 15028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(send_ssrc, ssrc); 15128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 15228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // No more packets to read. 153d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader_w_ssrc.ReadPacket(&packet)); 15428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 15528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 15628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that we read the same RTCP packets that rtp dump writes. 15728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, WriteReadSameRtcp) { 158d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 15928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 16028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 16128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer)); 16228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream( 16328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc)); 16428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 16528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Check stream has only RtpTestUtility::GetTestPacketCount() packets. 16628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 16728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 16828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org reader.SetSsrc(kTestSsrc + 1); // Does not affect RTCP packet. 16928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) { 170d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 17128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(packet.is_rtcp()); 17228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(0U, packet.original_data_len); 17328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 17428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // No more packets to read. 175d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 17628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 17728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 17828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test dumping only RTP packet headers. 17928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, WriteReadRtpHeadersOnly) { 180d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 18128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 18228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org writer.set_packet_filter(PF_RTPHEADER); 18328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 18428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Write some RTP and RTCP packets. RTP packets should only have headers; 18528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // RTCP packets should be eaten. 18628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 18728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer)); 18828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 18928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer)); 19028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 19128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 19228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Check that only RTP packet headers are present. 19328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 19428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 19528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) { 196d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 19728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_FALSE(packet.is_rtcp()); 19828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org size_t len = 0; 19928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org packet.GetRtpHeaderLen(&len); 20028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(len, packet.data.size()); 20128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_GT(packet.original_data_len, packet.data.size()); 20228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 20328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // No more packets to read. 204d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 20528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 20628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 20728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test dumping only RTCP packets. 20828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, WriteReadRtcpOnly) { 209d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 21028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 21128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org writer.set_packet_filter(PF_RTCPPACKET); 21228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 21328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Write some RTP and RTCP packets. RTP packets should be eaten. 21428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 21528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer)); 21628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 21728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer)); 21828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 21928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 22028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Check that only RTCP packets are present. 22128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 22228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 22328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org for (size_t i = 0; i < RtpTestUtility::GetTestPacketCount(); ++i) { 224d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 22528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(packet.is_rtcp()); 22628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_EQ(0U, packet.original_data_len); 22728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 22828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // No more packets to read. 229d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 23028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 23128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 23228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that RtpDumpLoopReader reads RTP packets continously and the elapsed 23328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// time, the sequence number, and timestamp are maintained properly. 23428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, LoopReadRtp) { 235d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 23628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 23728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 23828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), false, kTestSsrc, &writer)); 23928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream( 24028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3 * RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc)); 24128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 24228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 24328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that RtpDumpLoopReader reads RTCP packets continously and the elapsed 24428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// time is maintained properly. 24528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, LoopReadRtcp) { 246d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 24728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 24828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets( 24928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpTestUtility::GetTestPacketCount(), true, kTestSsrc, &writer)); 25028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org EXPECT_TRUE(RtpTestUtility::VerifyTestPacketsFromStream( 25128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3 * RtpTestUtility::GetTestPacketCount(), &stream, kTestSsrc)); 25228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 25328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 25428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that RtpDumpLoopReader reads continously from stream with a single RTP 25528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// packets. 25628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, LoopReadSingleRtp) { 257d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 25828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 25928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, false, kTestSsrc, &writer)); 26028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 26128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The regular reader can read only one packet. 26228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 26328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 26428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 265d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 266d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 26728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 26828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The loop reader reads three packets from the input stream. 26928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 27028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpLoopReader loop_reader(&stream); 271d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 272d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 273d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 27428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 27528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 27628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// Test that RtpDumpLoopReader reads continously from stream with a single RTCP 27728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org// packets. 27828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgTEST(RtpDumpTest, LoopReadSingleRtcp) { 279d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::MemoryStream stream; 28028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpWriter writer(&stream); 28128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org ASSERT_TRUE(RtpTestUtility::WriteTestPackets(1, true, kTestSsrc, &writer)); 28228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 28328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The regular reader can read only one packet. 28428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpPacket packet; 28528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 28628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpReader reader(&stream); 287d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, reader.ReadPacket(&packet)); 288d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_EOS, reader.ReadPacket(&packet)); 28928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 29028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // The loop reader reads three packets from the input stream. 29128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org stream.Rewind(); 29228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org RtpDumpLoopReader loop_reader(&stream); 293d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 294d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 295d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org EXPECT_EQ(rtc::SR_SUCCESS, loop_reader.ReadPacket(&packet)); 29628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} 29728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 29828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} // namespace cricket 299