peerconnection.h revision 0c7e9f540b282d60b94081f601a1694054d8646e
128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org/* 228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * libjingle 35f93d0a140515e3b8cdd1b9a4c6f5871144e5deejlmiller@webrtc.org * Copyright 2012 Google Inc. 428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * Redistribution and use in source and binary forms, with or without 628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * modification, are permitted provided that the following conditions are met: 728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 1. Redistributions of source code must retain the above copyright notice, 928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * this list of conditions and the following disclaimer. 1028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 2. Redistributions in binary form must reproduce the above copyright notice, 1128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * this list of conditions and the following disclaimer in the documentation 1228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * and/or other materials provided with the distribution. 1328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 3. The name of the author may not be used to endorse or promote products 1428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * derived from this software without specific prior written permission. 1528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * 1628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 1728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 1828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 1928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 2028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 2128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 2228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 2328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 2428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 2528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 2628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org */ 2728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 2828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#ifndef TALK_APP_WEBRTC_PEERCONNECTION_H_ 2928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#define TALK_APP_WEBRTC_PEERCONNECTION_H_ 3028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 3128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include <string> 3228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 335e56c5927e097f095aef2e9f7be49fd3d59221e1Henrik Boström#include "talk/app/webrtc/dtlsidentitystore.h" 3428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/app/webrtc/peerconnectionfactory.h" 35a09a99950ec40aef6421e4ba35eee7196b7a6e68buildbot@webrtc.org#include "talk/app/webrtc/peerconnectioninterface.h" 3670ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef#include "talk/app/webrtc/rtpreceiverinterface.h" 3770ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef#include "talk/app/webrtc/rtpsenderinterface.h" 3828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/app/webrtc/statscollector.h" 3928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/app/webrtc/streamcollection.h" 4028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#include "talk/app/webrtc/webrtcsession.h" 41d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org#include "webrtc/base/scoped_ptr.h" 4228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 4328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgnamespace webrtc { 4428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 45eb45981165f982dd51425fad5ecb7ea9619063d3deadbeefclass MediaStreamObserver; 46ab9b2d1516cad017c6e0236c468934582530c965deadbeefclass RemoteMediaStreamFactory; 47ab9b2d1516cad017c6e0236c468934582530c965deadbeef 48ab9b2d1516cad017c6e0236c468934582530c965deadbeef// Populates |session_options| from |rtc_options|, and returns true if options 49ab9b2d1516cad017c6e0236c468934582530c965deadbeef// are valid. 50ab9b2d1516cad017c6e0236c468934582530c965deadbeefbool ConvertRtcOptionsForOffer( 51ab9b2d1516cad017c6e0236c468934582530c965deadbeef const PeerConnectionInterface::RTCOfferAnswerOptions& rtc_options, 52ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaSessionOptions* session_options); 53ab9b2d1516cad017c6e0236c468934582530c965deadbeef 54ab9b2d1516cad017c6e0236c468934582530c965deadbeef// Populates |session_options| from |constraints|, and returns true if all 55ab9b2d1516cad017c6e0236c468934582530c965deadbeef// mandatory constraints are satisfied. 56ab9b2d1516cad017c6e0236c468934582530c965deadbeefbool ParseConstraintsForAnswer(const MediaConstraintsInterface* constraints, 57ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaSessionOptions* session_options); 58ab9b2d1516cad017c6e0236c468934582530c965deadbeef 590c7e9f540b282d60b94081f601a1694054d8646eTaylor Brandstetter// Parses the URLs for each server in |servers| to build |stun_servers| and 600c7e9f540b282d60b94081f601a1694054d8646eTaylor Brandstetter// |turn_servers|. 610a6c4ca942f3a25c15c7af64a9515d381c34cd9cdeadbeefbool ParseIceServers(const PeerConnectionInterface::IceServers& servers, 620c7e9f540b282d60b94081f601a1694054d8646eTaylor Brandstetter cricket::ServerAddresses* stun_servers, 630c7e9f540b282d60b94081f601a1694054d8646eTaylor Brandstetter std::vector<cricket::RelayServerConfig>* turn_servers); 640a6c4ca942f3a25c15c7af64a9515d381c34cd9cdeadbeef 6570ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef// PeerConnection implements the PeerConnectionInterface interface. 66ab9b2d1516cad017c6e0236c468934582530c965deadbeef// It uses WebRtcSession to implement the PeerConnection functionality. 6728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.orgclass PeerConnection : public PeerConnectionInterface, 6828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org public IceObserver, 69d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org public rtc::MessageHandler, 7028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org public sigslot::has_slots<> { 7128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org public: 7228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org explicit PeerConnection(PeerConnectionFactory* factory); 7328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 74653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef bool Initialize( 75653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef const PeerConnectionInterface::RTCConfiguration& configuration, 76653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef const MediaConstraintsInterface* constraints, 77653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef rtc::scoped_ptr<cricket::PortAllocator> allocator, 78653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef rtc::scoped_ptr<DtlsIdentityStoreInterface> dtls_identity_store, 79653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef PeerConnectionObserver* observer); 80653b8e02f22c9b6ba38be1cf4c0fa101894a9407deadbeef 81a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef rtc::scoped_refptr<StreamCollectionInterface> local_streams() override; 82a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef rtc::scoped_refptr<StreamCollectionInterface> remote_streams() override; 83a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef bool AddStream(MediaStreamInterface* local_stream) override; 84a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void RemoveStream(MediaStreamInterface* local_stream) override; 8528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 86ab9b2d1516cad017c6e0236c468934582530c965deadbeef virtual WebRtcSession* session() { return session_.get(); } 87ab9b2d1516cad017c6e0236c468934582530c965deadbeef 88a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef rtc::scoped_refptr<DtmfSenderInterface> CreateDtmfSender( 89a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef AudioTrackInterface* track) override; 9028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 91fac0655fd7fe0b40ef50dc5b7f11ea44d72cec6cdeadbeef rtc::scoped_refptr<RtpSenderInterface> CreateSender( 92bd7d8f7e2b824a887aa12236cb6185d446d7da61deadbeef const std::string& kind, 93bd7d8f7e2b824a887aa12236cb6185d446d7da61deadbeef const std::string& stream_id) override; 94fac0655fd7fe0b40ef50dc5b7f11ea44d72cec6cdeadbeef 9570ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpSenderInterface>> GetSenders() 9670ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef const override; 9770ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpReceiverInterface>> GetReceivers() 9870ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef const override; 9970ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef 100a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef rtc::scoped_refptr<DataChannelInterface> CreateDataChannel( 10128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const std::string& label, 102a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const DataChannelInit* config) override; 103a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef bool GetStats(StatsObserver* observer, 104a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef webrtc::MediaStreamTrackInterface* track, 105a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef StatsOutputLevel level) override; 10628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 107a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef SignalingState signaling_state() override; 10828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 10928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // TODO(bemasc): Remove ice_state() when callers are removed. 110a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef IceState ice_state() override; 111a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef IceConnectionState ice_connection_state() override; 112a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef IceGatheringState ice_gathering_state() override; 11328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 114a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const SessionDescriptionInterface* local_description() const override; 115a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const SessionDescriptionInterface* remote_description() const override; 11628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 11728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // JSEP01 118a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void CreateOffer(CreateSessionDescriptionObserver* observer, 119a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const MediaConstraintsInterface* constraints) override; 120a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void CreateOffer(CreateSessionDescriptionObserver* observer, 121a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const RTCOfferAnswerOptions& options) override; 122a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void CreateAnswer(CreateSessionDescriptionObserver* observer, 123a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const MediaConstraintsInterface* constraints) override; 124a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void SetLocalDescription(SetSessionDescriptionObserver* observer, 125a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef SessionDescriptionInterface* desc) override; 126a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void SetRemoteDescription(SetSessionDescriptionObserver* observer, 127a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef SessionDescriptionInterface* desc) override; 128a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef bool SetConfiguration( 129a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef const PeerConnectionInterface::RTCConfiguration& config) override; 130a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef bool AddIceCandidate(const IceCandidateInterface* candidate) override; 131a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef 132a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void RegisterUMAObserver(UMAObserver* observer) override; 133a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef 134a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void Close() override; 13528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 136ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Virtual for unit tests. 137ab9b2d1516cad017c6e0236c468934582530c965deadbeef virtual const std::vector<rtc::scoped_refptr<DataChannel>>& 138ab9b2d1516cad017c6e0236c468934582530c965deadbeef sctp_data_channels() const { 139ab9b2d1516cad017c6e0236c468934582530c965deadbeef return sctp_data_channels_; 140ab9b2d1516cad017c6e0236c468934582530c965deadbeef }; 141ab9b2d1516cad017c6e0236c468934582530c965deadbeef 14228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org protected: 143a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef ~PeerConnection() override; 14428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 14528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org private: 146ab9b2d1516cad017c6e0236c468934582530c965deadbeef struct TrackInfo { 147ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfo() : ssrc(0) {} 148ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfo(const std::string& stream_label, 149ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string track_id, 150ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc) 151ab9b2d1516cad017c6e0236c468934582530c965deadbeef : stream_label(stream_label), track_id(track_id), ssrc(ssrc) {} 152bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef bool operator==(const TrackInfo& other) { 153bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef return this->stream_label == other.stream_label && 154bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef this->track_id == other.track_id && this->ssrc == other.ssrc; 155bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef } 156ab9b2d1516cad017c6e0236c468934582530c965deadbeef std::string stream_label; 157ab9b2d1516cad017c6e0236c468934582530c965deadbeef std::string track_id; 158ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc; 159ab9b2d1516cad017c6e0236c468934582530c965deadbeef }; 160ab9b2d1516cad017c6e0236c468934582530c965deadbeef typedef std::vector<TrackInfo> TrackInfos; 161ab9b2d1516cad017c6e0236c468934582530c965deadbeef 16228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Implements MessageHandler. 163a67696b3cde98163ee38de8313ee9eddb73c662edeadbeef void OnMessage(rtc::Message* msg) override; 16428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 165ab9b2d1516cad017c6e0236c468934582530c965deadbeef void CreateAudioReceiver(MediaStreamInterface* stream, 166ab9b2d1516cad017c6e0236c468934582530c965deadbeef AudioTrackInterface* audio_track, 167ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc); 168ab9b2d1516cad017c6e0236c468934582530c965deadbeef void CreateVideoReceiver(MediaStreamInterface* stream, 169ab9b2d1516cad017c6e0236c468934582530c965deadbeef VideoTrackInterface* video_track, 170ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc); 171ab9b2d1516cad017c6e0236c468934582530c965deadbeef void DestroyAudioReceiver(MediaStreamInterface* stream, 172ab9b2d1516cad017c6e0236c468934582530c965deadbeef AudioTrackInterface* audio_track); 173ab9b2d1516cad017c6e0236c468934582530c965deadbeef void DestroyVideoReceiver(MediaStreamInterface* stream, 174ab9b2d1516cad017c6e0236c468934582530c965deadbeef VideoTrackInterface* video_track); 175ab9b2d1516cad017c6e0236c468934582530c965deadbeef void DestroyAudioSender(MediaStreamInterface* stream, 176ab9b2d1516cad017c6e0236c468934582530c965deadbeef AudioTrackInterface* audio_track, 177ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc); 178ab9b2d1516cad017c6e0236c468934582530c965deadbeef void DestroyVideoSender(MediaStreamInterface* stream, 179ab9b2d1516cad017c6e0236c468934582530c965deadbeef VideoTrackInterface* video_track); 18028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 18128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Implements IceObserver 18254360510ff9b7c61fc906d3ed360b06a5824bbf1Peter Thatcher void OnIceConnectionChange(IceConnectionState new_state) override; 18354360510ff9b7c61fc906d3ed360b06a5824bbf1Peter Thatcher void OnIceGatheringChange(IceGatheringState new_state) override; 18454360510ff9b7c61fc906d3ed360b06a5824bbf1Peter Thatcher void OnIceCandidate(const IceCandidateInterface* candidate) override; 18554360510ff9b7c61fc906d3ed360b06a5824bbf1Peter Thatcher void OnIceComplete() override; 18654360510ff9b7c61fc906d3ed360b06a5824bbf1Peter Thatcher void OnIceConnectionReceivingChange(bool receiving) override; 18728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 18828e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Signals from WebRtcSession. 189d59daf8023286d63a1b6c8af82eedb684181c1ebdeadbeef void OnSessionStateChange(WebRtcSession* session, WebRtcSession::State state); 19028e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org void ChangeSignalingState(SignalingState signaling_state); 19128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 192eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef // Signals from MediaStreamObserver. 193eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef void OnAudioTrackAdded(AudioTrackInterface* track, 194eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef MediaStreamInterface* stream); 195eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef void OnAudioTrackRemoved(AudioTrackInterface* track, 196eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef MediaStreamInterface* stream); 197eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef void OnVideoTrackAdded(VideoTrackInterface* track, 198eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef MediaStreamInterface* stream); 199eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef void OnVideoTrackRemoved(VideoTrackInterface* track, 200eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef MediaStreamInterface* stream); 201eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef 202d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::Thread* signaling_thread() const { 20328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org return factory_->signaling_thread(); 20428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 20528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 20628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org void PostSetSessionDescriptionFailure(SetSessionDescriptionObserver* observer, 20728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org const std::string& error); 208ab9b2d1516cad017c6e0236c468934582530c965deadbeef void PostCreateSessionDescriptionFailure( 209ab9b2d1516cad017c6e0236c468934582530c965deadbeef CreateSessionDescriptionObserver* observer, 210ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& error); 21128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 21228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org bool IsClosed() const { 21328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org return signaling_state_ == PeerConnectionInterface::kClosed; 21428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org } 21528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 216ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Returns a MediaSessionOptions struct with options decided by |options|, 217ab9b2d1516cad017c6e0236c468934582530c965deadbeef // the local MediaStreams and DataChannels. 218ab9b2d1516cad017c6e0236c468934582530c965deadbeef virtual bool GetOptionsForOffer( 219ab9b2d1516cad017c6e0236c468934582530c965deadbeef const PeerConnectionInterface::RTCOfferAnswerOptions& rtc_options, 220ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaSessionOptions* session_options); 221ab9b2d1516cad017c6e0236c468934582530c965deadbeef 222ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Returns a MediaSessionOptions struct with options decided by 223ab9b2d1516cad017c6e0236c468934582530c965deadbeef // |constraints|, the local MediaStreams and DataChannels. 224ab9b2d1516cad017c6e0236c468934582530c965deadbeef virtual bool GetOptionsForAnswer( 225ab9b2d1516cad017c6e0236c468934582530c965deadbeef const MediaConstraintsInterface* constraints, 226ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaSessionOptions* session_options); 227ab9b2d1516cad017c6e0236c468934582530c965deadbeef 228faac497af560ece34301343eb40377fd5503f7a0deadbeef // Remove all local and remote tracks of type |media_type|. 229faac497af560ece34301343eb40377fd5503f7a0deadbeef // Called when a media type is rejected (m-line set to port 0). 230faac497af560ece34301343eb40377fd5503f7a0deadbeef void RemoveTracks(cricket::MediaType media_type); 231faac497af560ece34301343eb40377fd5503f7a0deadbeef 232bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef // Makes sure a MediaStreamTrack is created for each StreamParam in |streams|, 233bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef // and existing MediaStreamTracks are removed if there is no corresponding 234bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef // StreamParam. If |default_track_needed| is true, a default MediaStreamTrack 235bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef // is created if it doesn't exist; if false, it's removed if it exists. 236bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef // |media_type| is the type of the |streams| and can be either audio or video. 237ab9b2d1516cad017c6e0236c468934582530c965deadbeef // If a new MediaStream is created it is added to |new_streams|. 238ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateRemoteStreamsList( 239ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::vector<cricket::StreamParams>& streams, 240bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef bool default_track_needed, 241ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type, 242ab9b2d1516cad017c6e0236c468934582530c965deadbeef StreamCollection* new_streams); 243ab9b2d1516cad017c6e0236c468934582530c965deadbeef 244ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Triggered when a remote track has been seen for the first time in a remote 245ab9b2d1516cad017c6e0236c468934582530c965deadbeef // session description. It creates a remote MediaStreamTrackInterface 246ab9b2d1516cad017c6e0236c468934582530c965deadbeef // implementation and triggers CreateAudioReceiver or CreateVideoReceiver. 247ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnRemoteTrackSeen(const std::string& stream_label, 248ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& track_id, 249ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc, 250ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type); 251ab9b2d1516cad017c6e0236c468934582530c965deadbeef 252ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Triggered when a remote track has been removed from a remote session 253ab9b2d1516cad017c6e0236c468934582530c965deadbeef // description. It removes the remote track with id |track_id| from a remote 254ab9b2d1516cad017c6e0236c468934582530c965deadbeef // MediaStream and triggers DestroyAudioReceiver or DestroyVideoReceiver. 255ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnRemoteTrackRemoved(const std::string& stream_label, 256ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& track_id, 257ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type); 258ab9b2d1516cad017c6e0236c468934582530c965deadbeef 259ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Finds remote MediaStreams without any tracks and removes them from 260ab9b2d1516cad017c6e0236c468934582530c965deadbeef // |remote_streams_| and notifies the observer that the MediaStreams no longer 261ab9b2d1516cad017c6e0236c468934582530c965deadbeef // exist. 262ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateEndedRemoteMediaStreams(); 263ab9b2d1516cad017c6e0236c468934582530c965deadbeef 264ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Set the MediaStreamTrackInterface::TrackState to |kEnded| on all remote 265ab9b2d1516cad017c6e0236c468934582530c965deadbeef // tracks of type |media_type|. 266ab9b2d1516cad017c6e0236c468934582530c965deadbeef void EndRemoteTracks(cricket::MediaType media_type); 267ab9b2d1516cad017c6e0236c468934582530c965deadbeef 268ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Loops through the vector of |streams| and finds added and removed 269ab9b2d1516cad017c6e0236c468934582530c965deadbeef // StreamParams since last time this method was called. 270ab9b2d1516cad017c6e0236c468934582530c965deadbeef // For each new or removed StreamParam, OnLocalTrackSeen or 271ab9b2d1516cad017c6e0236c468934582530c965deadbeef // OnLocalTrackRemoved is invoked. 272ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateLocalTracks(const std::vector<cricket::StreamParams>& streams, 273ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type); 274ab9b2d1516cad017c6e0236c468934582530c965deadbeef 275ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Triggered when a local track has been seen for the first time in a local 276ab9b2d1516cad017c6e0236c468934582530c965deadbeef // session description. 277ab9b2d1516cad017c6e0236c468934582530c965deadbeef // This method triggers CreateAudioSender or CreateVideoSender if the rtp 278ab9b2d1516cad017c6e0236c468934582530c965deadbeef // streams in the local SessionDescription can be mapped to a MediaStreamTrack 279ab9b2d1516cad017c6e0236c468934582530c965deadbeef // in a MediaStream in |local_streams_| 280ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnLocalTrackSeen(const std::string& stream_label, 281ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& track_id, 282ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc, 283ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type); 284ab9b2d1516cad017c6e0236c468934582530c965deadbeef 285ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Triggered when a local track has been removed from a local session 286ab9b2d1516cad017c6e0236c468934582530c965deadbeef // description. 287ab9b2d1516cad017c6e0236c468934582530c965deadbeef // This method triggers DestroyAudioSender or DestroyVideoSender if a stream 288ab9b2d1516cad017c6e0236c468934582530c965deadbeef // has been removed from the local SessionDescription and the stream can be 289ab9b2d1516cad017c6e0236c468934582530c965deadbeef // mapped to a MediaStreamTrack in a MediaStream in |local_streams_|. 290ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnLocalTrackRemoved(const std::string& stream_label, 291ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& track_id, 292ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t ssrc, 293ab9b2d1516cad017c6e0236c468934582530c965deadbeef cricket::MediaType media_type); 294ab9b2d1516cad017c6e0236c468934582530c965deadbeef 295ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateLocalRtpDataChannels(const cricket::StreamParamsVec& streams); 296ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateRemoteRtpDataChannels(const cricket::StreamParamsVec& streams); 297ab9b2d1516cad017c6e0236c468934582530c965deadbeef void UpdateClosingRtpDataChannels( 298ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::vector<std::string>& active_channels, 299ab9b2d1516cad017c6e0236c468934582530c965deadbeef bool is_local_update); 300ab9b2d1516cad017c6e0236c468934582530c965deadbeef void CreateRemoteRtpDataChannel(const std::string& label, 301ab9b2d1516cad017c6e0236c468934582530c965deadbeef uint32_t remote_ssrc); 302ab9b2d1516cad017c6e0236c468934582530c965deadbeef 303ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Creates channel and adds it to the collection of DataChannels that will 304ab9b2d1516cad017c6e0236c468934582530c965deadbeef // be offered in a SessionDescription. 305ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_refptr<DataChannel> InternalCreateDataChannel( 306ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& label, 307ab9b2d1516cad017c6e0236c468934582530c965deadbeef const InternalDataChannelInit* config); 308ab9b2d1516cad017c6e0236c468934582530c965deadbeef 309ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Checks if any data channel has been added. 310ab9b2d1516cad017c6e0236c468934582530c965deadbeef bool HasDataChannels() const; 311ab9b2d1516cad017c6e0236c468934582530c965deadbeef 312ab9b2d1516cad017c6e0236c468934582530c965deadbeef void AllocateSctpSids(rtc::SSLRole role); 313ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnSctpDataChannelClosed(DataChannel* channel); 314ab9b2d1516cad017c6e0236c468934582530c965deadbeef 315ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Notifications from WebRtcSession relating to BaseChannels. 316ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnVoiceChannelDestroyed(); 317ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnVideoChannelDestroyed(); 318ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnDataChannelCreated(); 319ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnDataChannelDestroyed(); 320ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Called when the cricket::DataChannel receives a message indicating that a 321ab9b2d1516cad017c6e0236c468934582530c965deadbeef // webrtc::DataChannel should be opened. 322ab9b2d1516cad017c6e0236c468934582530c965deadbeef void OnDataChannelOpenMessage(const std::string& label, 323ab9b2d1516cad017c6e0236c468934582530c965deadbeef const InternalDataChannelInit& config); 324ab9b2d1516cad017c6e0236c468934582530c965deadbeef 325fac0655fd7fe0b40ef50dc5b7f11ea44d72cec6cdeadbeef RtpSenderInterface* FindSenderById(const std::string& id); 326fac0655fd7fe0b40ef50dc5b7f11ea44d72cec6cdeadbeef 32770ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpSenderInterface>>::iterator 32870ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef FindSenderForTrack(MediaStreamTrackInterface* track); 32970ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpReceiverInterface>>::iterator 33070ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef FindReceiverForTrack(MediaStreamTrackInterface* track); 33170ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef 332ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos* GetRemoteTracks(cricket::MediaType media_type); 333ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos* GetLocalTracks(cricket::MediaType media_type); 334ab9b2d1516cad017c6e0236c468934582530c965deadbeef const TrackInfo* FindTrackInfo(const TrackInfos& infos, 335ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string& stream_label, 336ab9b2d1516cad017c6e0236c468934582530c965deadbeef const std::string track_id) const; 337ab9b2d1516cad017c6e0236c468934582530c965deadbeef 338ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Returns the specified SCTP DataChannel in sctp_data_channels_, 339ab9b2d1516cad017c6e0236c468934582530c965deadbeef // or nullptr if not found. 340ab9b2d1516cad017c6e0236c468934582530c965deadbeef DataChannel* FindDataChannelBySid(int sid) const; 341ab9b2d1516cad017c6e0236c468934582530c965deadbeef 34228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // Storing the factory as a scoped reference pointer ensures that the memory 34328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // in the PeerConnectionFactoryImpl remains available as long as the 34428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // PeerConnection is running. It is passed to PeerConnection as a raw pointer. 34528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // However, since the reference counting is done in the 346ab9b2d1516cad017c6e0236c468934582530c965deadbeef // PeerConnectionFactoryInterface all instances created using the raw pointer 34728e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // will refer to the same reference count. 348d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::scoped_refptr<PeerConnectionFactory> factory_; 34928e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org PeerConnectionObserver* observer_; 3501567b8cf8cc486067c5ddf327dd3516bc8dc93e7buildbot@webrtc.org UMAObserver* uma_observer_; 35128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org SignalingState signaling_state_; 35228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org // TODO(bemasc): Remove ice_state_. 35328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org IceState ice_state_; 35428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org IceConnectionState ice_connection_state_; 35528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org IceGatheringState ice_gathering_state_; 35628e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 357d4e598d57aed714a599444a7eab5e8fdde52a950buildbot@webrtc.org rtc::scoped_ptr<cricket::PortAllocator> port_allocator_; 358c1aeaf0dc37d96f31c92f893f4e30e7a5f7cc2b7stefan rtc::scoped_ptr<MediaControllerInterface> media_controller_; 359ab9b2d1516cad017c6e0236c468934582530c965deadbeef 360ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Streams added via AddStream. 361ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_refptr<StreamCollection> local_streams_; 362ab9b2d1516cad017c6e0236c468934582530c965deadbeef // Streams created as a result of SetRemoteDescription. 363ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_refptr<StreamCollection> remote_streams_; 364ab9b2d1516cad017c6e0236c468934582530c965deadbeef 365eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef std::vector<rtc::scoped_ptr<MediaStreamObserver>> stream_observers_; 366eb45981165f982dd51425fad5ecb7ea9619063d3deadbeef 367ab9b2d1516cad017c6e0236c468934582530c965deadbeef // These lists store track info seen in local/remote descriptions. 368ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos remote_audio_tracks_; 369ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos remote_video_tracks_; 370ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos local_audio_tracks_; 371ab9b2d1516cad017c6e0236c468934582530c965deadbeef TrackInfos local_video_tracks_; 372ab9b2d1516cad017c6e0236c468934582530c965deadbeef 373ab9b2d1516cad017c6e0236c468934582530c965deadbeef SctpSidAllocator sid_allocator_; 374ab9b2d1516cad017c6e0236c468934582530c965deadbeef // label -> DataChannel 375ab9b2d1516cad017c6e0236c468934582530c965deadbeef std::map<std::string, rtc::scoped_refptr<DataChannel>> rtp_data_channels_; 376ab9b2d1516cad017c6e0236c468934582530c965deadbeef std::vector<rtc::scoped_refptr<DataChannel>> sctp_data_channels_; 377bd292465ee6d8219b04f17e2ffc0790313167f01deadbeef std::vector<rtc::scoped_refptr<DataChannel>> sctp_data_channels_to_free_; 378ab9b2d1516cad017c6e0236c468934582530c965deadbeef 379bda7e0b932fc89598da95496efc8650bc0e2c86cdeadbeef bool remote_peer_supports_msid_ = false; 380ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_ptr<RemoteMediaStreamFactory> remote_stream_factory_; 38170ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef 38270ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpSenderInterface>> senders_; 38370ab1a1ca89d280a7d51e3fadc51d4be9df209cadeadbeef std::vector<rtc::scoped_refptr<RtpReceiverInterface>> receivers_; 384ab9b2d1516cad017c6e0236c468934582530c965deadbeef 385ab9b2d1516cad017c6e0236c468934582530c965deadbeef // The session_ scoped_ptr is declared at the bottom of PeerConnection 386ab9b2d1516cad017c6e0236c468934582530c965deadbeef // because its destruction fires signals (such as VoiceChannelDestroyed) 387ab9b2d1516cad017c6e0236c468934582530c965deadbeef // which will trigger some final actions in PeerConnection... 388ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_ptr<WebRtcSession> session_; 389ab9b2d1516cad017c6e0236c468934582530c965deadbeef // ... But stats_ depends on session_ so it should be destroyed even earlier. 390ab9b2d1516cad017c6e0236c468934582530c965deadbeef rtc::scoped_ptr<StatsCollector> stats_; 39128e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org}; 39228e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 39328e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org} // namespace webrtc 39428e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org 39528e20752806a492f5a6a5d343c02f9556f39b1cdhenrike@webrtc.org#endif // TALK_APP_WEBRTC_PEERCONNECTION_H_ 396