Extended proxy abstraction, to call certain methods to the worker thread.

webrtc/api/videocapturertracksource.cc

 /*
  *  Copyright 2012 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 268 matching lines @@
       new rtc::RefCountedObject<VideoCapturerTrackSource>(worker_thread,
                                                           capturer, remote));
   source->Initialize(nullptr);
   return source;
 }
 
 VideoCapturerTrackSource::VideoCapturerTrackSource(
     rtc::Thread* worker_thread,
     cricket::VideoCapturer* capturer,
     bool remote)
-    : VideoTrackSource(capturer, worker_thread, remote),
+    : VideoTrackSource(capturer, remote),
       signaling_thread_(rtc::Thread::Current()),
+      worker_thread_(worker_thread),
       video_capturer_(capturer),
       started_(false) {
   video_capturer_->SignalStateChange.connect(
       this, &VideoCapturerTrackSource::OnStateChange);
 }
 
 VideoCapturerTrackSource::~VideoCapturerTrackSource() {
   video_capturer_->SignalStateChange.disconnect(this);
   Stop();
 }
@@ skipping 42 matching lines @@
   if (!ExtractOption(constraints, MediaConstraintsInterface::kNoiseReduction,
                      &needs_denoising_)) {
     LOG(LS_WARNING) << "Invalid mandatory value for"
                     << MediaConstraintsInterface::kNoiseReduction;
     SetState(kEnded);
     return;
   }
 
   format_ = GetBestCaptureFormat(formats);
   // Start the camera with our best guess.
-  if (!worker_thread()->Invoke<bool>(
+  if (!worker_thread_->Invoke<bool>(
           rtc::Bind(&cricket::VideoCapturer::StartCapturing,
                     video_capturer_.get(), format_))) {
     SetState(kEnded);
     return;
   }
   started_ = true;
   // Initialize hasn't succeeded until a successful state change has occurred.
 }
 
 bool VideoCapturerTrackSource::GetStats(Stats* stats) {
   return video_capturer_->GetInputSize(&stats->input_width,
                                        &stats->input_height);
 }
 
 void VideoCapturerTrackSource::Stop() {
   if (!started_) {
     return;
   }
   started_ = false;
-  worker_thread()->Invoke<void>(
+  worker_thread_->Invoke<void>(
       rtc::Bind(&cricket::VideoCapturer::Stop, video_capturer_.get()));
 }
 
 void VideoCapturerTrackSource::Restart() {
   if (started_) {
     return;
   }
-  if (!worker_thread()->Invoke<bool>(
+  if (!worker_thread_->Invoke<bool>(
           rtc::Bind(&cricket::VideoCapturer::StartCapturing,
                     video_capturer_.get(), format_))) {
     SetState(kEnded);
     return;
   }
   started_ = true;
 }
 
 // OnStateChange listens to the cricket::VideoCapturer::SignalStateChange.
 void VideoCapturerTrackSource::OnStateChange(
     cricket::VideoCapturer* capturer,
     cricket::CaptureState capture_state) {
   if (rtc::Thread::Current() != signaling_thread_) {
     invoker_.AsyncInvoke<void>(
         signaling_thread_, rtc::Bind(&VideoCapturerTrackSource::OnStateChange,
                                      this, capturer, capture_state));
     return;
   }
 
   if (capturer == video_capturer_.get()) {
     SetState(GetReadyState(capture_state));
   }
 }
 
 }  // namespace webrtc