| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| 11 #include "webrtc/logging/rtc_event_log/rtc_event_log_parser.h" | 11 #include "webrtc/logging/rtc_event_log/rtc_event_log_parser.h" |
| 12 | 12 |
| 13 #include <stdint.h> | 13 #include <stdint.h> |
| 14 #include <string.h> | 14 #include <string.h> |
| 15 | 15 |
| 16 #include <algorithm> | 16 #include <algorithm> |
| 17 #include <fstream> | 17 #include <fstream> |
| 18 #include <istream> | 18 #include <istream> |
| 19 #include <map> | 19 #include <map> |
| 20 #include <utility> | 20 #include <utility> |
| 21 | 21 |
| 22 #include "webrtc/base/checks.h" | 22 #include "webrtc/base/checks.h" |
| 23 #include "webrtc/base/logging.h" | 23 #include "webrtc/base/logging.h" |
| 24 #include "webrtc/base/protobuf_utils.h" | 24 #include "webrtc/base/protobuf_utils.h" |
| 25 #include "webrtc/call/call.h" | |
| 26 #include "webrtc/logging/rtc_event_log/rtc_event_log.h" | 25 #include "webrtc/logging/rtc_event_log/rtc_event_log.h" |
| 27 #include "webrtc/modules/audio_coding/audio_network_adaptor/include/audio_networ
k_adaptor.h" | 26 #include "webrtc/modules/audio_coding/audio_network_adaptor/include/audio_networ
k_adaptor.h" |
| 28 #include "webrtc/modules/remote_bitrate_estimator/include/bwe_defines.h" | 27 #include "webrtc/modules/remote_bitrate_estimator/include/bwe_defines.h" |
| 29 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" | 28 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" |
| 30 | 29 |
| 31 namespace webrtc { | 30 namespace webrtc { |
| 32 | 31 |
| 33 namespace { | 32 namespace { |
| 34 MediaType GetRuntimeMediaType(rtclog::MediaType media_type) { | |
| 35 switch (media_type) { | |
| 36 case rtclog::MediaType::ANY: | |
| 37 return MediaType::ANY; | |
| 38 case rtclog::MediaType::AUDIO: | |
| 39 return MediaType::AUDIO; | |
| 40 case rtclog::MediaType::VIDEO: | |
| 41 return MediaType::VIDEO; | |
| 42 case rtclog::MediaType::DATA: | |
| 43 return MediaType::DATA; | |
| 44 } | |
| 45 RTC_NOTREACHED(); | |
| 46 return MediaType::ANY; | |
| 47 } | |
| 48 | |
| 49 RtcpMode GetRuntimeRtcpMode(rtclog::VideoReceiveConfig::RtcpMode rtcp_mode) { | 33 RtcpMode GetRuntimeRtcpMode(rtclog::VideoReceiveConfig::RtcpMode rtcp_mode) { |
| 50 switch (rtcp_mode) { | 34 switch (rtcp_mode) { |
| 51 case rtclog::VideoReceiveConfig::RTCP_COMPOUND: | 35 case rtclog::VideoReceiveConfig::RTCP_COMPOUND: |
| 52 return RtcpMode::kCompound; | 36 return RtcpMode::kCompound; |
| 53 case rtclog::VideoReceiveConfig::RTCP_REDUCEDSIZE: | 37 case rtclog::VideoReceiveConfig::RTCP_REDUCEDSIZE: |
| 54 return RtcpMode::kReducedSize; | 38 return RtcpMode::kReducedSize; |
| 55 } | 39 } |
| 56 RTC_NOTREACHED(); | 40 RTC_NOTREACHED(); |
| 57 return RtcpMode::kOff; | 41 return RtcpMode::kOff; |
| 58 } | 42 } |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 | 156 |
| 173 while (1) { | 157 while (1) { |
| 174 // Check whether we have reached end of file. | 158 // Check whether we have reached end of file. |
| 175 stream.peek(); | 159 stream.peek(); |
| 176 if (stream.eof()) { | 160 if (stream.eof()) { |
| 177 return true; | 161 return true; |
| 178 } | 162 } |
| 179 | 163 |
| 180 // Read the next message tag. The tag number is defined as | 164 // Read the next message tag. The tag number is defined as |
| 181 // (fieldnumber << 3) | wire_type. In our case, the field number is | 165 // (fieldnumber << 3) | wire_type. In our case, the field number is |
| 182 // supposed to be 1 and the wire type for an length-delimited field is 2. | 166 // supposed to be 1 and the wire type for an |
| 167 // length-deli"../call:call_interfaces",mited field is 2. |
| 183 const uint64_t kExpectedTag = (1 << 3) | 2; | 168 const uint64_t kExpectedTag = (1 << 3) | 2; |
| 184 std::tie(tag, success) = ParseVarInt(stream); | 169 std::tie(tag, success) = ParseVarInt(stream); |
| 185 if (!success) { | 170 if (!success) { |
| 186 LOG(LS_WARNING) << "Missing field tag from beginning of protobuf event."; | 171 LOG(LS_WARNING) << "Missing field tag from beginning of protobuf event."; |
| 187 return false; | 172 return false; |
| 188 } else if (tag != kExpectedTag) { | 173 } else if (tag != kExpectedTag) { |
| 189 LOG(LS_WARNING) << "Unexpected field tag at beginning of protobuf event."; | 174 LOG(LS_WARNING) << "Unexpected field tag at beginning of protobuf event."; |
| 190 return false; | 175 return false; |
| 191 } | 176 } |
| 192 | 177 |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 232 size_t index) const { | 217 size_t index) const { |
| 233 RTC_CHECK_LT(index, GetNumberOfEvents()); | 218 RTC_CHECK_LT(index, GetNumberOfEvents()); |
| 234 const rtclog::Event& event = events_[index]; | 219 const rtclog::Event& event = events_[index]; |
| 235 RTC_CHECK(event.has_type()); | 220 RTC_CHECK(event.has_type()); |
| 236 return GetRuntimeEventType(event.type()); | 221 return GetRuntimeEventType(event.type()); |
| 237 } | 222 } |
| 238 | 223 |
| 239 // The header must have space for at least IP_PACKET_SIZE bytes. | 224 // The header must have space for at least IP_PACKET_SIZE bytes. |
| 240 void ParsedRtcEventLog::GetRtpHeader(size_t index, | 225 void ParsedRtcEventLog::GetRtpHeader(size_t index, |
| 241 PacketDirection* incoming, | 226 PacketDirection* incoming, |
| 242 MediaType* media_type, | |
| 243 uint8_t* header, | 227 uint8_t* header, |
| 244 size_t* header_length, | 228 size_t* header_length, |
| 245 size_t* total_length) const { | 229 size_t* total_length) const { |
| 246 RTC_CHECK_LT(index, GetNumberOfEvents()); | 230 RTC_CHECK_LT(index, GetNumberOfEvents()); |
| 247 const rtclog::Event& event = events_[index]; | 231 const rtclog::Event& event = events_[index]; |
| 248 RTC_CHECK(event.has_type()); | 232 RTC_CHECK(event.has_type()); |
| 249 RTC_CHECK_EQ(event.type(), rtclog::Event::RTP_EVENT); | 233 RTC_CHECK_EQ(event.type(), rtclog::Event::RTP_EVENT); |
| 250 RTC_CHECK(event.has_rtp_packet()); | 234 RTC_CHECK(event.has_rtp_packet()); |
| 251 const rtclog::RtpPacket& rtp_packet = event.rtp_packet(); | 235 const rtclog::RtpPacket& rtp_packet = event.rtp_packet(); |
| 252 // Get direction of packet. | 236 // Get direction of packet. |
| 253 RTC_CHECK(rtp_packet.has_incoming()); | 237 RTC_CHECK(rtp_packet.has_incoming()); |
| 254 if (incoming != nullptr) { | 238 if (incoming != nullptr) { |
| 255 *incoming = rtp_packet.incoming() ? kIncomingPacket : kOutgoingPacket; | 239 *incoming = rtp_packet.incoming() ? kIncomingPacket : kOutgoingPacket; |
| 256 } | 240 } |
| 257 // Get media type. | |
| 258 RTC_CHECK(rtp_packet.has_type()); | |
| 259 if (media_type != nullptr) { | |
| 260 *media_type = GetRuntimeMediaType(rtp_packet.type()); | |
| 261 } | |
| 262 // Get packet length. | 241 // Get packet length. |
| 263 RTC_CHECK(rtp_packet.has_packet_length()); | 242 RTC_CHECK(rtp_packet.has_packet_length()); |
| 264 if (total_length != nullptr) { | 243 if (total_length != nullptr) { |
| 265 *total_length = rtp_packet.packet_length(); | 244 *total_length = rtp_packet.packet_length(); |
| 266 } | 245 } |
| 267 // Get header length. | 246 // Get header length. |
| 268 RTC_CHECK(rtp_packet.has_header()); | 247 RTC_CHECK(rtp_packet.has_header()); |
| 269 if (header_length != nullptr) { | 248 if (header_length != nullptr) { |
| 270 *header_length = rtp_packet.header().size(); | 249 *header_length = rtp_packet.header().size(); |
| 271 } | 250 } |
| 272 // Get header contents. | 251 // Get header contents. |
| 273 if (header != nullptr) { | 252 if (header != nullptr) { |
| 274 const size_t kMinRtpHeaderSize = 12; | 253 const size_t kMinRtpHeaderSize = 12; |
| 275 RTC_CHECK_GE(rtp_packet.header().size(), kMinRtpHeaderSize); | 254 RTC_CHECK_GE(rtp_packet.header().size(), kMinRtpHeaderSize); |
| 276 RTC_CHECK_LE(rtp_packet.header().size(), | 255 RTC_CHECK_LE(rtp_packet.header().size(), |
| 277 static_cast<size_t>(IP_PACKET_SIZE)); | 256 static_cast<size_t>(IP_PACKET_SIZE)); |
| 278 memcpy(header, rtp_packet.header().data(), rtp_packet.header().size()); | 257 memcpy(header, rtp_packet.header().data(), rtp_packet.header().size()); |
| 279 } | 258 } |
| 280 } | 259 } |
| 281 | 260 |
| 282 // The packet must have space for at least IP_PACKET_SIZE bytes. | 261 // The packet must have space for at least IP_PACKET_SIZE bytes. |
| 283 void ParsedRtcEventLog::GetRtcpPacket(size_t index, | 262 void ParsedRtcEventLog::GetRtcpPacket(size_t index, |
| 284 PacketDirection* incoming, | 263 PacketDirection* incoming, |
| 285 MediaType* media_type, | |
| 286 uint8_t* packet, | 264 uint8_t* packet, |
| 287 size_t* length) const { | 265 size_t* length) const { |
| 288 RTC_CHECK_LT(index, GetNumberOfEvents()); | 266 RTC_CHECK_LT(index, GetNumberOfEvents()); |
| 289 const rtclog::Event& event = events_[index]; | 267 const rtclog::Event& event = events_[index]; |
| 290 RTC_CHECK(event.has_type()); | 268 RTC_CHECK(event.has_type()); |
| 291 RTC_CHECK_EQ(event.type(), rtclog::Event::RTCP_EVENT); | 269 RTC_CHECK_EQ(event.type(), rtclog::Event::RTCP_EVENT); |
| 292 RTC_CHECK(event.has_rtcp_packet()); | 270 RTC_CHECK(event.has_rtcp_packet()); |
| 293 const rtclog::RtcpPacket& rtcp_packet = event.rtcp_packet(); | 271 const rtclog::RtcpPacket& rtcp_packet = event.rtcp_packet(); |
| 294 // Get direction of packet. | 272 // Get direction of packet. |
| 295 RTC_CHECK(rtcp_packet.has_incoming()); | 273 RTC_CHECK(rtcp_packet.has_incoming()); |
| 296 if (incoming != nullptr) { | 274 if (incoming != nullptr) { |
| 297 *incoming = rtcp_packet.incoming() ? kIncomingPacket : kOutgoingPacket; | 275 *incoming = rtcp_packet.incoming() ? kIncomingPacket : kOutgoingPacket; |
| 298 } | 276 } |
| 299 // Get media type. | |
| 300 RTC_CHECK(rtcp_packet.has_type()); | |
| 301 if (media_type != nullptr) { | |
| 302 *media_type = GetRuntimeMediaType(rtcp_packet.type()); | |
| 303 } | |
| 304 // Get packet length. | 277 // Get packet length. |
| 305 RTC_CHECK(rtcp_packet.has_packet_data()); | 278 RTC_CHECK(rtcp_packet.has_packet_data()); |
| 306 if (length != nullptr) { | 279 if (length != nullptr) { |
| 307 *length = rtcp_packet.packet_data().size(); | 280 *length = rtcp_packet.packet_data().size(); |
| 308 } | 281 } |
| 309 // Get packet contents. | 282 // Get packet contents. |
| 310 if (packet != nullptr) { | 283 if (packet != nullptr) { |
| 311 RTC_CHECK_LE(rtcp_packet.packet_data().size(), | 284 RTC_CHECK_LE(rtcp_packet.packet_data().size(), |
| 312 static_cast<unsigned>(IP_PACKET_SIZE)); | 285 static_cast<unsigned>(IP_PACKET_SIZE)); |
| 313 memcpy(packet, rtcp_packet.packet_data().data(), | 286 memcpy(packet, rtcp_packet.packet_data().data(), |
| (...skipping 268 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 582 rtc::Optional<ProbeFailureReason>(kInvalidSendReceiveRatio); | 555 rtc::Optional<ProbeFailureReason>(kInvalidSendReceiveRatio); |
| 583 } else if (pr_event.result() == rtclog::BweProbeResult::TIMEOUT) { | 556 } else if (pr_event.result() == rtclog::BweProbeResult::TIMEOUT) { |
| 584 res.failure_reason = rtc::Optional<ProbeFailureReason>(kTimeout); | 557 res.failure_reason = rtc::Optional<ProbeFailureReason>(kTimeout); |
| 585 } else { | 558 } else { |
| 586 RTC_NOTREACHED(); | 559 RTC_NOTREACHED(); |
| 587 } | 560 } |
| 588 | 561 |
| 589 return res; | 562 return res; |
| 590 } | 563 } |
| 591 } // namespace webrtc | 564 } // namespace webrtc |
| OLD | NEW |