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 |
new file mode 100644 |
index 0000000000000000000000000000000000000000..2882812df43e6abb48cb3f55f5806ba8d30a8ef0 |
--- /dev/null |
+++ b/webrtc/video/rtc_event_log2rtp_dump.cc |
@@ -0,0 +1,117 @@ |
+/* |
+ * 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 <string> |
+ |
+#include "gflags/gflags.h" |
+#include "webrtc/base/scoped_ptr.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 |
+ |
+DEFINE_bool(audio_only, |
hlundin-webrtc
2015/08/17 11:14:34
Feature request: Can you add a flag to store only
ivoc
2015/08/21 14:30:57
Done.
|
+ false, |
+ "Store only audio packets in the converted " |
+ "RTPdump file."); |
+DEFINE_bool(video_only, |
+ false, |
+ "Store only video packets in the converted " |
+ "RTPdump file."); |
+DEFINE_bool(data_only, |
+ false, |
+ "Store only data packets in the converted " |
+ "RTPdump file."); |
+ |
+// 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]; |
+ |
+ 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; |
+ // 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); |
hlundin-webrtc
2015/08/17 11:14:34
const auto& ? Or is the compiler unable to deduce
terelius
2015/08/17 11:39:06
Personally, I like being explicit with the types.
ivoc
2015/08/21 14:30:57
I tend to agree with terelius@ on this one, let me
hlundin-webrtc
2015/08/26 09:24:37
Acknowledged.
|
+ if (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().has_packet_length() && |
+ event.rtp_packet().has_type()) { |
+ if (FLAGS_audio_only && |
+ event.rtp_packet().type() != webrtc::rtclog::AUDIO) |
+ continue; |
+ if (FLAGS_video_only && |
+ event.rtp_packet().type() != webrtc::rtclog::VIDEO) |
+ continue; |
+ if (FLAGS_data_only && |
+ event.rtp_packet().type() != webrtc::rtclog::DATA) |
+ continue; |
+ webrtc::test::RtpPacket packet; |
+ packet.length = event.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 = event.rtp_packet().packet_length(); |
hlundin-webrtc
2015/08/17 11:14:33
I think it would be handy to know if the output is
ivoc
2015/08/21 14:30:57
Done.
|
+ packet.time_ms = event.timestamp_us() / 1000; |
+ memcpy(packet.data, event.rtp_packet().header().data(), packet.length); |
+ rtp_writer->WritePacket(&packet); |
+ rtp_counter++; |
+ } else { |
+ std::cout << "Skipping malformed event." << std::endl; |
+ } |
+ } |
+ } |
+ std::cout << "Wrote " << rtp_counter << " RTP packets to the output file." |
+ << std::endl; |
+ return 0; |
+} |