Cast: Add GetStats() extensions API.

chrome/renderer/media/cast_session_delegate.cc

 // Copyright 2013 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 "chrome/renderer/media/cast_session_delegate.h"
 
 #include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "chrome/renderer/media/cast_threads.h"
 #include "chrome/renderer/media/cast_transport_sender_ipc.h"
 #include "content/public/renderer/render_thread.h"
 #include "media/cast/cast_config.h"
 #include "media/cast/cast_environment.h"
 #include "media/cast/cast_sender.h"
 #include "media/cast/logging/encoding_event_subscriber.h"
 #include "media/cast/logging/log_serializer.h"
 #include "media/cast/logging/logging_defines.h"
+#include "media/cast/logging/stats_converter.h"
 #include "media/cast/transport/cast_transport_config.h"
 #include "media/cast/transport/cast_transport_sender.h"
 
 using media::cast::AudioSenderConfig;
 using media::cast::CastEnvironment;
 using media::cast::CastSender;
 using media::cast::VideoSenderConfig;
 
 static base::LazyInstance<CastThreads> g_cast_threads =
     LAZY_INSTANCE_INITIALIZER;
@@ skipping 146 matching lines @@
     return;
   }
 
   scoped_ptr<std::string> serialized_log =
       log_serializer.GetSerializedLogAndReset();
   DVLOG(2) << "Serialized log length: " << serialized_log->size();
 
   callback.Run(serialized_log.Pass());
 }
 
+void CastSessionDelegate::GetStatsAndReset(bool is_audio,
+                                           const StatsCallback& callback) {
+  media::cast::FrameStatsMap frame_stats =
+      cast_environment_->Logging()->GetFrameStatsData(
+          is_audio ? media::cast::AUDIO_EVENT : media::cast::VIDEO_EVENT);
+  media::cast::PacketStatsMap packet_stats =
+      cast_environment_->Logging()->GetPacketStatsData(
+          is_audio ? media::cast::AUDIO_EVENT : media::cast::VIDEO_EVENT);
+
+  scoped_ptr<base::DictionaryValue> stats = media::cast::ConvertStats(
+      frame_stats, packet_stats);
+
+  callback.Run(stats.Pass());
+}
+
 void CastSessionDelegate::StatusNotificationCB(
     media::cast::transport::CastTransportStatus unused_status) {
   DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
   // TODO(hubbe): Call javascript UDPTransport error function.
 }
 
 void CastSessionDelegate::StartSendingInternal() {
   DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
 
   // No transport, wait.
@@ skipping 48 matching lines @@
   if (result == media::cast::STATUS_INITIALIZED) {
     if (!audio_frame_input_available_callback_.is_null()) {
       audio_frame_input_available_callback_.Run(cast_sender_->frame_input());
     }
     if (!video_frame_input_available_callback_.is_null()) {
       video_frame_input_available_callback_.Run(cast_sender_->frame_input());
     }
   }
 }