[Chromecast] Add metrics for logging platform A/V bitrate estimates.

chromecast/media/cma/pipeline/video_pipeline_impl.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chromecast/media/cma/pipeline/video_pipeline_impl.h"
 
 #include <stddef.h>
 #include <utility>
 
 #include "base/bind.h"
+#include "base/time/time.h"
+#include "chromecast/base/metrics/cast_metrics_helper.h"
 #include "chromecast/media/cdm/browser_cdm_cast.h"
 #include "chromecast/media/cma/base/buffering_defs.h"
 #include "chromecast/media/cma/base/cma_logging.h"
 #include "chromecast/media/cma/base/coded_frame_provider.h"
 #include "chromecast/media/cma/base/decoder_config_adapter.h"
 #include "chromecast/media/cma/pipeline/av_pipeline_impl.h"
 #include "chromecast/public/graphics_types.h"
 #include "chromecast/public/media/decoder_config.h"
 #include "media/base/video_decoder_config.h"
 
 namespace chromecast {
 namespace media {
 
 namespace {
 const size_t kMaxVideoFrameSize = 1024 * 1024;
+
+void LogEstimatedVideoBitrate(int bitrate) {
+  CMALOG(kLogControl) << "Estimated video bitrate is " << bitrate << " kbps";
+  chromecast::metrics::CastMetricsHelper* metrics_helper =
+      chromecast::metrics::CastMetricsHelper::GetInstance();
+  metrics_helper->RecordSimpleActionWithValue("Cast.Platform.VideoBitrate",
+                                              bitrate);
+}
+
 }
 
 VideoPipelineImpl::VideoPipelineImpl(
     MediaPipelineBackend::VideoDecoder* decoder,
     const VideoPipelineClient& client)
     : AvPipelineImpl(decoder, client.av_pipeline_client),
       video_decoder_(decoder),
-      natural_size_changed_cb_(client.natural_size_changed_cb) {
+      natural_size_changed_cb_(client.natural_size_changed_cb),
+      last_sample_time_(base::Time()),
+      elapsed_time_delta_(base::TimeDelta()),
+      video_bytes_for_bitrate_estimation_(0) {
   DCHECK(video_decoder_);
 }
 
 VideoPipelineImpl::~VideoPipelineImpl() {
 }
 
 ::media::PipelineStatus VideoPipelineImpl::Initialize(
     const std::vector<::media::VideoDecoderConfig>& configs,
     scoped_ptr<CodedFrameProvider> frame_provider) {
   DCHECK_GT(configs.size(), 0u);
@@ skipping 66 matching lines @@
   current_stats.video_frames_dropped = video_stats.dropped_frames;
 
   ::media::PipelineStatistics delta_stats;
   delta_stats.video_bytes_decoded =
       current_stats.video_bytes_decoded - previous_stats_.video_bytes_decoded;
   delta_stats.video_frames_decoded =
       current_stats.video_frames_decoded - previous_stats_.video_frames_decoded;
   delta_stats.video_frames_dropped =
       current_stats.video_frames_dropped - previous_stats_.video_frames_dropped;
 
+  base::Time current_time = base::Time::Now();
+  elapsed_time_delta_ += current_time - last_sample_time_;
+  video_bytes_for_bitrate_estimation_ += delta_stats.video_bytes_decoded;
+
+  if (state() != kPlaying) {
+    // Invalidate any data that was collected in a window where we were not in
+    // the playing state.
+    elapsed_time_delta_ = base::TimeDelta::FromSeconds(0);
+    video_bytes_for_bitrate_estimation_ = 0;
+  } else if (elapsed_time_delta_.InMilliseconds() > 5000) {
+    int estimated_bitrate_in_kbps = 8 * video_bytes_for_bitrate_estimation_ /
+                                    elapsed_time_delta_.InMilliseconds();
+    if (estimated_bitrate_in_kbps > 0) {
+      LogEstimatedVideoBitrate(estimated_bitrate_in_kbps);
+    }
+    elapsed_time_delta_ = base::TimeDelta::FromSeconds(0);
+    video_bytes_for_bitrate_estimation_ = 0;
+  }
+  last_sample_time_ = current_time;
   previous_stats_ = current_stats;
 
   client().statistics_cb.Run(delta_stats);
 }
 
 }  // namespace media
 }  // namespace chromecast