Deliver video frames on libjingle worker thread to WebRtcVideoCapturerAdapter.

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/strings/utf_string_conversions.h"
@@ skipping 220 matching lines @@
 }
 
 WebRtcVideoCapturerAdapter* MediaStreamDependencyFactory::CreateVideoCapturer(
     bool is_screeencast) {
   // We need to make sure the libjingle thread wrappers have been created
   // before we can use an instance of a WebRtcVideoCapturerAdapter. This is
   // since the base class of WebRtcVideoCapturerAdapter is a
   // cricket::VideoCapturer and it uses the libjingle thread wrappers.
   if (!GetPcFactory())
     return NULL;
-  return new WebRtcVideoCapturerAdapter(is_screeencast);
+  return new WebRtcVideoCapturerAdapter(GetWebRtcWorkerThread(),
+                                        is_screeencast);
 }
 
 scoped_refptr<webrtc::VideoSourceInterface>
 MediaStreamDependencyFactory::CreateVideoSource(
     cricket::VideoCapturer* capturer,
     const blink::WebMediaConstraints& constraints) {
   RTCMediaConstraints webrtc_constraints(constraints);
   scoped_refptr<webrtc::VideoSourceInterface> source =
       GetPcFactory()->CreateVideoSource(capturer, &webrtc_constraints).get();
   return source;
@@ skipping 342 matching lines @@
             webkit_track.source().type());
   blink::WebMediaStreamTrack track = webkit_track;
 
   DVLOG(1) << "AddNativeTrackToBlinkTrack() audio";
   track.setExtraData(
       new MediaStreamTrack(
           static_cast<webrtc::AudioTrackInterface*>(native_track),
           is_local_track));
 }
 
+scoped_refptr<base::MessageLoopProxy>
+MediaStreamDependencyFactory::GetWebRtcWorkerThread() const {
+  DCHECK(CalledOnValidThread());
+  return chrome_worker_thread_.message_loop_proxy();
+}
+
 bool MediaStreamDependencyFactory::OnControlMessageReceived(
     const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(MediaStreamDependencyFactory, message)
     IPC_MESSAGE_HANDLER(MediaStreamMsg_EnableAecDump, OnAecDumpFile)
     IPC_MESSAGE_HANDLER(MediaStreamMsg_DisableAecDump, OnDisableAecDump)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
@@ skipping 40 matching lines @@
 }
 
 void MediaStreamDependencyFactory::EnsureWebRtcAudioDeviceImpl() {
   if (audio_device_)
     return;
 
   audio_device_ = new WebRtcAudioDeviceImpl();
 }
 
 }  // namespace content