content/renderer/media/media_stream.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/renderer/media/media_stream.h"
   6
   7 #include "base/logging.h"
   8 #include "third_party/WebKit/public/platform/WebString.h"
   9 #include "third_party/libjingle/source/talk/app/webrtc/mediastreaminterface.h"
  10
  11 namespace content {
  12
  13 // static
  14 MediaStream* MediaStream::GetMediaStream(
  15     const blink::WebMediaStream& stream) {
  16   return static_cast<MediaStream*>(stream.extraData());
  17 }
  18
  19 // static
  20 webrtc::MediaStreamInterface* MediaStream::GetAdapter(
  21      const blink::WebMediaStream& stream) {
  22   MediaStream* native_stream = GetMediaStream(stream);
  23   DCHECK(native_stream);
  24   return native_stream->GetWebRtcAdapter(stream);
  25 }
  26
  27 MediaStream::MediaStream(const blink::WebMediaStream& stream)
  28     : is_local_(true),
  29       webrtc_media_stream_(NULL) {
  30 }
  31
  32 MediaStream::MediaStream(webrtc::MediaStreamInterface* webrtc_stream)
  33     : is_local_(false),
  34       webrtc_media_stream_(webrtc_stream) {
  35 }
  36
  37 MediaStream::~MediaStream() {
  38   DCHECK(observers_.empty());
  39 }
  40
  41 webrtc::MediaStreamInterface* MediaStream::GetWebRtcAdapter(
  42     const blink::WebMediaStream& stream) {
  43   DCHECK(webrtc_media_stream_.get());
  44   DCHECK(thread_checker_.CalledOnValidThread());
  45   return webrtc_media_stream_.get();
  46 }
  47
  48 void MediaStream::AddObserver(MediaStreamObserver* observer) {
  49   DCHECK(thread_checker_.CalledOnValidThread());
  50   DCHECK(std::find(observers_.begin(), observers_.end(), observer) ==
  51       observers_.end());
  52   observers_.push_back(observer);
  53 }
  54
  55 void MediaStream::RemoveObserver(MediaStreamObserver* observer) {
  56   DCHECK(thread_checker_.CalledOnValidThread());
  57   std::vector<MediaStreamObserver*>::iterator it =
  58       std::find(observers_.begin(), observers_.end(), observer);
  59   DCHECK(it != observers_.end());
  60   observers_.erase(it);
  61 }
  62
  63 bool MediaStream::AddTrack(const blink::WebMediaStreamTrack& track) {
  64   DCHECK(thread_checker_.CalledOnValidThread());
  65   for (std::vector<MediaStreamObserver*>::iterator it = observers_.begin();
  66        it != observers_.end(); ++it) {
  67     (*it)->TrackAdded(track);
  68   }
  69   return true;
  70 }
  71
  72 bool MediaStream::RemoveTrack(const blink::WebMediaStreamTrack& track) {
  73   DCHECK(thread_checker_.CalledOnValidThread());
  74   for (std::vector<MediaStreamObserver*>::iterator it = observers_.begin();
  75        it != observers_.end(); ++it) {
  76     (*it)->TrackRemoved(track);
  77   }
  78   return true;
  79 }
  80
  81 }  // namespace content