Implement a source for remote video tracks.

content/renderer/media/media_stream_video_track.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 "content/renderer/media/media_stream_video_track.h"
 
 #include "content/renderer/media/media_stream_dependency_factory.h"
-#include "content/renderer/media/webrtc/webrtc_video_sink_adapter.h"
 
 namespace content {
 
 //static
 blink::WebMediaStreamTrack MediaStreamVideoTrack::CreateVideoTrack(
     MediaStreamVideoSource* source,
     const blink::WebMediaConstraints& constraints,
     const MediaStreamVideoSource::ConstraintsCallback& callback,
     bool enabled,
     MediaStreamDependencyFactory* factory) {
@@ skipping 16 matching lines @@
 MediaStreamVideoTrack::MediaStreamVideoTrack(
     MediaStreamVideoSource* source,
     const blink::WebMediaConstraints& constraints,
     const MediaStreamVideoSource::ConstraintsCallback& callback,
     bool enabled,
     MediaStreamDependencyFactory* factory)
     : MediaStreamTrack(NULL, true),
       enabled_(enabled),
       source_(source),
       factory_(factory) {
-  // TODO(perkj): source can be NULL if this is actually a remote video track.
-  // Remove as soon as we only have one implementation of video tracks.
-  if (source)
-    source->AddTrack(this, constraints, callback);
+  source->AddTrack(this, constraints, callback);
 }
 
 MediaStreamVideoTrack::~MediaStreamVideoTrack() {
   DCHECK(sinks_.empty());
-  // TODO(perkj): source can be NULL if this is actually a remote video track.
-  // Remove as soon as we only have one implementation of video tracks.
-  if (source_)
-    source_->RemoveTrack(this);
+  source_->RemoveTrack(this);
 }
 
 void MediaStreamVideoTrack::AddSink(MediaStreamVideoSink* sink) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(std::find(sinks_.begin(), sinks_.end(), sink) == sinks_.end());
   sinks_.push_back(sink);
 }
 
 void MediaStreamVideoTrack::RemoveSink(MediaStreamVideoSink* sink) {
   DCHECK(thread_checker_.CalledOnValidThread());
@@ skipping 42 matching lines @@
 
 void MediaStreamVideoTrack::OnReadyStateChanged(
     blink::WebMediaStreamSource::ReadyState state) {
   DCHECK(thread_checker_.CalledOnValidThread());
   for (std::vector<MediaStreamVideoSink*>::iterator it = sinks_.begin();
        it != sinks_.end(); ++it) {
     (*it)->OnReadyStateChanged(state);
   }
 }
 
-// Wrapper which allows to use std::find_if() when adding and removing
-// sinks to/from |sinks_|.
-struct SinkWrapper {
-  explicit SinkWrapper(MediaStreamVideoSink* sink) : sink_(sink) {}
-  bool operator()(
-      const WebRtcVideoSinkAdapter* owner) {
-    return owner->sink() == sink_;
-  }
-  MediaStreamVideoSink* sink_;
-};
-
-WebRtcMediaStreamVideoTrack::WebRtcMediaStreamVideoTrack(
-    webrtc::VideoTrackInterface* track)
-    : MediaStreamVideoTrack(NULL,
-                            blink::WebMediaConstraints(),
-                            MediaStreamVideoSource::ConstraintsCallback(),
-                            track->enabled(),
-                            NULL) {
-  track_ = track;
-}
-
-WebRtcMediaStreamVideoTrack::~WebRtcMediaStreamVideoTrack() {
-}
-
-void WebRtcMediaStreamVideoTrack::AddSink(MediaStreamVideoSink* sink) {
-  DCHECK(thread_checker_.CalledOnValidThread());
-  DCHECK(std::find_if(sinks_.begin(), sinks_.end(),
-                      SinkWrapper(sink)) == sinks_.end());
-  sinks_.push_back(new WebRtcVideoSinkAdapter(GetVideoAdapter(), sink));
-}
-
-void WebRtcMediaStreamVideoTrack::RemoveSink(MediaStreamVideoSink* sink) {
-  DCHECK(thread_checker_.CalledOnValidThread());
-  ScopedVector<WebRtcVideoSinkAdapter>::iterator it =
-      std::find_if(sinks_.begin(), sinks_.end(), SinkWrapper(sink));
-  DCHECK(it != sinks_.end());
-  sinks_.erase(it);
-}
-
 }  // namespace content