| Index: webrtc/video/rtc_event_log2rtp_dump.cc
|
| diff --git a/webrtc/video/rtc_event_log2rtp_dump.cc b/webrtc/video/rtc_event_log2rtp_dump.cc
|
| deleted file mode 100644
|
| index 4f1d93bbe46ce55997d42a2fdf7d8786a75c8a08..0000000000000000000000000000000000000000
|
| --- a/webrtc/video/rtc_event_log2rtp_dump.cc
|
| +++ /dev/null
|
| @@ -1,207 +0,0 @@
|
| -/*
|
| - * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -#include <iostream>
|
| -#include <sstream>
|
| -#include <string>
|
| -
|
| -#include "gflags/gflags.h"
|
| -#include "webrtc/base/checks.h"
|
| -#include "webrtc/base/scoped_ptr.h"
|
| -#include "webrtc/modules/rtp_rtcp/source/byte_io.h"
|
| -#include "webrtc/test/rtp_file_writer.h"
|
| -#include "webrtc/video/rtc_event_log.h"
|
| -
|
| -// Files generated at build-time by the protobuf compiler.
|
| -#ifdef WEBRTC_ANDROID_PLATFORM_BUILD
|
| -#include "external/webrtc/webrtc/video/rtc_event_log.pb.h"
|
| -#else
|
| -#include "webrtc/video/rtc_event_log.pb.h"
|
| -#endif
|
| -
|
| -namespace {
|
| -
|
| -DEFINE_bool(noaudio,
|
| - false,
|
| - "Excludes audio packets from the converted RTPdump file.");
|
| -DEFINE_bool(novideo,
|
| - false,
|
| - "Excludes video packets from the converted RTPdump file.");
|
| -DEFINE_bool(nodata,
|
| - false,
|
| - "Excludes data packets from the converted RTPdump file.");
|
| -DEFINE_bool(nortp,
|
| - false,
|
| - "Excludes RTP packets from the converted RTPdump file.");
|
| -DEFINE_bool(nortcp,
|
| - false,
|
| - "Excludes RTCP packets from the converted RTPdump file.");
|
| -DEFINE_string(ssrc,
|
| - "",
|
| - "Store only packets with this SSRC (decimal or hex, the latter "
|
| - "starting with 0x).");
|
| -
|
| -// Parses the input string for a valid SSRC. If a valid SSRC is found, it is
|
| -// written to the output variable |ssrc|, and true is returned. Otherwise,
|
| -// false is returned.
|
| -// The empty string must be validated as true, because it is the default value
|
| -// of the command-line flag. In this case, no value is written to the output
|
| -// variable.
|
| -bool ParseSsrc(std::string str, uint32_t* ssrc) {
|
| - // If the input string starts with 0x or 0X it indicates a hexadecimal number.
|
| - auto read_mode = std::dec;
|
| - if (str.size() > 2 &&
|
| - (str.substr(0, 2) == "0x" || str.substr(0, 2) == "0X")) {
|
| - read_mode = std::hex;
|
| - str = str.substr(2);
|
| - }
|
| - std::stringstream ss(str);
|
| - ss >> read_mode >> *ssrc;
|
| - return str.empty() || (!ss.fail() && ss.eof());
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -// This utility will convert a stored event log to the rtpdump format.
|
| -int main(int argc, char* argv[]) {
|
| - std::string program_name = argv[0];
|
| - std::string usage =
|
| - "Tool for converting an RtcEventLog file to an RTP dump file.\n"
|
| - "Run " +
|
| - program_name +
|
| - " --helpshort for usage.\n"
|
| - "Example usage:\n" +
|
| - program_name + " input.rel output.rtp\n";
|
| - google::SetUsageMessage(usage);
|
| - google::ParseCommandLineFlags(&argc, &argv, true);
|
| -
|
| - if (argc != 3) {
|
| - std::cout << google::ProgramUsage();
|
| - return 0;
|
| - }
|
| - std::string input_file = argv[1];
|
| - std::string output_file = argv[2];
|
| -
|
| - uint32_t ssrc_filter = 0;
|
| - if (!FLAGS_ssrc.empty())
|
| - RTC_CHECK(ParseSsrc(FLAGS_ssrc, &ssrc_filter))
|
| - << "Flag verification has failed.";
|
| -
|
| - webrtc::rtclog::EventStream event_stream;
|
| - if (!webrtc::RtcEventLog::ParseRtcEventLog(input_file, &event_stream)) {
|
| - std::cerr << "Error while parsing input file: " << input_file << std::endl;
|
| - return -1;
|
| - }
|
| -
|
| - rtc::scoped_ptr<webrtc::test::RtpFileWriter> rtp_writer(
|
| - webrtc::test::RtpFileWriter::Create(
|
| - webrtc::test::RtpFileWriter::FileFormat::kRtpDump, output_file));
|
| -
|
| - if (!rtp_writer.get()) {
|
| - std::cerr << "Error while opening output file: " << output_file
|
| - << std::endl;
|
| - return -1;
|
| - }
|
| -
|
| - std::cout << "Found " << event_stream.stream_size()
|
| - << " events in the input file." << std::endl;
|
| - int rtp_counter = 0, rtcp_counter = 0;
|
| - bool header_only = false;
|
| - // TODO(ivoc): This can be refactored once the packet interpretation
|
| - // functions are finished.
|
| - for (int i = 0; i < event_stream.stream_size(); i++) {
|
| - const webrtc::rtclog::Event& event = event_stream.stream(i);
|
| - if (!FLAGS_nortp && event.has_type() && event.type() == event.RTP_EVENT) {
|
| - if (event.has_timestamp_us() && event.has_rtp_packet() &&
|
| - event.rtp_packet().has_header() &&
|
| - event.rtp_packet().header().size() >= 12 &&
|
| - event.rtp_packet().has_packet_length() &&
|
| - event.rtp_packet().has_type()) {
|
| - const webrtc::rtclog::RtpPacket& rtp_packet = event.rtp_packet();
|
| - if (FLAGS_noaudio && rtp_packet.type() == webrtc::rtclog::AUDIO)
|
| - continue;
|
| - if (FLAGS_novideo && rtp_packet.type() == webrtc::rtclog::VIDEO)
|
| - continue;
|
| - if (FLAGS_nodata && rtp_packet.type() == webrtc::rtclog::DATA)
|
| - continue;
|
| - if (!FLAGS_ssrc.empty()) {
|
| - const uint32_t packet_ssrc =
|
| - webrtc::ByteReader<uint32_t>::ReadBigEndian(
|
| - reinterpret_cast<const uint8_t*>(rtp_packet.header().data() +
|
| - 8));
|
| - if (packet_ssrc != ssrc_filter)
|
| - continue;
|
| - }
|
| -
|
| - webrtc::test::RtpPacket packet;
|
| - packet.length = rtp_packet.header().size();
|
| - if (packet.length > packet.kMaxPacketBufferSize) {
|
| - std::cout << "Skipping packet with size " << packet.length
|
| - << ", the maximum supported size is "
|
| - << packet.kMaxPacketBufferSize << std::endl;
|
| - continue;
|
| - }
|
| - packet.original_length = rtp_packet.packet_length();
|
| - if (packet.original_length > packet.length)
|
| - header_only = true;
|
| - packet.time_ms = event.timestamp_us() / 1000;
|
| - memcpy(packet.data, rtp_packet.header().data(), packet.length);
|
| - rtp_writer->WritePacket(&packet);
|
| - rtp_counter++;
|
| - } else {
|
| - std::cout << "Skipping malformed event." << std::endl;
|
| - }
|
| - }
|
| - if (!FLAGS_nortcp && event.has_type() && event.type() == event.RTCP_EVENT) {
|
| - if (event.has_timestamp_us() && event.has_rtcp_packet() &&
|
| - event.rtcp_packet().has_type() &&
|
| - event.rtcp_packet().has_packet_data() &&
|
| - event.rtcp_packet().packet_data().size() > 0) {
|
| - const webrtc::rtclog::RtcpPacket& rtcp_packet = event.rtcp_packet();
|
| - if (FLAGS_noaudio && rtcp_packet.type() == webrtc::rtclog::AUDIO)
|
| - continue;
|
| - if (FLAGS_novideo && rtcp_packet.type() == webrtc::rtclog::VIDEO)
|
| - continue;
|
| - if (FLAGS_nodata && rtcp_packet.type() == webrtc::rtclog::DATA)
|
| - continue;
|
| - if (!FLAGS_ssrc.empty()) {
|
| - const uint32_t packet_ssrc =
|
| - webrtc::ByteReader<uint32_t>::ReadBigEndian(
|
| - reinterpret_cast<const uint8_t*>(
|
| - rtcp_packet.packet_data().data() + 4));
|
| - if (packet_ssrc != ssrc_filter)
|
| - continue;
|
| - }
|
| -
|
| - webrtc::test::RtpPacket packet;
|
| - packet.length = rtcp_packet.packet_data().size();
|
| - if (packet.length > packet.kMaxPacketBufferSize) {
|
| - std::cout << "Skipping packet with size " << packet.length
|
| - << ", the maximum supported size is "
|
| - << packet.kMaxPacketBufferSize << std::endl;
|
| - continue;
|
| - }
|
| - // For RTCP packets the original_length should be set to 0 in the
|
| - // RTPdump format.
|
| - packet.original_length = 0;
|
| - packet.time_ms = event.timestamp_us() / 1000;
|
| - memcpy(packet.data, rtcp_packet.packet_data().data(), packet.length);
|
| - rtp_writer->WritePacket(&packet);
|
| - rtcp_counter++;
|
| - } else {
|
| - std::cout << "Skipping malformed event." << std::endl;
|
| - }
|
| - }
|
| - }
|
| - std::cout << "Wrote " << rtp_counter << (header_only ? " header-only" : "")
|
| - << " RTP packets and " << rtcp_counter << " RTCP packets to the "
|
| - << "output file." << std::endl;
|
| - return 0;
|
| -}
|
|
|