blob: 0f9d674ecee549139762bece67f36ee16224bd45 [file] [log] [blame]
tereliusd4ed7f52017-02-08 04:22:53 -08001/*
2 * Copyright (c) 2017 The WebRTC project authors. All Rights Reserved.
3 *
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
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
oprypin6e09d872017-08-31 03:21:39 -070011#include <string.h>
12
tereliusd4ed7f52017-02-08 04:22:53 -080013#include <iostream>
ilnika8e781a2017-06-12 01:02:46 -070014#include <map>
tereliusd4ed7f52017-02-08 04:22:53 -080015#include <sstream>
16#include <string>
ilnika8e781a2017-06-12 01:02:46 -070017#include <utility> // pair
tereliusd4ed7f52017-02-08 04:22:53 -080018
Stefan Holmer1acbd682017-09-01 15:29:28 +020019#include "webrtc/call/video_config.h"
tereliusd4ed7f52017-02-08 04:22:53 -080020#include "webrtc/common_types.h"
21#include "webrtc/logging/rtc_event_log/rtc_event_log_parser.h"
22#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/bye.h"
23#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/common_header.h"
24#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/extended_reports.h"
25#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/fir.h"
26#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/nack.h"
27#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/pli.h"
28#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/rapid_resync_request.h"
29#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/receiver_report.h"
30#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/remb.h"
tereliusd4ed7f52017-02-08 04:22:53 -080031#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/sdes.h"
32#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/sender_report.h"
tereliusd4ed7f52017-02-08 04:22:53 -080033#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/tmmbn.h"
34#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/tmmbr.h"
35#include "webrtc/modules/rtp_rtcp/source/rtcp_packet/transport_feedback.h"
terelius007d5622017-08-08 05:40:26 -070036#include "webrtc/modules/rtp_rtcp/source/rtp_header_extensions.h"
tereliusd4ed7f52017-02-08 04:22:53 -080037#include "webrtc/modules/rtp_rtcp/source/rtp_utility.h"
Edward Lemurc20978e2017-07-06 19:44:34 +020038#include "webrtc/rtc_base/checks.h"
oprypin6e09d872017-08-31 03:21:39 -070039#include "webrtc/rtc_base/flags.h"
tereliusd4ed7f52017-02-08 04:22:53 -080040
41namespace {
42
tereliusc3d2bfd2017-09-12 05:57:36 -070043DEFINE_bool(config, true, "Use --noconfig to exclude stream configurations.");
44DEFINE_bool(incoming, true, "Use --noincoming to exclude incoming packets.");
45DEFINE_bool(outgoing, true, "Use --nooutgoing to exclude packets.");
tereliusd4ed7f52017-02-08 04:22:53 -080046// TODO(terelius): Note that the media type doesn't work with outgoing packets.
tereliusc3d2bfd2017-09-12 05:57:36 -070047DEFINE_bool(audio, true, "Use --noaudio to exclude audio packets.");
tereliusd4ed7f52017-02-08 04:22:53 -080048// TODO(terelius): Note that the media type doesn't work with outgoing packets.
tereliusc3d2bfd2017-09-12 05:57:36 -070049DEFINE_bool(video, true, "Use --novideo to exclude video packets.");
tereliusd4ed7f52017-02-08 04:22:53 -080050// TODO(terelius): Note that the media type doesn't work with outgoing packets.
tereliusc3d2bfd2017-09-12 05:57:36 -070051DEFINE_bool(data, true, "Use --nodata to exclude data packets.");
52DEFINE_bool(rtp, true, "Use --nortp to exclude RTP packets.");
53DEFINE_bool(rtcp, true, "Use --nortcp to exclude RTCP packets.");
tereliusd4ed7f52017-02-08 04:22:53 -080054// TODO(terelius): Allow a list of SSRCs.
55DEFINE_string(ssrc,
56 "",
57 "Print only packets with this SSRC (decimal or hex, the latter "
58 "starting with 0x).");
oprypin6e09d872017-08-31 03:21:39 -070059DEFINE_bool(help, false, "Prints this message.");
tereliusd4ed7f52017-02-08 04:22:53 -080060
perkj77cd58e2017-05-30 03:52:10 -070061using MediaType = webrtc::ParsedRtcEventLog::MediaType;
62
tereliusd4ed7f52017-02-08 04:22:53 -080063static uint32_t filtered_ssrc = 0;
64
65// Parses the input string for a valid SSRC. If a valid SSRC is found, it is
66// written to the static global variable |filtered_ssrc|, and true is returned.
67// Otherwise, false is returned.
68// The empty string must be validated as true, because it is the default value
69// of the command-line flag. In this case, no value is written to the output
70// variable.
71bool ParseSsrc(std::string str) {
72 // If the input string starts with 0x or 0X it indicates a hexadecimal number.
73 auto read_mode = std::dec;
74 if (str.size() > 2 &&
75 (str.substr(0, 2) == "0x" || str.substr(0, 2) == "0X")) {
76 read_mode = std::hex;
77 str = str.substr(2);
78 }
79 std::stringstream ss(str);
80 ss >> read_mode >> filtered_ssrc;
81 return str.empty() || (!ss.fail() && ss.eof());
82}
83
84bool ExcludePacket(webrtc::PacketDirection direction,
perkj77cd58e2017-05-30 03:52:10 -070085 MediaType media_type,
tereliusd4ed7f52017-02-08 04:22:53 -080086 uint32_t packet_ssrc) {
tereliusc3d2bfd2017-09-12 05:57:36 -070087 if (!FLAG_outgoing && direction == webrtc::kOutgoingPacket)
tereliusd4ed7f52017-02-08 04:22:53 -080088 return true;
tereliusc3d2bfd2017-09-12 05:57:36 -070089 if (!FLAG_incoming && direction == webrtc::kIncomingPacket)
tereliusd4ed7f52017-02-08 04:22:53 -080090 return true;
tereliusc3d2bfd2017-09-12 05:57:36 -070091 if (!FLAG_audio && media_type == MediaType::AUDIO)
tereliusd4ed7f52017-02-08 04:22:53 -080092 return true;
tereliusc3d2bfd2017-09-12 05:57:36 -070093 if (!FLAG_video && media_type == MediaType::VIDEO)
tereliusd4ed7f52017-02-08 04:22:53 -080094 return true;
tereliusc3d2bfd2017-09-12 05:57:36 -070095 if (!FLAG_data && media_type == MediaType::DATA)
tereliusd4ed7f52017-02-08 04:22:53 -080096 return true;
oprypin6e09d872017-08-31 03:21:39 -070097 if (strlen(FLAG_ssrc) > 0 && packet_ssrc != filtered_ssrc)
tereliusd4ed7f52017-02-08 04:22:53 -080098 return true;
99 return false;
100}
101
102const char* StreamInfo(webrtc::PacketDirection direction,
perkj77cd58e2017-05-30 03:52:10 -0700103 MediaType media_type) {
tereliusd4ed7f52017-02-08 04:22:53 -0800104 if (direction == webrtc::kOutgoingPacket) {
perkj77cd58e2017-05-30 03:52:10 -0700105 if (media_type == MediaType::AUDIO)
tereliusd4ed7f52017-02-08 04:22:53 -0800106 return "(out,audio)";
perkj77cd58e2017-05-30 03:52:10 -0700107 else if (media_type == MediaType::VIDEO)
tereliusd4ed7f52017-02-08 04:22:53 -0800108 return "(out,video)";
perkj77cd58e2017-05-30 03:52:10 -0700109 else if (media_type == MediaType::DATA)
tereliusd4ed7f52017-02-08 04:22:53 -0800110 return "(out,data)";
111 else
112 return "(out)";
113 }
114 if (direction == webrtc::kIncomingPacket) {
perkj77cd58e2017-05-30 03:52:10 -0700115 if (media_type == MediaType::AUDIO)
tereliusd4ed7f52017-02-08 04:22:53 -0800116 return "(in,audio)";
perkj77cd58e2017-05-30 03:52:10 -0700117 else if (media_type == MediaType::VIDEO)
tereliusd4ed7f52017-02-08 04:22:53 -0800118 return "(in,video)";
perkj77cd58e2017-05-30 03:52:10 -0700119 else if (media_type == MediaType::DATA)
tereliusd4ed7f52017-02-08 04:22:53 -0800120 return "(in,data)";
121 else
122 return "(in)";
123 }
124 return "(unknown)";
125}
126
terelius007d5622017-08-08 05:40:26 -0700127// Return default values for header extensions, to use on streams without stored
128// mapping data. Currently this only applies to audio streams, since the mapping
129// is not stored in the event log.
130// TODO(ivoc): Remove this once this mapping is stored in the event log for
131// audio streams. Tracking bug: webrtc:6399
132webrtc::RtpHeaderExtensionMap GetDefaultHeaderExtensionMap() {
133 webrtc::RtpHeaderExtensionMap default_map;
134 default_map.Register<webrtc::AudioLevel>(
135 webrtc::RtpExtension::kAudioLevelDefaultId);
136 default_map.Register<webrtc::TransmissionOffset>(
137 webrtc::RtpExtension::kTimestampOffsetDefaultId);
138 default_map.Register<webrtc::AbsoluteSendTime>(
139 webrtc::RtpExtension::kAbsSendTimeDefaultId);
140 default_map.Register<webrtc::VideoOrientation>(
141 webrtc::RtpExtension::kVideoRotationDefaultId);
142 default_map.Register<webrtc::VideoContentTypeExtension>(
143 webrtc::RtpExtension::kVideoContentTypeDefaultId);
144 default_map.Register<webrtc::VideoTimingExtension>(
145 webrtc::RtpExtension::kVideoTimingDefaultId);
146 default_map.Register<webrtc::TransportSequenceNumber>(
147 webrtc::RtpExtension::kTransportSequenceNumberDefaultId);
148 default_map.Register<webrtc::PlayoutDelayLimits>(
149 webrtc::RtpExtension::kPlayoutDelayDefaultId);
150 return default_map;
151}
152
perkj77cd58e2017-05-30 03:52:10 -0700153void PrintSenderReport(const webrtc::ParsedRtcEventLog& parsed_stream,
154 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800155 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700156 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800157 webrtc::rtcp::SenderReport sr;
158 if (!sr.Parse(rtcp_block))
159 return;
perkj77cd58e2017-05-30 03:52:10 -0700160 MediaType media_type =
161 parsed_stream.GetMediaType(sr.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800162 if (ExcludePacket(direction, media_type, sr.sender_ssrc()))
163 return;
164 std::cout << log_timestamp << "\t"
165 << "RTCP_SR" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800166 << "\tssrc=" << sr.sender_ssrc()
tereliusd4ed7f52017-02-08 04:22:53 -0800167 << "\ttimestamp=" << sr.rtp_timestamp() << std::endl;
168}
169
perkj77cd58e2017-05-30 03:52:10 -0700170void PrintReceiverReport(const webrtc::ParsedRtcEventLog& parsed_stream,
171 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800172 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700173 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800174 webrtc::rtcp::ReceiverReport rr;
175 if (!rr.Parse(rtcp_block))
176 return;
perkj77cd58e2017-05-30 03:52:10 -0700177 MediaType media_type =
178 parsed_stream.GetMediaType(rr.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800179 if (ExcludePacket(direction, media_type, rr.sender_ssrc()))
180 return;
181 std::cout << log_timestamp << "\t"
182 << "RTCP_RR" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800183 << "\tssrc=" << rr.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800184}
185
perkj77cd58e2017-05-30 03:52:10 -0700186void PrintXr(const webrtc::ParsedRtcEventLog& parsed_stream,
187 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800188 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700189 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800190 webrtc::rtcp::ExtendedReports xr;
191 if (!xr.Parse(rtcp_block))
192 return;
perkj77cd58e2017-05-30 03:52:10 -0700193 MediaType media_type =
194 parsed_stream.GetMediaType(xr.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800195 if (ExcludePacket(direction, media_type, xr.sender_ssrc()))
196 return;
197 std::cout << log_timestamp << "\t"
198 << "RTCP_XR" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800199 << "\tssrc=" << xr.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800200}
201
202void PrintSdes(const webrtc::rtcp::CommonHeader& rtcp_block,
203 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700204 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800205 std::cout << log_timestamp << "\t"
perkj77cd58e2017-05-30 03:52:10 -0700206 << "RTCP_SDES" << StreamInfo(direction, MediaType::ANY)
perkjc52bd612017-05-19 05:32:56 -0700207 << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800208 RTC_NOTREACHED() << "SDES should have been redacted when writing the log";
209}
210
perkj77cd58e2017-05-30 03:52:10 -0700211void PrintBye(const webrtc::ParsedRtcEventLog& parsed_stream,
212 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800213 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700214 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800215 webrtc::rtcp::Bye bye;
216 if (!bye.Parse(rtcp_block))
217 return;
perkj77cd58e2017-05-30 03:52:10 -0700218 MediaType media_type =
219 parsed_stream.GetMediaType(bye.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800220 if (ExcludePacket(direction, media_type, bye.sender_ssrc()))
221 return;
222 std::cout << log_timestamp << "\t"
223 << "RTCP_BYE" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800224 << "\tssrc=" << bye.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800225}
226
perkj77cd58e2017-05-30 03:52:10 -0700227void PrintRtpFeedback(const webrtc::ParsedRtcEventLog& parsed_stream,
228 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800229 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700230 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800231 switch (rtcp_block.fmt()) {
232 case webrtc::rtcp::Nack::kFeedbackMessageType: {
233 webrtc::rtcp::Nack nack;
234 if (!nack.Parse(rtcp_block))
235 return;
perkj77cd58e2017-05-30 03:52:10 -0700236 MediaType media_type =
237 parsed_stream.GetMediaType(nack.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800238 if (ExcludePacket(direction, media_type, nack.sender_ssrc()))
239 return;
240 std::cout << log_timestamp << "\t"
241 << "RTCP_NACK" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800242 << "\tssrc=" << nack.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800243 break;
244 }
245 case webrtc::rtcp::Tmmbr::kFeedbackMessageType: {
246 webrtc::rtcp::Tmmbr tmmbr;
247 if (!tmmbr.Parse(rtcp_block))
248 return;
perkj77cd58e2017-05-30 03:52:10 -0700249 MediaType media_type =
250 parsed_stream.GetMediaType(tmmbr.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800251 if (ExcludePacket(direction, media_type, tmmbr.sender_ssrc()))
252 return;
253 std::cout << log_timestamp << "\t"
254 << "RTCP_TMMBR" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800255 << "\tssrc=" << tmmbr.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800256 break;
257 }
258 case webrtc::rtcp::Tmmbn::kFeedbackMessageType: {
259 webrtc::rtcp::Tmmbn tmmbn;
260 if (!tmmbn.Parse(rtcp_block))
261 return;
perkj77cd58e2017-05-30 03:52:10 -0700262 MediaType media_type =
263 parsed_stream.GetMediaType(tmmbn.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800264 if (ExcludePacket(direction, media_type, tmmbn.sender_ssrc()))
265 return;
266 std::cout << log_timestamp << "\t"
267 << "RTCP_TMMBN" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800268 << "\tssrc=" << tmmbn.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800269 break;
270 }
271 case webrtc::rtcp::RapidResyncRequest::kFeedbackMessageType: {
272 webrtc::rtcp::RapidResyncRequest sr_req;
273 if (!sr_req.Parse(rtcp_block))
274 return;
perkj77cd58e2017-05-30 03:52:10 -0700275 MediaType media_type =
276 parsed_stream.GetMediaType(sr_req.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800277 if (ExcludePacket(direction, media_type, sr_req.sender_ssrc()))
278 return;
279 std::cout << log_timestamp << "\t"
280 << "RTCP_SRREQ" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800281 << "\tssrc=" << sr_req.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800282 break;
283 }
284 case webrtc::rtcp::TransportFeedback::kFeedbackMessageType: {
285 webrtc::rtcp::TransportFeedback transport_feedback;
286 if (!transport_feedback.Parse(rtcp_block))
287 return;
perkj77cd58e2017-05-30 03:52:10 -0700288 MediaType media_type = parsed_stream.GetMediaType(
289 transport_feedback.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800290 if (ExcludePacket(direction, media_type,
291 transport_feedback.sender_ssrc()))
292 return;
293 std::cout << log_timestamp << "\t"
294 << "RTCP_NEWFB" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800295 << "\tssrc=" << transport_feedback.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800296 break;
297 }
298 default:
tereliusd4ed7f52017-02-08 04:22:53 -0800299 break;
300 }
301}
302
perkj77cd58e2017-05-30 03:52:10 -0700303void PrintPsFeedback(const webrtc::ParsedRtcEventLog& parsed_stream,
304 const webrtc::rtcp::CommonHeader& rtcp_block,
tereliusd4ed7f52017-02-08 04:22:53 -0800305 uint64_t log_timestamp,
perkjc52bd612017-05-19 05:32:56 -0700306 webrtc::PacketDirection direction) {
tereliusd4ed7f52017-02-08 04:22:53 -0800307 switch (rtcp_block.fmt()) {
308 case webrtc::rtcp::Pli::kFeedbackMessageType: {
309 webrtc::rtcp::Pli pli;
310 if (!pli.Parse(rtcp_block))
311 return;
perkj77cd58e2017-05-30 03:52:10 -0700312 MediaType media_type =
313 parsed_stream.GetMediaType(pli.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800314 if (ExcludePacket(direction, media_type, pli.sender_ssrc()))
315 return;
316 std::cout << log_timestamp << "\t"
317 << "RTCP_PLI" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800318 << "\tssrc=" << pli.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800319 break;
320 }
tereliusd4ed7f52017-02-08 04:22:53 -0800321 case webrtc::rtcp::Fir::kFeedbackMessageType: {
322 webrtc::rtcp::Fir fir;
323 if (!fir.Parse(rtcp_block))
324 return;
perkj77cd58e2017-05-30 03:52:10 -0700325 MediaType media_type =
326 parsed_stream.GetMediaType(fir.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800327 if (ExcludePacket(direction, media_type, fir.sender_ssrc()))
328 return;
329 std::cout << log_timestamp << "\t"
330 << "RTCP_FIR" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800331 << "\tssrc=" << fir.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800332 break;
333 }
334 case webrtc::rtcp::Remb::kFeedbackMessageType: {
335 webrtc::rtcp::Remb remb;
336 if (!remb.Parse(rtcp_block))
337 return;
perkj77cd58e2017-05-30 03:52:10 -0700338 MediaType media_type =
339 parsed_stream.GetMediaType(remb.sender_ssrc(), direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800340 if (ExcludePacket(direction, media_type, remb.sender_ssrc()))
341 return;
342 std::cout << log_timestamp << "\t"
343 << "RTCP_REMB" << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800344 << "\tssrc=" << remb.sender_ssrc() << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800345 break;
346 }
347 default:
348 break;
349 }
350}
351
352} // namespace
353
354// This utility will print basic information about each packet to stdout.
355// Note that parser will assert if the protobuf event is missing some required
356// fields and we attempt to access them. We don't handle this at the moment.
357int main(int argc, char* argv[]) {
358 std::string program_name = argv[0];
359 std::string usage =
360 "Tool for printing packet information from an RtcEventLog as text.\n"
361 "Run " +
362 program_name +
oprypin6e09d872017-08-31 03:21:39 -0700363 " --help for usage.\n"
tereliusd4ed7f52017-02-08 04:22:53 -0800364 "Example usage:\n" +
365 program_name + " input.rel\n";
oprypin6e09d872017-08-31 03:21:39 -0700366 if (rtc::FlagList::SetFlagsFromCommandLine(&argc, argv, true) ||
367 FLAG_help || argc != 2) {
368 std::cout << usage;
369 if (FLAG_help) {
370 rtc::FlagList::Print(nullptr, false);
371 return 0;
372 }
373 return 1;
tereliusd4ed7f52017-02-08 04:22:53 -0800374 }
375 std::string input_file = argv[1];
376
oprypin6e09d872017-08-31 03:21:39 -0700377 if (strlen(FLAG_ssrc) > 0)
378 RTC_CHECK(ParseSsrc(FLAG_ssrc)) << "Flag verification has failed.";
tereliusd4ed7f52017-02-08 04:22:53 -0800379
terelius007d5622017-08-08 05:40:26 -0700380 webrtc::RtpHeaderExtensionMap default_map = GetDefaultHeaderExtensionMap();
381
tereliusd4ed7f52017-02-08 04:22:53 -0800382 webrtc::ParsedRtcEventLog parsed_stream;
383 if (!parsed_stream.ParseFile(input_file)) {
384 std::cerr << "Error while parsing input file: " << input_file << std::endl;
385 return -1;
386 }
387
388 for (size_t i = 0; i < parsed_stream.GetNumberOfEvents(); i++) {
tereliusc3d2bfd2017-09-12 05:57:36 -0700389 if (FLAG_config && FLAG_video && FLAG_incoming &&
perkj77cd58e2017-05-30 03:52:10 -0700390 parsed_stream.GetEventType(i) ==
391 webrtc::ParsedRtcEventLog::VIDEO_RECEIVER_CONFIG_EVENT) {
terelius8fbc7652017-05-31 02:03:16 -0700392 webrtc::rtclog::StreamConfig config =
393 parsed_stream.GetVideoReceiveConfig(i);
perkj77cd58e2017-05-30 03:52:10 -0700394 std::cout << parsed_stream.GetTimestamp(i) << "\tVIDEO_RECV_CONFIG"
perkj09e71da2017-05-22 03:26:49 -0700395 << "\tssrc=" << config.remote_ssrc
terelius5b542132017-06-01 05:23:03 -0700396 << "\tfeedback_ssrc=" << config.local_ssrc;
397 std::cout << "\textensions={";
398 for (const auto& extension : config.rtp_extensions) {
399 std::cout << extension.ToString() << ",";
400 }
401 std::cout << "}";
402 std::cout << "\tcodecs={";
403 for (const auto& codec : config.codecs) {
404 std::cout << "{name: " << codec.payload_name
405 << ", payload_type: " << codec.payload_type
406 << ", rtx_payload_type: " << codec.rtx_payload_type << "}";
407 }
408 std::cout << "}" << std::endl;
tereliusbb46b952017-02-08 09:37:30 -0800409 }
tereliusc3d2bfd2017-09-12 05:57:36 -0700410 if (FLAG_config && FLAG_video && FLAG_outgoing &&
perkj77cd58e2017-05-30 03:52:10 -0700411 parsed_stream.GetEventType(i) ==
412 webrtc::ParsedRtcEventLog::VIDEO_SENDER_CONFIG_EVENT) {
terelius8fbc7652017-05-31 02:03:16 -0700413 std::vector<webrtc::rtclog::StreamConfig> configs =
414 parsed_stream.GetVideoSendConfig(i);
terelius5b542132017-06-01 05:23:03 -0700415 for (const auto& config : configs) {
perkjc52bd612017-05-19 05:32:56 -0700416 std::cout << parsed_stream.GetTimestamp(i) << "\tVIDEO_SEND_CONFIG";
terelius5b542132017-06-01 05:23:03 -0700417 std::cout << "\tssrcs=" << config.local_ssrc;
418 std::cout << "\trtx_ssrcs=" << config.rtx_ssrc;
419 std::cout << "\textensions={";
420 for (const auto& extension : config.rtp_extensions) {
421 std::cout << extension.ToString() << ",";
422 }
423 std::cout << "}";
424 std::cout << "\tcodecs={";
425 for (const auto& codec : config.codecs) {
426 std::cout << "{name: " << codec.payload_name
427 << ", payload_type: " << codec.payload_type
428 << ", rtx_payload_type: " << codec.rtx_payload_type << "}";
429 }
430 std::cout << "}" << std::endl;
terelius8fbc7652017-05-31 02:03:16 -0700431 }
tereliusbb46b952017-02-08 09:37:30 -0800432 }
tereliusc3d2bfd2017-09-12 05:57:36 -0700433 if (FLAG_config && FLAG_audio && FLAG_incoming &&
perkj77cd58e2017-05-30 03:52:10 -0700434 parsed_stream.GetEventType(i) ==
435 webrtc::ParsedRtcEventLog::AUDIO_RECEIVER_CONFIG_EVENT) {
terelius8fbc7652017-05-31 02:03:16 -0700436 webrtc::rtclog::StreamConfig config =
437 parsed_stream.GetAudioReceiveConfig(i);
perkj77cd58e2017-05-30 03:52:10 -0700438 std::cout << parsed_stream.GetTimestamp(i) << "\tAUDIO_RECV_CONFIG"
439 << "\tssrc=" << config.remote_ssrc
terelius5b542132017-06-01 05:23:03 -0700440 << "\tfeedback_ssrc=" << config.local_ssrc;
441 std::cout << "\textensions={";
442 for (const auto& extension : config.rtp_extensions) {
443 std::cout << extension.ToString() << ",";
444 }
445 std::cout << "}";
446 std::cout << "\tcodecs={";
447 for (const auto& codec : config.codecs) {
448 std::cout << "{name: " << codec.payload_name
449 << ", payload_type: " << codec.payload_type
450 << ", rtx_payload_type: " << codec.rtx_payload_type << "}";
451 }
452 std::cout << "}" << std::endl;
tereliusbb46b952017-02-08 09:37:30 -0800453 }
tereliusc3d2bfd2017-09-12 05:57:36 -0700454 if (FLAG_config && FLAG_audio && FLAG_outgoing &&
perkj77cd58e2017-05-30 03:52:10 -0700455 parsed_stream.GetEventType(i) ==
456 webrtc::ParsedRtcEventLog::AUDIO_SENDER_CONFIG_EVENT) {
terelius8fbc7652017-05-31 02:03:16 -0700457 webrtc::rtclog::StreamConfig config = parsed_stream.GetAudioSendConfig(i);
perkj77cd58e2017-05-30 03:52:10 -0700458 std::cout << parsed_stream.GetTimestamp(i) << "\tAUDIO_SEND_CONFIG"
terelius5b542132017-06-01 05:23:03 -0700459 << "\tssrc=" << config.local_ssrc;
460 std::cout << "\textensions={";
461 for (const auto& extension : config.rtp_extensions) {
462 std::cout << extension.ToString() << ",";
463 }
464 std::cout << "}";
465 std::cout << "\tcodecs={";
466 for (const auto& codec : config.codecs) {
467 std::cout << "{name: " << codec.payload_name
468 << ", payload_type: " << codec.payload_type
469 << ", rtx_payload_type: " << codec.rtx_payload_type << "}";
470 }
471 std::cout << "}" << std::endl;
tereliusbb46b952017-02-08 09:37:30 -0800472 }
tereliusc3d2bfd2017-09-12 05:57:36 -0700473 if (FLAG_rtp &&
tereliusd4ed7f52017-02-08 04:22:53 -0800474 parsed_stream.GetEventType(i) == webrtc::ParsedRtcEventLog::RTP_EVENT) {
475 size_t header_length;
476 size_t total_length;
477 uint8_t header[IP_PACKET_SIZE];
478 webrtc::PacketDirection direction;
ilnika8e781a2017-06-12 01:02:46 -0700479 webrtc::RtpHeaderExtensionMap* extension_map = parsed_stream.GetRtpHeader(
480 i, &direction, header, &header_length, &total_length);
tereliusd4ed7f52017-02-08 04:22:53 -0800481
terelius007d5622017-08-08 05:40:26 -0700482 if (extension_map == nullptr)
483 extension_map = &default_map;
484
tereliusd4ed7f52017-02-08 04:22:53 -0800485 // Parse header to get SSRC and RTP time.
486 webrtc::RtpUtility::RtpHeaderParser rtp_parser(header, header_length);
487 webrtc::RTPHeader parsed_header;
ilnika8e781a2017-06-12 01:02:46 -0700488 rtp_parser.Parse(&parsed_header, extension_map);
perkj77cd58e2017-05-30 03:52:10 -0700489 MediaType media_type =
490 parsed_stream.GetMediaType(parsed_header.ssrc, direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800491
492 if (ExcludePacket(direction, media_type, parsed_header.ssrc))
493 continue;
494
495 std::cout << parsed_stream.GetTimestamp(i) << "\tRTP"
496 << StreamInfo(direction, media_type)
tereliusbb46b952017-02-08 09:37:30 -0800497 << "\tssrc=" << parsed_header.ssrc
ilnika8e781a2017-06-12 01:02:46 -0700498 << "\ttimestamp=" << parsed_header.timestamp;
499 if (parsed_header.extension.hasAbsoluteSendTime) {
500 std::cout << "\tAbsSendTime="
501 << parsed_header.extension.absoluteSendTime;
502 }
503 if (parsed_header.extension.hasVideoContentType) {
504 std::cout << "\tContentType="
505 << static_cast<int>(parsed_header.extension.videoContentType);
506 }
507 if (parsed_header.extension.hasVideoRotation) {
508 std::cout << "\tRotation="
509 << static_cast<int>(parsed_header.extension.videoRotation);
510 }
511 if (parsed_header.extension.hasTransportSequenceNumber) {
512 std::cout << "\tTransportSeq="
513 << parsed_header.extension.transportSequenceNumber;
514 }
515 if (parsed_header.extension.hasTransmissionTimeOffset) {
516 std::cout << "\tTransmTimeOffset="
517 << parsed_header.extension.transmissionTimeOffset;
518 }
519 if (parsed_header.extension.hasAudioLevel) {
520 std::cout << "\tAudioLevel=" << parsed_header.extension.audioLevel;
521 }
522 std::cout << std::endl;
tereliusd4ed7f52017-02-08 04:22:53 -0800523 }
tereliusc3d2bfd2017-09-12 05:57:36 -0700524 if (FLAG_rtcp && parsed_stream.GetEventType(i) ==
525 webrtc::ParsedRtcEventLog::RTCP_EVENT) {
tereliusd4ed7f52017-02-08 04:22:53 -0800526 size_t length;
527 uint8_t packet[IP_PACKET_SIZE];
528 webrtc::PacketDirection direction;
perkj77cd58e2017-05-30 03:52:10 -0700529 parsed_stream.GetRtcpPacket(i, &direction, packet, &length);
tereliusd4ed7f52017-02-08 04:22:53 -0800530
531 webrtc::rtcp::CommonHeader rtcp_block;
532 const uint8_t* packet_end = packet + length;
533 for (const uint8_t* next_block = packet; next_block != packet_end;
534 next_block = rtcp_block.NextPacket()) {
535 ptrdiff_t remaining_blocks_size = packet_end - next_block;
536 RTC_DCHECK_GT(remaining_blocks_size, 0);
537 if (!rtcp_block.Parse(next_block, remaining_blocks_size)) {
538 break;
539 }
540
541 uint64_t log_timestamp = parsed_stream.GetTimestamp(i);
542 switch (rtcp_block.type()) {
543 case webrtc::rtcp::SenderReport::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700544 PrintSenderReport(parsed_stream, rtcp_block, log_timestamp,
545 direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800546 break;
547 case webrtc::rtcp::ReceiverReport::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700548 PrintReceiverReport(parsed_stream, rtcp_block, log_timestamp,
549 direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800550 break;
551 case webrtc::rtcp::Sdes::kPacketType:
perkjc52bd612017-05-19 05:32:56 -0700552 PrintSdes(rtcp_block, log_timestamp, direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800553 break;
554 case webrtc::rtcp::ExtendedReports::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700555 PrintXr(parsed_stream, rtcp_block, log_timestamp, direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800556 break;
557 case webrtc::rtcp::Bye::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700558 PrintBye(parsed_stream, rtcp_block, log_timestamp, direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800559 break;
560 case webrtc::rtcp::Rtpfb::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700561 PrintRtpFeedback(parsed_stream, rtcp_block, log_timestamp,
562 direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800563 break;
564 case webrtc::rtcp::Psfb::kPacketType:
perkj77cd58e2017-05-30 03:52:10 -0700565 PrintPsFeedback(parsed_stream, rtcp_block, log_timestamp,
566 direction);
tereliusd4ed7f52017-02-08 04:22:53 -0800567 break;
568 default:
569 break;
570 }
571 }
572 }
tereliusd4ed7f52017-02-08 04:22:53 -0800573 }
574 return 0;
575}