peerconnection.cc

  bool PeerConnection::AddStream(MediaStreamInterface* local_stream) {
    TRACE_EVENT0("webrtc", "PeerConnection::AddStream");
    if (IsClosed()) {
      return false;
    }
    if (!CanAddLocalMediaStream(local_streams_, local_stream)) {
      return false;
    }

    local_streams_->AddStream(local_stream);
    MediaStreamObserver* observer = new MediaStreamObserver(local_stream);
    observer->SignalAudioTrackAdded.connect(this,
                                            &PeerConnection::OnAudioTrackAdded);
    observer->SignalAudioTrackRemoved.connect(
        this, &PeerConnection::OnAudioTrackRemoved);
    observer->SignalVideoTrackAdded.connect(this,
                                            &PeerConnection::OnVideoTrackAdded);
    observer->SignalVideoTrackRemoved.connect(
        this, &PeerConnection::OnVideoTrackRemoved);
    stream_observers_.push_back(std::unique_ptr<MediaStreamObserver>(observer));

    for (const auto& track : local_stream->GetAudioTracks()) {
      AddAudioTrack(track.get(), local_stream);
    }
    for (const auto& track : local_stream->GetVideoTracks()) {
      AddVideoTrack(track.get(), local_stream);
    }

    stats_->AddStream(local_stream);
    observer_->OnRenegotiationNeeded();
    return true;
  }