Support for multiple PeerConnections

content/renderer/media/peer_connection_handler.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/peer_connection_handler.h"
 
 #include <utility>
 #include <vector>
 
 #include "base/bind.h"
@@ skipping 13 matching lines @@
     MediaStreamDependencyFactory* dependency_factory)
     : client_(client),
       media_stream_impl_(msi),
       dependency_factory_(dependency_factory),
       message_loop_proxy_(base::MessageLoopProxy::current()) {
 }
 
 PeerConnectionHandler::~PeerConnectionHandler() {
 }
 
+bool PeerConnectionHandler::HasStream(const std::string& stream_label) {
+  webrtc::MediaStreamInterface* stream =
+      native_peer_connection_->remote_streams()->find(stream_label);
+  return stream != NULL;
+}
+
 void PeerConnectionHandler::SetVideoRenderer(
     const std::string& stream_label,
     webrtc::VideoRendererWrapperInterface* renderer) {
   webrtc::MediaStreamInterface* stream =
       native_peer_connection_->remote_streams()->find(stream_label);
   webrtc::VideoTracks* video_tracks = stream->video_tracks();
   // We assume there is only one enabled video track.
-  for(size_t i = 0; i < video_tracks->count(); ++i) {
+  for (size_t i = 0; i < video_tracks->count(); ++i) {
     webrtc::VideoTrackInterface* video_track = video_tracks->at(i);
     if (video_track->enabled()) {
       video_track->SetRenderer(renderer);
       return;
     }
   }
   DVLOG(1) << "No enabled video track.";
 }
 
 void PeerConnectionHandler::initialize(
@@ skipping 35 matching lines @@
     size_t length) {
   // TODO(grunell): Implement.
   NOTIMPLEMENTED();
 }
 
 void PeerConnectionHandler::stop() {
   // TODO(ronghuawu): There's an issue with signaling messages being sent during
   // close. We need to investigate further. Not calling Close() on native
   // PeerConnection is OK for now.
   native_peer_connection_ = NULL;
-  media_stream_impl_->ClosePeerConnection();
+  media_stream_impl_->ClosePeerConnection(this);
 }
 
 void PeerConnectionHandler::OnError() {
   // TODO(grunell): Implement.
   NOTIMPLEMENTED();
 }
 
 void PeerConnectionHandler::OnMessage(const std::string& msg) {
   // TODO(grunell): Implement.
   NOTIMPLEMENTED();
@@ skipping 134 matching lines @@
           UTF8ToUTF16(video_track->label()),
           WebKit::WebMediaStreamSource::TypeVideo,
           UTF8ToUTF16(video_track->label()));
   }
 
   WebKit::WebMediaStreamDescriptor descriptor;
   descriptor.initialize(UTF8ToUTF16(stream->label()), source_vector);
 
   return descriptor;
 }