Integrate VDA with WebRTC.

content/renderer/media/media_stream_dependency_factory.cc

 // Copyright (c) 2012 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 "content/renderer/media/media_stream_dependency_factory.h"
 
 #include <vector>
 
 #include "base/command_line.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/utf_string_conversions.h"
 #include "content/public/common/content_switches.h"
 #include "content/renderer/media/media_stream_source_extra_data.h"
+#include "content/renderer/media/renderer_gpu_video_decoder_factories.h"
 #include "content/renderer/media/rtc_media_constraints.h"
 #include "content/renderer/media/rtc_peer_connection_handler.h"
 #include "content/renderer/media/rtc_video_capturer.h"
+#include "content/renderer/media/rtc_video_decoder_factory.h"
 #include "content/renderer/media/video_capture_impl_manager.h"
 #include "content/renderer/media/webaudio_capturer_source.h"
 #include "content/renderer/media/webrtc_audio_device_impl.h"
 #include "content/renderer/media/webrtc_local_audio_track.h"
 #include "content/renderer/media/webrtc_logging_handler_impl.h"
 #include "content/renderer/media/webrtc_logging_message_filter.h"
 #include "content/renderer/media/webrtc_uma_histograms.h"
 #include "content/renderer/p2p/ipc_network_manager.h"
 #include "content/renderer/p2p/ipc_socket_factory.h"
 #include "content/renderer/p2p/port_allocator.h"
@@ skipping 445 matching lines @@
   return type == WebKit::WebMediaStreamSource::TypeAudio ?
       native_stream->RemoveTrack(native_stream->FindAudioTrack(track_id)) :
       native_stream->RemoveTrack(native_stream->FindVideoTrack(track_id));
 }
 
 bool MediaStreamDependencyFactory::CreatePeerConnectionFactory() {
   DVLOG(1) << "MediaStreamDependencyFactory::CreatePeerConnectionFactory()";
   if (!pc_factory_) {
     DCHECK(!audio_device_);
     audio_device_ = new WebRtcAudioDeviceImpl();
+
+    const CommandLine* cmd_line = CommandLine::ForCurrentProcess();
+    scoped_ptr<RTCVideoDecoderFactory> decoder_factory;
+    scoped_refptr<content::RendererGpuVideoDecoderFactories> gpu_factories;
+    if (cmd_line->HasSwitch(switches::kEnableWebRTCHWDecoding)) {
+      scoped_ptr<base::Thread> vda_thread(new base::Thread("VDA_thread"));
+      if (vda_thread->Start()) {
+        gpu_factories = RenderThreadImpl::current()->GetGpuFactories(
+            vda_thread->message_loop_proxy());
+      } else {
+        LOG(ERROR) << "Could not start VDA thread";
+      }
+      if (gpu_factories != NULL) {
+        decoder_factory.reset(
+            new RTCVideoDecoderFactory(gpu_factories, vda_thread.Pass()));
+      }
+    }
+
     scoped_refptr<webrtc::PeerConnectionFactoryInterface> factory(
         webrtc::CreatePeerConnectionFactory(
-            worker_thread_, signaling_thread_, audio_device_, NULL, NULL));
+            worker_thread_, signaling_thread_, audio_device_, NULL,
+            decoder_factory.release()));
     if (factory)
       pc_factory_ = factory;
     else
       audio_device_ = NULL;
   }
   return pc_factory_.get() != NULL;
 }
 
 bool MediaStreamDependencyFactory::PeerConnectionFactoryCreated() {
   return pc_factory_.get() != NULL;
@@ skipping 299 matching lines @@
 void MediaStreamDependencyFactory::CreateWebRtcLoggingHandler(
     WebRtcLoggingMessageFilter* filter,
     const std::string& app_session_id,
     const std::string& app_url) {
   WebRtcLoggingHandlerImpl* handler =
       new WebRtcLoggingHandlerImpl(filter->io_message_loop());
   filter->InitLogging(handler, app_session_id, app_url);
 }
 
 }  // namespace content