Connect webrtc MediaSourceInterface ready states with webkit WebMediaStreamSource

content/renderer/media/mock_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/mock_media_stream_dependency_factory.h"
 
 #include "base/logging.h"
 #include "content/renderer/media/mock_peer_connection_impl.h"
 #include "third_party/libjingle/source/talk/app/webrtc/mediastreaminterface.h"
 #include "third_party/libjingle/source/talk/base/scoped_ref_ptr.h"
@@ skipping 130 matching lines @@
   state_ = MediaSourceInterface::kEnded;
   if (observer_)
     observer_->OnChanged();
 }
 
 webrtc::MediaSourceInterface::SourceState MockAudioSource::state() const {
   return state_;
 }
 
 MockVideoSource::MockVideoSource()
-    : observer_(NULL),
-      state_(MediaSourceInterface::kInitializing) {
+    : state_(MediaSourceInterface::kInitializing) {
 }
 
 MockVideoSource::~MockVideoSource() {}
 
 cricket::VideoCapturer* MockVideoSource::GetVideoCapturer() {
   NOTIMPLEMENTED();
   return NULL;
 }
 
 void MockVideoSource::AddSink(cricket::VideoRenderer* output) {
   NOTIMPLEMENTED();
 }
 
 void MockVideoSource::RemoveSink(cricket::VideoRenderer* output) {
   NOTIMPLEMENTED();
 }
 
 void MockVideoSource::RegisterObserver(webrtc::ObserverInterface* observer) {
-  observer_ = observer;
+  observers_.push_back(observer);
 }
 
 void MockVideoSource::UnregisterObserver(webrtc::ObserverInterface* observer) {
-  DCHECK(observer_  == observer);
-  observer_ = NULL;
+  for (std::vector<ObserverInterface*>::iterator it = observers_.begin();
+       it != observers_.end(); ++it) {
+    if (*it == observer) {
+      observers_.erase(it);
+      break;
+    }
+  }
+}
+
+void MockVideoSource::FireOnChanged() {
+  std::vector<ObserverInterface*> observers(observers_);
+  for (std::vector<ObserverInterface*>::iterator it = observers.begin();
+       it != observers.end(); ++it) {
+    (*it)->OnChanged();
+  }
 }
 
 void MockVideoSource::SetLive() {
   DCHECK_EQ(MediaSourceInterface::kInitializing, state_);
   state_ = MediaSourceInterface::kLive;
-  if (observer_)
-    observer_->OnChanged();
+  FireOnChanged();
 }
 
 void MockVideoSource::SetEnded() {
   DCHECK_NE(MediaSourceInterface::kEnded, state_);
   state_ = MediaSourceInterface::kEnded;
-  if (observer_)
-    observer_->OnChanged();
+  FireOnChanged();
 }
 
 webrtc::MediaSourceInterface::SourceState MockVideoSource::state() const {
   return state_;
 }
 
 const cricket::VideoOptions* MockVideoSource::options() const {
   NOTIMPLEMENTED();
   return NULL;
 }
@@ skipping 276 matching lines @@
 
 webrtc::IceCandidateInterface*
 MockMediaStreamDependencyFactory::CreateIceCandidate(
     const std::string& sdp_mid,
     int sdp_mline_index,
     const std::string& sdp) {
   return new MockIceCandidate(sdp_mid, sdp_mline_index, sdp);
 }
 
 }  // namespace content