OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 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/video/send_statistics_proxy.h" | 11 #include "webrtc/video/send_statistics_proxy.h" |
12 | 12 |
13 #include <algorithm> | 13 #include <algorithm> |
14 #include <cmath> | 14 #include <cmath> |
15 #include <map> | 15 #include <map> |
16 #include <vector> | 16 #include <vector> |
17 | 17 |
18 #include "webrtc/base/checks.h" | 18 #include "webrtc/base/checks.h" |
19 #include "webrtc/base/logging.h" | 19 #include "webrtc/base/logging.h" |
| 20 #include "webrtc/modules/video_coding/include/video_codec_interface.h" |
20 #include "webrtc/system_wrappers/include/metrics.h" | 21 #include "webrtc/system_wrappers/include/metrics.h" |
21 | 22 |
22 namespace webrtc { | 23 namespace webrtc { |
23 namespace { | 24 namespace { |
24 const float kEncodeTimeWeigthFactor = 0.5f; | 25 const float kEncodeTimeWeigthFactor = 0.5f; |
25 | 26 |
26 // Used by histograms. Values of entries should not be changed. | 27 // Used by histograms. Values of entries should not be changed. |
27 enum HistogramCodecType { | 28 enum HistogramCodecType { |
28 kVideoUnknown = 0, | 29 kVideoUnknown = 0, |
29 kVideoVp8 = 1, | 30 kVideoVp8 = 1, |
(...skipping 389 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
419 stats->width = 0; | 420 stats->width = 0; |
420 } | 421 } |
421 | 422 |
422 void SendStatisticsProxy::OnSetRates(uint32_t bitrate_bps, int framerate) { | 423 void SendStatisticsProxy::OnSetRates(uint32_t bitrate_bps, int framerate) { |
423 rtc::CritScope lock(&crit_); | 424 rtc::CritScope lock(&crit_); |
424 stats_.target_media_bitrate_bps = bitrate_bps; | 425 stats_.target_media_bitrate_bps = bitrate_bps; |
425 } | 426 } |
426 | 427 |
427 void SendStatisticsProxy::OnSendEncodedImage( | 428 void SendStatisticsProxy::OnSendEncodedImage( |
428 const EncodedImage& encoded_image, | 429 const EncodedImage& encoded_image, |
429 const RTPVideoHeader* rtp_video_header) { | 430 const CodecSpecificInfo* codec_info) { |
430 size_t simulcast_idx = rtp_video_header ? rtp_video_header->simulcastIdx : 0; | 431 size_t simulcast_idx = 0; |
| 432 |
| 433 if (codec_info) { |
| 434 if (codec_info->codecType == kVideoCodecVP8) { |
| 435 simulcast_idx = codec_info->codecSpecific.VP8.simulcastIdx; |
| 436 } else if (codec_info->codecType == kVideoCodecGeneric) { |
| 437 simulcast_idx = codec_info->codecSpecific.generic.simulcast_idx; |
| 438 } |
| 439 } |
| 440 |
431 if (simulcast_idx >= config_.rtp.ssrcs.size()) { | 441 if (simulcast_idx >= config_.rtp.ssrcs.size()) { |
432 LOG(LS_ERROR) << "Encoded image outside simulcast range (" << simulcast_idx | 442 LOG(LS_ERROR) << "Encoded image outside simulcast range (" << simulcast_idx |
433 << " >= " << config_.rtp.ssrcs.size() << ")."; | 443 << " >= " << config_.rtp.ssrcs.size() << ")."; |
434 return; | 444 return; |
435 } | 445 } |
436 uint32_t ssrc = config_.rtp.ssrcs[simulcast_idx]; | 446 uint32_t ssrc = config_.rtp.ssrcs[simulcast_idx]; |
437 | 447 |
438 rtc::CritScope lock(&crit_); | 448 rtc::CritScope lock(&crit_); |
439 VideoSendStream::StreamStats* stats = GetStatsEntry(ssrc); | 449 VideoSendStream::StreamStats* stats = GetStatsEntry(ssrc); |
440 if (!stats) | 450 if (!stats) |
(...skipping 21 matching lines...) Expand all Loading... |
462 } | 472 } |
463 if (encoded_image.adapt_reason_.bw_resolutions_disabled != -1) { | 473 if (encoded_image.adapt_reason_.bw_resolutions_disabled != -1) { |
464 bool bw_limited = encoded_image.adapt_reason_.bw_resolutions_disabled > 0; | 474 bool bw_limited = encoded_image.adapt_reason_.bw_resolutions_disabled > 0; |
465 uma_container_->bw_limited_frame_counter_.Add(bw_limited); | 475 uma_container_->bw_limited_frame_counter_.Add(bw_limited); |
466 if (bw_limited) { | 476 if (bw_limited) { |
467 uma_container_->bw_resolutions_disabled_counter_.Add( | 477 uma_container_->bw_resolutions_disabled_counter_.Add( |
468 encoded_image.adapt_reason_.bw_resolutions_disabled); | 478 encoded_image.adapt_reason_.bw_resolutions_disabled); |
469 } | 479 } |
470 } | 480 } |
471 | 481 |
472 if (encoded_image.qp_ != -1 && rtp_video_header) { | 482 if (encoded_image.qp_ != -1 && codec_info) { |
473 if (rtp_video_header->codec == kRtpVideoVp8) { | 483 if (codec_info->codecType == kVideoCodecVP8) { |
474 int spatial_idx = (config_.rtp.ssrcs.size() == 1) | 484 int spatial_idx = (config_.rtp.ssrcs.size() == 1) |
475 ? -1 | 485 ? -1 |
476 : static_cast<int>(simulcast_idx); | 486 : static_cast<int>(simulcast_idx); |
477 uma_container_->qp_counters_[spatial_idx].vp8.Add(encoded_image.qp_); | 487 uma_container_->qp_counters_[spatial_idx].vp8.Add(encoded_image.qp_); |
478 } else if (rtp_video_header->codec == kRtpVideoVp9) { | 488 } else if (codec_info->codecType == kVideoCodecVP9) { |
479 int spatial_idx = | 489 int spatial_idx = (codec_info->codecSpecific.VP9.num_spatial_layers == 1) |
480 (rtp_video_header->codecHeader.VP9.num_spatial_layers == 1) | 490 ? -1 |
481 ? -1 | 491 : codec_info->codecSpecific.VP9.spatial_idx; |
482 : rtp_video_header->codecHeader.VP9.spatial_idx; | |
483 uma_container_->qp_counters_[spatial_idx].vp9.Add(encoded_image.qp_); | 492 uma_container_->qp_counters_[spatial_idx].vp9.Add(encoded_image.qp_); |
484 } | 493 } |
485 } | 494 } |
486 | 495 |
487 // TODO(asapersson): This is incorrect if simulcast layers are encoded on | 496 // TODO(asapersson): This is incorrect if simulcast layers are encoded on |
488 // different threads and there is no guarantee that one frame of all layers | 497 // different threads and there is no guarantee that one frame of all layers |
489 // are encoded before the next start. | 498 // are encoded before the next start. |
490 if (last_sent_frame_timestamp_ > 0 && | 499 if (last_sent_frame_timestamp_ > 0 && |
491 encoded_image._timeStamp != last_sent_frame_timestamp_) { | 500 encoded_image._timeStamp != last_sent_frame_timestamp_) { |
492 uma_container_->sent_frame_rate_tracker_.AddSamples(1); | 501 uma_container_->sent_frame_rate_tracker_.AddSamples(1); |
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
615 return Fraction(min_required_samples, 1000.0f); | 624 return Fraction(min_required_samples, 1000.0f); |
616 } | 625 } |
617 | 626 |
618 int SendStatisticsProxy::BoolSampleCounter::Fraction( | 627 int SendStatisticsProxy::BoolSampleCounter::Fraction( |
619 int min_required_samples, float multiplier) const { | 628 int min_required_samples, float multiplier) const { |
620 if (num_samples < min_required_samples || num_samples == 0) | 629 if (num_samples < min_required_samples || num_samples == 0) |
621 return -1; | 630 return -1; |
622 return static_cast<int>((sum * multiplier / num_samples) + 0.5f); | 631 return static_cast<int>((sum * multiplier / num_samples) + 0.5f); |
623 } | 632 } |
624 } // namespace webrtc | 633 } // namespace webrtc |
OLD | NEW |