blob: c2039aeea414321e612e461d635df72e486904a3 [file] [log] [blame]
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001/*
kjellanderb24317b2016-02-10 07:54:43 -08002 * Copyright 2012 The WebRTC project authors. All Rights Reserved.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003 *
kjellanderb24317b2016-02-10 07:54:43 -08004 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00009 */
10
Henrik Kjellander15583c12016-02-10 10:53:12 +010011#include "webrtc/api/peerconnection.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000012
deadbeefeb459812015-12-15 19:24:43 -080013#include <algorithm>
deadbeef0a6c4ca2015-10-06 11:38:28 -070014#include <cctype> // for isdigit
kwiberg0eb15ed2015-12-17 03:04:15 -080015#include <utility>
16#include <vector>
henrike@webrtc.org28e20752013-07-10 00:45:36 +000017
Henrik Kjellander15583c12016-02-10 10:53:12 +010018#include "webrtc/api/audiotrack.h"
19#include "webrtc/api/dtmfsender.h"
20#include "webrtc/api/jsepicecandidate.h"
21#include "webrtc/api/jsepsessiondescription.h"
22#include "webrtc/api/mediaconstraintsinterface.h"
23#include "webrtc/api/mediastream.h"
24#include "webrtc/api/mediastreamobserver.h"
25#include "webrtc/api/mediastreamproxy.h"
26#include "webrtc/api/mediastreamtrackproxy.h"
27#include "webrtc/api/remoteaudiosource.h"
28#include "webrtc/api/remotevideocapturer.h"
29#include "webrtc/api/rtpreceiver.h"
30#include "webrtc/api/rtpsender.h"
31#include "webrtc/api/streamcollection.h"
perkja3ede6c2016-03-08 01:27:48 +010032#include "webrtc/api/videocapturertracksource.h"
Henrik Kjellander15583c12016-02-10 10:53:12 +010033#include "webrtc/api/videotrack.h"
tfarina5237aaf2015-11-10 23:44:30 -080034#include "webrtc/base/arraysize.h"
buildbot@webrtc.orga09a9992014-08-13 17:26:08 +000035#include "webrtc/base/logging.h"
36#include "webrtc/base/stringencode.h"
deadbeefab9b2d12015-10-14 11:33:11 -070037#include "webrtc/base/stringutils.h"
Peter Boström1a9d6152015-12-08 22:15:17 +010038#include "webrtc/base/trace_event.h"
kjellandera96e2d72016-02-04 23:52:28 -080039#include "webrtc/media/sctp/sctpdataengine.h"
tfarina5237aaf2015-11-10 23:44:30 -080040#include "webrtc/p2p/client/basicportallocator.h"
kjellander@webrtc.org9b8df252016-02-12 06:47:59 +010041#include "webrtc/pc/channelmanager.h"
Henrik Kjellander98f53512015-10-28 18:17:40 +010042#include "webrtc/system_wrappers/include/field_trial.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000043
44namespace {
45
deadbeefab9b2d12015-10-14 11:33:11 -070046using webrtc::DataChannel;
47using webrtc::MediaConstraintsInterface;
48using webrtc::MediaStreamInterface;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000049using webrtc::PeerConnectionInterface;
deadbeeffac06552015-11-25 11:26:01 -080050using webrtc::RtpSenderInterface;
deadbeefab9b2d12015-10-14 11:33:11 -070051using webrtc::StreamCollection;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000052
deadbeefab9b2d12015-10-14 11:33:11 -070053static const char kDefaultStreamLabel[] = "default";
54static const char kDefaultAudioTrackLabel[] = "defaulta0";
55static const char kDefaultVideoTrackLabel[] = "defaultv0";
56
henrike@webrtc.org28e20752013-07-10 00:45:36 +000057// The min number of tokens must present in Turn host uri.
58// e.g. user@turn.example.org
59static const size_t kTurnHostTokensNum = 2;
60// Number of tokens must be preset when TURN uri has transport param.
61static const size_t kTurnTransportTokensNum = 2;
62// The default stun port.
wu@webrtc.org91053e72013-08-10 07:18:04 +000063static const int kDefaultStunPort = 3478;
64static const int kDefaultStunTlsPort = 5349;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000065static const char kTransport[] = "transport";
henrike@webrtc.org28e20752013-07-10 00:45:36 +000066
67// NOTE: Must be in the same order as the ServiceType enum.
deadbeef0a6c4ca2015-10-06 11:38:28 -070068static const char* kValidIceServiceTypes[] = {"stun", "stuns", "turn", "turns"};
henrike@webrtc.org28e20752013-07-10 00:45:36 +000069
deadbeef0a6c4ca2015-10-06 11:38:28 -070070// NOTE: A loop below assumes that the first value of this enum is 0 and all
71// other values are incremental.
henrike@webrtc.org28e20752013-07-10 00:45:36 +000072enum ServiceType {
deadbeef0a6c4ca2015-10-06 11:38:28 -070073 STUN = 0, // Indicates a STUN server.
74 STUNS, // Indicates a STUN server used with a TLS session.
75 TURN, // Indicates a TURN server
76 TURNS, // Indicates a TURN server used with a TLS session.
77 INVALID, // Unknown.
henrike@webrtc.org28e20752013-07-10 00:45:36 +000078};
tfarina5237aaf2015-11-10 23:44:30 -080079static_assert(INVALID == arraysize(kValidIceServiceTypes),
deadbeef0a6c4ca2015-10-06 11:38:28 -070080 "kValidIceServiceTypes must have as many strings as ServiceType "
81 "has values.");
henrike@webrtc.org28e20752013-07-10 00:45:36 +000082
83enum {
wu@webrtc.org91053e72013-08-10 07:18:04 +000084 MSG_SET_SESSIONDESCRIPTION_SUCCESS = 0,
henrike@webrtc.org28e20752013-07-10 00:45:36 +000085 MSG_SET_SESSIONDESCRIPTION_FAILED,
deadbeefab9b2d12015-10-14 11:33:11 -070086 MSG_CREATE_SESSIONDESCRIPTION_FAILED,
henrike@webrtc.org28e20752013-07-10 00:45:36 +000087 MSG_GETSTATS,
deadbeefbd292462015-12-14 18:15:29 -080088 MSG_FREE_DATACHANNELS,
henrike@webrtc.org28e20752013-07-10 00:45:36 +000089};
90
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +000091struct SetSessionDescriptionMsg : public rtc::MessageData {
henrike@webrtc.org28e20752013-07-10 00:45:36 +000092 explicit SetSessionDescriptionMsg(
93 webrtc::SetSessionDescriptionObserver* observer)
94 : observer(observer) {
95 }
96
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +000097 rtc::scoped_refptr<webrtc::SetSessionDescriptionObserver> observer;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000098 std::string error;
99};
100
deadbeefab9b2d12015-10-14 11:33:11 -0700101struct CreateSessionDescriptionMsg : public rtc::MessageData {
102 explicit CreateSessionDescriptionMsg(
103 webrtc::CreateSessionDescriptionObserver* observer)
104 : observer(observer) {}
105
106 rtc::scoped_refptr<webrtc::CreateSessionDescriptionObserver> observer;
107 std::string error;
108};
109
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000110struct GetStatsMsg : public rtc::MessageData {
tommi@webrtc.org5b06b062014-08-15 08:38:30 +0000111 GetStatsMsg(webrtc::StatsObserver* observer,
112 webrtc::MediaStreamTrackInterface* track)
113 : observer(observer), track(track) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000114 }
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000115 rtc::scoped_refptr<webrtc::StatsObserver> observer;
tommi@webrtc.org5b06b062014-08-15 08:38:30 +0000116 rtc::scoped_refptr<webrtc::MediaStreamTrackInterface> track;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000117};
118
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000119// |in_str| should be of format
120// stunURI = scheme ":" stun-host [ ":" stun-port ]
121// scheme = "stun" / "stuns"
122// stun-host = IP-literal / IPv4address / reg-name
123// stun-port = *DIGIT
deadbeef0a6c4ca2015-10-06 11:38:28 -0700124//
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000125// draft-petithuguenin-behave-turn-uris-01
126// turnURI = scheme ":" turn-host [ ":" turn-port ]
127// turn-host = username@IP-literal / IPv4address / reg-name
128bool GetServiceTypeAndHostnameFromUri(const std::string& in_str,
129 ServiceType* service_type,
130 std::string* hostname) {
Tommi77d444a2015-04-24 15:38:38 +0200131 const std::string::size_type colonpos = in_str.find(':');
deadbeef0a6c4ca2015-10-06 11:38:28 -0700132 if (colonpos == std::string::npos) {
133 LOG(LS_WARNING) << "Missing ':' in ICE URI: " << in_str;
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000134 return false;
135 }
deadbeef0a6c4ca2015-10-06 11:38:28 -0700136 if ((colonpos + 1) == in_str.length()) {
137 LOG(LS_WARNING) << "Empty hostname in ICE URI: " << in_str;
138 return false;
139 }
140 *service_type = INVALID;
tfarina5237aaf2015-11-10 23:44:30 -0800141 for (size_t i = 0; i < arraysize(kValidIceServiceTypes); ++i) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700142 if (in_str.compare(0, colonpos, kValidIceServiceTypes[i]) == 0) {
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000143 *service_type = static_cast<ServiceType>(i);
144 break;
145 }
146 }
147 if (*service_type == INVALID) {
148 return false;
149 }
150 *hostname = in_str.substr(colonpos + 1, std::string::npos);
151 return true;
152}
153
deadbeef0a6c4ca2015-10-06 11:38:28 -0700154bool ParsePort(const std::string& in_str, int* port) {
155 // Make sure port only contains digits. FromString doesn't check this.
156 for (const char& c : in_str) {
157 if (!std::isdigit(c)) {
158 return false;
159 }
160 }
161 return rtc::FromString(in_str, port);
162}
163
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000164// This method parses IPv6 and IPv4 literal strings, along with hostnames in
165// standard hostname:port format.
166// Consider following formats as correct.
167// |hostname:port|, |[IPV6 address]:port|, |IPv4 address|:port,
deadbeef0a6c4ca2015-10-06 11:38:28 -0700168// |hostname|, |[IPv6 address]|, |IPv4 address|.
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000169bool ParseHostnameAndPortFromString(const std::string& in_str,
170 std::string* host,
171 int* port) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700172 RTC_DCHECK(host->empty());
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000173 if (in_str.at(0) == '[') {
174 std::string::size_type closebracket = in_str.rfind(']');
175 if (closebracket != std::string::npos) {
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000176 std::string::size_type colonpos = in_str.find(':', closebracket);
177 if (std::string::npos != colonpos) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700178 if (!ParsePort(in_str.substr(closebracket + 2, std::string::npos),
179 port)) {
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000180 return false;
181 }
182 }
deadbeef0a6c4ca2015-10-06 11:38:28 -0700183 *host = in_str.substr(1, closebracket - 1);
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000184 } else {
185 return false;
186 }
187 } else {
188 std::string::size_type colonpos = in_str.find(':');
189 if (std::string::npos != colonpos) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700190 if (!ParsePort(in_str.substr(colonpos + 1, std::string::npos), port)) {
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000191 return false;
192 }
deadbeef0a6c4ca2015-10-06 11:38:28 -0700193 *host = in_str.substr(0, colonpos);
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000194 } else {
195 *host = in_str;
196 }
197 }
deadbeef0a6c4ca2015-10-06 11:38:28 -0700198 return !host->empty();
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000199}
200
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800201// Adds a STUN or TURN server to the appropriate list,
deadbeef0a6c4ca2015-10-06 11:38:28 -0700202// by parsing |url| and using the username/password in |server|.
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200203bool ParseIceServerUrl(const PeerConnectionInterface::IceServer& server,
204 const std::string& url,
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800205 cricket::ServerAddresses* stun_servers,
206 std::vector<cricket::RelayServerConfig>* turn_servers) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000207 // draft-nandakumar-rtcweb-stun-uri-01
208 // stunURI = scheme ":" stun-host [ ":" stun-port ]
209 // scheme = "stun" / "stuns"
210 // stun-host = IP-literal / IPv4address / reg-name
211 // stun-port = *DIGIT
212
213 // draft-petithuguenin-behave-turn-uris-01
214 // turnURI = scheme ":" turn-host [ ":" turn-port ]
215 // [ "?transport=" transport ]
216 // scheme = "turn" / "turns"
217 // transport = "udp" / "tcp" / transport-ext
218 // transport-ext = 1*unreserved
219 // turn-host = IP-literal / IPv4address / reg-name
220 // turn-port = *DIGIT
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800221 RTC_DCHECK(stun_servers != nullptr);
222 RTC_DCHECK(turn_servers != nullptr);
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200223 std::vector<std::string> tokens;
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800224 cricket::ProtocolType turn_transport_type = cricket::PROTO_UDP;
deadbeef0a6c4ca2015-10-06 11:38:28 -0700225 RTC_DCHECK(!url.empty());
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200226 rtc::tokenize(url, '?', &tokens);
227 std::string uri_without_transport = tokens[0];
228 // Let's look into transport= param, if it exists.
229 if (tokens.size() == kTurnTransportTokensNum) { // ?transport= is present.
230 std::string uri_transport_param = tokens[1];
231 rtc::tokenize(uri_transport_param, '=', &tokens);
232 if (tokens[0] == kTransport) {
233 // As per above grammar transport param will be consist of lower case
234 // letters.
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800235 if (!cricket::StringToProto(tokens[1].c_str(), &turn_transport_type) ||
236 (turn_transport_type != cricket::PROTO_UDP &&
237 turn_transport_type != cricket::PROTO_TCP)) {
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200238 LOG(LS_WARNING) << "Transport param should always be udp or tcp.";
deadbeef0a6c4ca2015-10-06 11:38:28 -0700239 return false;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000240 }
241 }
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200242 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000243
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200244 std::string hoststring;
deadbeef0a6c4ca2015-10-06 11:38:28 -0700245 ServiceType service_type;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200246 if (!GetServiceTypeAndHostnameFromUri(uri_without_transport,
247 &service_type,
248 &hoststring)) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700249 LOG(LS_WARNING) << "Invalid transport parameter in ICE URI: " << url;
250 return false;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200251 }
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000252
deadbeef0a6c4ca2015-10-06 11:38:28 -0700253 // GetServiceTypeAndHostnameFromUri should never give an empty hoststring
254 RTC_DCHECK(!hoststring.empty());
Tommi77d444a2015-04-24 15:38:38 +0200255
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200256 // Let's break hostname.
257 tokens.clear();
deadbeef0a6c4ca2015-10-06 11:38:28 -0700258 rtc::tokenize_with_empty_tokens(hoststring, '@', &tokens);
259
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200260 std::string username(server.username);
deadbeef0a6c4ca2015-10-06 11:38:28 -0700261 if (tokens.size() > kTurnHostTokensNum) {
262 LOG(LS_WARNING) << "Invalid user@hostname format: " << hoststring;
263 return false;
264 }
265 if (tokens.size() == kTurnHostTokensNum) {
266 if (tokens[0].empty() || tokens[1].empty()) {
267 LOG(LS_WARNING) << "Invalid user@hostname format: " << hoststring;
268 return false;
269 }
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200270 username.assign(rtc::s_url_decode(tokens[0]));
271 hoststring = tokens[1];
272 } else {
273 hoststring = tokens[0];
274 }
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000275
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200276 int port = kDefaultStunPort;
277 if (service_type == TURNS) {
278 port = kDefaultStunTlsPort;
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800279 turn_transport_type = cricket::PROTO_TCP;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200280 }
sergeyu@chromium.org5bc25c42013-12-05 00:24:06 +0000281
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200282 std::string address;
283 if (!ParseHostnameAndPortFromString(hoststring, &address, &port)) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700284 LOG(WARNING) << "Invalid hostname format: " << uri_without_transport;
285 return false;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200286 }
sergeyu@chromium.orga23f0ca2013-11-13 22:48:52 +0000287
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200288 if (port <= 0 || port > 0xffff) {
289 LOG(WARNING) << "Invalid port: " << port;
deadbeef0a6c4ca2015-10-06 11:38:28 -0700290 return false;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200291 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000292
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200293 switch (service_type) {
294 case STUN:
295 case STUNS:
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800296 stun_servers->insert(rtc::SocketAddress(address, port));
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200297 break;
298 case TURN:
299 case TURNS: {
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200300 bool secure = (service_type == TURNS);
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800301 turn_servers->push_back(
302 cricket::RelayServerConfig(address, port, username, server.password,
303 turn_transport_type, secure));
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200304 break;
305 }
306 case INVALID:
307 default:
308 LOG(WARNING) << "Configuration not supported: " << url;
309 return false;
310 }
311 return true;
312}
313
deadbeefab9b2d12015-10-14 11:33:11 -0700314// Check if we can send |new_stream| on a PeerConnection.
315bool CanAddLocalMediaStream(webrtc::StreamCollectionInterface* current_streams,
316 webrtc::MediaStreamInterface* new_stream) {
317 if (!new_stream || !current_streams) {
318 return false;
319 }
320 if (current_streams->find(new_stream->label()) != nullptr) {
321 LOG(LS_ERROR) << "MediaStream with label " << new_stream->label()
322 << " is already added.";
323 return false;
324 }
325 return true;
326}
327
328bool MediaContentDirectionHasSend(cricket::MediaContentDirection dir) {
329 return dir == cricket::MD_SENDONLY || dir == cricket::MD_SENDRECV;
330}
331
deadbeef5e97fb52015-10-15 12:49:08 -0700332// If the direction is "recvonly" or "inactive", treat the description
333// as containing no streams.
334// See: https://code.google.com/p/webrtc/issues/detail?id=5054
335std::vector<cricket::StreamParams> GetActiveStreams(
336 const cricket::MediaContentDescription* desc) {
337 return MediaContentDirectionHasSend(desc->direction())
338 ? desc->streams()
339 : std::vector<cricket::StreamParams>();
340}
341
deadbeefab9b2d12015-10-14 11:33:11 -0700342bool IsValidOfferToReceiveMedia(int value) {
343 typedef PeerConnectionInterface::RTCOfferAnswerOptions Options;
344 return (value >= Options::kUndefined) &&
345 (value <= Options::kMaxOfferToReceiveMedia);
346}
347
348// Add the stream and RTP data channel info to |session_options|.
deadbeeffac06552015-11-25 11:26:01 -0800349void AddSendStreams(
350 cricket::MediaSessionOptions* session_options,
351 const std::vector<rtc::scoped_refptr<RtpSenderInterface>>& senders,
352 const std::map<std::string, rtc::scoped_refptr<DataChannel>>&
353 rtp_data_channels) {
deadbeefab9b2d12015-10-14 11:33:11 -0700354 session_options->streams.clear();
deadbeeffac06552015-11-25 11:26:01 -0800355 for (const auto& sender : senders) {
356 session_options->AddSendStream(sender->media_type(), sender->id(),
357 sender->stream_id());
deadbeefab9b2d12015-10-14 11:33:11 -0700358 }
359
360 // Check for data channels.
361 for (const auto& kv : rtp_data_channels) {
362 const DataChannel* channel = kv.second;
363 if (channel->state() == DataChannel::kConnecting ||
364 channel->state() == DataChannel::kOpen) {
365 // |streamid| and |sync_label| are both set to the DataChannel label
366 // here so they can be signaled the same way as MediaStreams and Tracks.
367 // For MediaStreams, the sync_label is the MediaStream label and the
368 // track label is the same as |streamid|.
369 const std::string& streamid = channel->label();
370 const std::string& sync_label = channel->label();
371 session_options->AddSendStream(cricket::MEDIA_TYPE_DATA, streamid,
372 sync_label);
373 }
374 }
375}
376
deadbeef0a6c4ca2015-10-06 11:38:28 -0700377} // namespace
378
379namespace webrtc {
380
deadbeefab9b2d12015-10-14 11:33:11 -0700381// Factory class for creating remote MediaStreams and MediaStreamTracks.
382class RemoteMediaStreamFactory {
383 public:
384 explicit RemoteMediaStreamFactory(rtc::Thread* signaling_thread,
Per0f13ec12016-03-03 09:22:28 +0100385 rtc::Thread* worker_thread)
deadbeefab9b2d12015-10-14 11:33:11 -0700386 : signaling_thread_(signaling_thread),
Per0f13ec12016-03-03 09:22:28 +0100387 worker_thread_(worker_thread) {}
deadbeefab9b2d12015-10-14 11:33:11 -0700388
389 rtc::scoped_refptr<MediaStreamInterface> CreateMediaStream(
390 const std::string& stream_label) {
391 return MediaStreamProxy::Create(signaling_thread_,
392 MediaStream::Create(stream_label));
393 }
394
Tommif888bb52015-12-12 01:37:01 +0100395 AudioTrackInterface* AddAudioTrack(uint32_t ssrc,
396 AudioProviderInterface* provider,
397 webrtc::MediaStreamInterface* stream,
deadbeefab9b2d12015-10-14 11:33:11 -0700398 const std::string& track_id) {
tommi6eca7e32015-12-15 04:27:11 -0800399 return AddTrack<AudioTrackInterface, AudioTrack, AudioTrackProxy>(
Tommif888bb52015-12-12 01:37:01 +0100400 stream, track_id, RemoteAudioSource::Create(ssrc, provider));
deadbeefab9b2d12015-10-14 11:33:11 -0700401 }
402
403 VideoTrackInterface* AddVideoTrack(webrtc::MediaStreamInterface* stream,
404 const std::string& track_id) {
405 return AddTrack<VideoTrackInterface, VideoTrack, VideoTrackProxy>(
406 stream, track_id,
perkja3ede6c2016-03-08 01:27:48 +0100407 VideoCapturerTrackSource::Create(
408 worker_thread_, new RemoteVideoCapturer(), nullptr, true)
deadbeefab9b2d12015-10-14 11:33:11 -0700409 .get());
410 }
411
412 private:
413 template <typename TI, typename T, typename TP, typename S>
414 TI* AddTrack(MediaStreamInterface* stream,
415 const std::string& track_id,
Tommif888bb52015-12-12 01:37:01 +0100416 const S& source) {
deadbeefab9b2d12015-10-14 11:33:11 -0700417 rtc::scoped_refptr<TI> track(
418 TP::Create(signaling_thread_, T::Create(track_id, source)));
419 track->set_state(webrtc::MediaStreamTrackInterface::kLive);
420 if (stream->AddTrack(track)) {
421 return track;
422 }
423 return nullptr;
424 }
425
426 rtc::Thread* signaling_thread_;
Per0f13ec12016-03-03 09:22:28 +0100427 rtc::Thread* worker_thread_;
deadbeefab9b2d12015-10-14 11:33:11 -0700428};
429
htaa2a49d92016-03-04 02:51:39 -0800430bool ExtractMediaSessionOptions(
deadbeefab9b2d12015-10-14 11:33:11 -0700431 const PeerConnectionInterface::RTCOfferAnswerOptions& rtc_options,
432 cricket::MediaSessionOptions* session_options) {
433 typedef PeerConnectionInterface::RTCOfferAnswerOptions RTCOfferAnswerOptions;
434 if (!IsValidOfferToReceiveMedia(rtc_options.offer_to_receive_audio) ||
435 !IsValidOfferToReceiveMedia(rtc_options.offer_to_receive_video)) {
436 return false;
437 }
438
deadbeefc80741f2015-10-22 13:14:45 -0700439 if (rtc_options.offer_to_receive_audio != RTCOfferAnswerOptions::kUndefined) {
deadbeefab9b2d12015-10-14 11:33:11 -0700440 session_options->recv_audio = (rtc_options.offer_to_receive_audio > 0);
441 }
deadbeefc80741f2015-10-22 13:14:45 -0700442 if (rtc_options.offer_to_receive_video != RTCOfferAnswerOptions::kUndefined) {
deadbeefab9b2d12015-10-14 11:33:11 -0700443 session_options->recv_video = (rtc_options.offer_to_receive_video > 0);
444 }
445
446 session_options->vad_enabled = rtc_options.voice_activity_detection;
deadbeefc80741f2015-10-22 13:14:45 -0700447 session_options->bundle_enabled = rtc_options.use_rtp_mux;
deadbeef0ed85b22016-02-23 17:24:52 -0800448 for (auto& kv : session_options->transport_options) {
449 kv.second.ice_restart = rtc_options.ice_restart;
450 }
deadbeefab9b2d12015-10-14 11:33:11 -0700451
452 return true;
453}
454
455bool ParseConstraintsForAnswer(const MediaConstraintsInterface* constraints,
456 cricket::MediaSessionOptions* session_options) {
457 bool value = false;
458 size_t mandatory_constraints_satisfied = 0;
459
460 // kOfferToReceiveAudio defaults to true according to spec.
461 if (!FindConstraint(constraints,
462 MediaConstraintsInterface::kOfferToReceiveAudio, &value,
463 &mandatory_constraints_satisfied) ||
464 value) {
465 session_options->recv_audio = true;
466 }
467
468 // kOfferToReceiveVideo defaults to false according to spec. But
469 // if it is an answer and video is offered, we should still accept video
470 // per default.
471 value = false;
472 if (!FindConstraint(constraints,
473 MediaConstraintsInterface::kOfferToReceiveVideo, &value,
474 &mandatory_constraints_satisfied) ||
475 value) {
476 session_options->recv_video = true;
477 }
478
479 if (FindConstraint(constraints,
480 MediaConstraintsInterface::kVoiceActivityDetection, &value,
481 &mandatory_constraints_satisfied)) {
482 session_options->vad_enabled = value;
483 }
484
485 if (FindConstraint(constraints, MediaConstraintsInterface::kUseRtpMux, &value,
486 &mandatory_constraints_satisfied)) {
487 session_options->bundle_enabled = value;
488 } else {
489 // kUseRtpMux defaults to true according to spec.
490 session_options->bundle_enabled = true;
491 }
deadbeefab9b2d12015-10-14 11:33:11 -0700492
deadbeef0ed85b22016-02-23 17:24:52 -0800493 bool ice_restart = false;
deadbeefab9b2d12015-10-14 11:33:11 -0700494 if (FindConstraint(constraints, MediaConstraintsInterface::kIceRestart,
495 &value, &mandatory_constraints_satisfied)) {
deadbeefab9b2d12015-10-14 11:33:11 -0700496 // kIceRestart defaults to false according to spec.
deadbeef0ed85b22016-02-23 17:24:52 -0800497 ice_restart = true;
498 }
499 for (auto& kv : session_options->transport_options) {
500 kv.second.ice_restart = ice_restart;
deadbeefab9b2d12015-10-14 11:33:11 -0700501 }
502
503 if (!constraints) {
504 return true;
505 }
506 return mandatory_constraints_satisfied == constraints->GetMandatory().size();
507}
508
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200509bool ParseIceServers(const PeerConnectionInterface::IceServers& servers,
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800510 cricket::ServerAddresses* stun_servers,
511 std::vector<cricket::RelayServerConfig>* turn_servers) {
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200512 for (const webrtc::PeerConnectionInterface::IceServer& server : servers) {
513 if (!server.urls.empty()) {
514 for (const std::string& url : server.urls) {
Joachim Bauchd935f912015-05-29 22:14:21 +0200515 if (url.empty()) {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700516 LOG(LS_ERROR) << "Empty uri.";
517 return false;
Joachim Bauchd935f912015-05-29 22:14:21 +0200518 }
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800519 if (!ParseIceServerUrl(server, url, stun_servers, turn_servers)) {
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200520 return false;
521 }
522 }
523 } else if (!server.uri.empty()) {
524 // Fallback to old .uri if new .urls isn't present.
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800525 if (!ParseIceServerUrl(server, server.uri, stun_servers, turn_servers)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000526 return false;
Joachim Bauch7c4e7452015-05-28 23:06:30 +0200527 }
528 } else {
deadbeef0a6c4ca2015-10-06 11:38:28 -0700529 LOG(LS_ERROR) << "Empty uri.";
530 return false;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000531 }
532 }
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800533 // Candidates must have unique priorities, so that connectivity checks
534 // are performed in a well-defined order.
535 int priority = static_cast<int>(turn_servers->size() - 1);
536 for (cricket::RelayServerConfig& turn_server : *turn_servers) {
537 // First in the list gets highest priority.
538 turn_server.priority = priority--;
539 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000540 return true;
541}
542
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000543PeerConnection::PeerConnection(PeerConnectionFactory* factory)
544 : factory_(factory),
545 observer_(NULL),
buildbot@webrtc.org1567b8c2014-05-08 19:54:16 +0000546 uma_observer_(NULL),
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000547 signaling_state_(kStable),
548 ice_state_(kIceNew),
549 ice_connection_state_(kIceConnectionNew),
deadbeefab9b2d12015-10-14 11:33:11 -0700550 ice_gathering_state_(kIceGatheringNew),
551 local_streams_(StreamCollection::Create()),
552 remote_streams_(StreamCollection::Create()) {}
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000553
554PeerConnection::~PeerConnection() {
Peter Boström1a9d6152015-12-08 22:15:17 +0100555 TRACE_EVENT0("webrtc", "PeerConnection::~PeerConnection");
deadbeef0a6c4ca2015-10-06 11:38:28 -0700556 RTC_DCHECK(signaling_thread()->IsCurrent());
deadbeef70ab1a12015-09-28 16:53:55 -0700557 // Need to detach RTP senders/receivers from WebRtcSession,
558 // since it's about to be destroyed.
559 for (const auto& sender : senders_) {
560 sender->Stop();
561 }
562 for (const auto& receiver : receivers_) {
563 receiver->Stop();
564 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000565}
566
567bool PeerConnection::Initialize(
htaa2a49d92016-03-04 02:51:39 -0800568 const cricket::MediaConfig& media_config,
buildbot@webrtc.org41451d42014-05-03 05:39:45 +0000569 const PeerConnectionInterface::RTCConfiguration& configuration,
deadbeef653b8e02015-11-11 12:55:10 -0800570 rtc::scoped_ptr<cricket::PortAllocator> allocator,
571 rtc::scoped_ptr<DtlsIdentityStoreInterface> dtls_identity_store,
572 PeerConnectionObserver* observer) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100573 TRACE_EVENT0("webrtc", "PeerConnection::Initialize");
deadbeef653b8e02015-11-11 12:55:10 -0800574 RTC_DCHECK(observer != nullptr);
575 if (!observer) {
576 return false;
577 }
pthatcher@webrtc.org877ac762015-02-04 22:03:09 +0000578 observer_ = observer;
579
kwiberg0eb15ed2015-12-17 03:04:15 -0800580 port_allocator_ = std::move(allocator);
deadbeef653b8e02015-11-11 12:55:10 -0800581
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800582 cricket::ServerAddresses stun_servers;
583 std::vector<cricket::RelayServerConfig> turn_servers;
584 if (!ParseIceServers(configuration.servers, &stun_servers, &turn_servers)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000585 return false;
586 }
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -0800587 port_allocator_->SetIceServers(stun_servers, turn_servers);
henrika@webrtc.orgaebb1ad2014-01-14 10:00:58 +0000588
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000589 // To handle both internal and externally created port allocator, we will
henrika@webrtc.orgaebb1ad2014-01-14 10:00:58 +0000590 // enable BUNDLE here.
braveyao@webrtc.org1732df62014-10-27 03:01:37 +0000591 int portallocator_flags = port_allocator_->flags();
Peter Thatcher7cbd1882015-09-17 18:54:52 -0700592 portallocator_flags |= cricket::PORTALLOCATOR_ENABLE_SHARED_SOCKET |
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000593 cricket::PORTALLOCATOR_ENABLE_IPV6;
htaa2a49d92016-03-04 02:51:39 -0800594 // If the disable-IPv6 flag was specified, we'll not override it
595 // by experiment.
596 if (configuration.disable_ipv6) {
597 portallocator_flags &= ~(cricket::PORTALLOCATOR_ENABLE_IPV6);
guoweis@webrtc.org2c1bcea2014-09-23 16:23:02 +0000598 } else if (webrtc::field_trial::FindFullName("WebRTC-IPv6Default") ==
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000599 "Disabled") {
600 portallocator_flags &= ~(cricket::PORTALLOCATOR_ENABLE_IPV6);
henrika@webrtc.orgaebb1ad2014-01-14 10:00:58 +0000601 }
602
Jiayang Liucac1b382015-04-30 12:35:24 -0700603 if (configuration.tcp_candidate_policy == kTcpCandidatePolicyDisabled) {
604 portallocator_flags |= cricket::PORTALLOCATOR_DISABLE_TCP;
605 LOG(LS_INFO) << "TCP candidates are disabled.";
606 }
607
henrika@webrtc.orgaebb1ad2014-01-14 10:00:58 +0000608 port_allocator_->set_flags(portallocator_flags);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000609 // No step delay is used while allocating ports.
610 port_allocator_->set_step_delay(cricket::kMinimumStepDelay);
611
nisse51542be2016-02-12 02:27:06 -0800612 media_controller_.reset(factory_->CreateMediaController(media_config));
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000613
stefanc1aeaf02015-10-15 07:26:07 -0700614 remote_stream_factory_.reset(new RemoteMediaStreamFactory(
Per0f13ec12016-03-03 09:22:28 +0100615 factory_->signaling_thread(), factory_->worker_thread()));
stefanc1aeaf02015-10-15 07:26:07 -0700616
617 session_.reset(
618 new WebRtcSession(media_controller_.get(), factory_->signaling_thread(),
619 factory_->worker_thread(), port_allocator_.get()));
deadbeefab9b2d12015-10-14 11:33:11 -0700620 stats_.reset(new StatsCollector(this));
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000621
622 // Initialize the WebRtcSession. It creates transport channels etc.
htaa2a49d92016-03-04 02:51:39 -0800623 if (!session_->Initialize(factory_->options(), std::move(dtls_identity_store),
624 configuration)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000625 return false;
deadbeefab9b2d12015-10-14 11:33:11 -0700626 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000627
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000628 // Register PeerConnection as receiver of local ice candidates.
629 // All the callbacks will be posted to the application from PeerConnection.
630 session_->RegisterIceObserver(this);
631 session_->SignalState.connect(this, &PeerConnection::OnSessionStateChange);
deadbeefab9b2d12015-10-14 11:33:11 -0700632 session_->SignalVoiceChannelDestroyed.connect(
633 this, &PeerConnection::OnVoiceChannelDestroyed);
634 session_->SignalVideoChannelDestroyed.connect(
635 this, &PeerConnection::OnVideoChannelDestroyed);
636 session_->SignalDataChannelCreated.connect(
637 this, &PeerConnection::OnDataChannelCreated);
638 session_->SignalDataChannelDestroyed.connect(
639 this, &PeerConnection::OnDataChannelDestroyed);
640 session_->SignalDataChannelOpenMessage.connect(
641 this, &PeerConnection::OnDataChannelOpenMessage);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000642 return true;
643}
644
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000645rtc::scoped_refptr<StreamCollectionInterface>
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000646PeerConnection::local_streams() {
deadbeefab9b2d12015-10-14 11:33:11 -0700647 return local_streams_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000648}
649
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000650rtc::scoped_refptr<StreamCollectionInterface>
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000651PeerConnection::remote_streams() {
deadbeefab9b2d12015-10-14 11:33:11 -0700652 return remote_streams_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000653}
654
perkj@webrtc.orgc2dd5ee2014-11-04 11:31:29 +0000655bool PeerConnection::AddStream(MediaStreamInterface* local_stream) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100656 TRACE_EVENT0("webrtc", "PeerConnection::AddStream");
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000657 if (IsClosed()) {
658 return false;
659 }
deadbeefab9b2d12015-10-14 11:33:11 -0700660 if (!CanAddLocalMediaStream(local_streams_, local_stream)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000661 return false;
662 }
deadbeefab9b2d12015-10-14 11:33:11 -0700663
664 local_streams_->AddStream(local_stream);
deadbeefeb459812015-12-15 19:24:43 -0800665 MediaStreamObserver* observer = new MediaStreamObserver(local_stream);
666 observer->SignalAudioTrackAdded.connect(this,
667 &PeerConnection::OnAudioTrackAdded);
668 observer->SignalAudioTrackRemoved.connect(
669 this, &PeerConnection::OnAudioTrackRemoved);
670 observer->SignalVideoTrackAdded.connect(this,
671 &PeerConnection::OnVideoTrackAdded);
672 observer->SignalVideoTrackRemoved.connect(
673 this, &PeerConnection::OnVideoTrackRemoved);
674 stream_observers_.push_back(rtc::scoped_ptr<MediaStreamObserver>(observer));
deadbeefab9b2d12015-10-14 11:33:11 -0700675
deadbeefab9b2d12015-10-14 11:33:11 -0700676 for (const auto& track : local_stream->GetAudioTracks()) {
deadbeefeb459812015-12-15 19:24:43 -0800677 OnAudioTrackAdded(track.get(), local_stream);
deadbeefab9b2d12015-10-14 11:33:11 -0700678 }
679 for (const auto& track : local_stream->GetVideoTracks()) {
deadbeefeb459812015-12-15 19:24:43 -0800680 OnVideoTrackAdded(track.get(), local_stream);
deadbeefab9b2d12015-10-14 11:33:11 -0700681 }
682
tommi@webrtc.org03505bc2014-07-14 20:15:26 +0000683 stats_->AddStream(local_stream);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000684 observer_->OnRenegotiationNeeded();
685 return true;
686}
687
688void PeerConnection::RemoveStream(MediaStreamInterface* local_stream) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100689 TRACE_EVENT0("webrtc", "PeerConnection::RemoveStream");
deadbeefab9b2d12015-10-14 11:33:11 -0700690 for (const auto& track : local_stream->GetAudioTracks()) {
deadbeefeb459812015-12-15 19:24:43 -0800691 OnAudioTrackRemoved(track.get(), local_stream);
deadbeefab9b2d12015-10-14 11:33:11 -0700692 }
693 for (const auto& track : local_stream->GetVideoTracks()) {
deadbeefeb459812015-12-15 19:24:43 -0800694 OnVideoTrackRemoved(track.get(), local_stream);
deadbeefab9b2d12015-10-14 11:33:11 -0700695 }
696
697 local_streams_->RemoveStream(local_stream);
deadbeefeb459812015-12-15 19:24:43 -0800698 stream_observers_.erase(
699 std::remove_if(
700 stream_observers_.begin(), stream_observers_.end(),
701 [local_stream](const rtc::scoped_ptr<MediaStreamObserver>& observer) {
702 return observer->stream()->label().compare(local_stream->label()) ==
703 0;
704 }),
705 stream_observers_.end());
deadbeefab9b2d12015-10-14 11:33:11 -0700706
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000707 if (IsClosed()) {
708 return;
709 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000710 observer_->OnRenegotiationNeeded();
711}
712
deadbeefe1f9d832016-01-14 15:35:42 -0800713rtc::scoped_refptr<RtpSenderInterface> PeerConnection::AddTrack(
714 MediaStreamTrackInterface* track,
715 std::vector<MediaStreamInterface*> streams) {
716 TRACE_EVENT0("webrtc", "PeerConnection::AddTrack");
717 if (IsClosed()) {
718 return nullptr;
719 }
720 if (streams.size() >= 2) {
721 LOG(LS_ERROR)
722 << "Adding a track with two streams is not currently supported.";
723 return nullptr;
724 }
725 // TODO(deadbeef): Support adding a track to two different senders.
726 if (FindSenderForTrack(track) != senders_.end()) {
727 LOG(LS_ERROR) << "Sender for track " << track->id() << " already exists.";
728 return nullptr;
729 }
730
731 // TODO(deadbeef): Support adding a track to multiple streams.
732 rtc::scoped_refptr<RtpSenderInterface> new_sender;
733 if (track->kind() == MediaStreamTrackInterface::kAudioKind) {
734 new_sender = RtpSenderProxy::Create(
735 signaling_thread(),
736 new AudioRtpSender(static_cast<AudioTrackInterface*>(track),
737 session_.get(), stats_.get()));
738 if (!streams.empty()) {
739 new_sender->set_stream_id(streams[0]->label());
740 }
741 const TrackInfo* track_info = FindTrackInfo(
742 local_audio_tracks_, new_sender->stream_id(), track->id());
743 if (track_info) {
744 new_sender->SetSsrc(track_info->ssrc);
745 }
746 } else if (track->kind() == MediaStreamTrackInterface::kVideoKind) {
747 new_sender = RtpSenderProxy::Create(
748 signaling_thread(),
749 new VideoRtpSender(static_cast<VideoTrackInterface*>(track),
750 session_.get()));
751 if (!streams.empty()) {
752 new_sender->set_stream_id(streams[0]->label());
753 }
754 const TrackInfo* track_info = FindTrackInfo(
755 local_video_tracks_, new_sender->stream_id(), track->id());
756 if (track_info) {
757 new_sender->SetSsrc(track_info->ssrc);
758 }
759 } else {
760 LOG(LS_ERROR) << "CreateSender called with invalid kind: " << track->kind();
761 return rtc::scoped_refptr<RtpSenderInterface>();
762 }
763
764 senders_.push_back(new_sender);
765 observer_->OnRenegotiationNeeded();
766 return new_sender;
767}
768
769bool PeerConnection::RemoveTrack(RtpSenderInterface* sender) {
770 TRACE_EVENT0("webrtc", "PeerConnection::RemoveTrack");
771 if (IsClosed()) {
772 return false;
773 }
774
775 auto it = std::find(senders_.begin(), senders_.end(), sender);
776 if (it == senders_.end()) {
777 LOG(LS_ERROR) << "Couldn't find sender " << sender->id() << " to remove.";
778 return false;
779 }
780 (*it)->Stop();
781 senders_.erase(it);
782
783 observer_->OnRenegotiationNeeded();
784 return true;
785}
786
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000787rtc::scoped_refptr<DtmfSenderInterface> PeerConnection::CreateDtmfSender(
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000788 AudioTrackInterface* track) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100789 TRACE_EVENT0("webrtc", "PeerConnection::CreateDtmfSender");
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000790 if (!track) {
791 LOG(LS_ERROR) << "CreateDtmfSender - track is NULL.";
792 return NULL;
793 }
deadbeefab9b2d12015-10-14 11:33:11 -0700794 if (!local_streams_->FindAudioTrack(track->id())) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000795 LOG(LS_ERROR) << "CreateDtmfSender is called with a non local audio track.";
796 return NULL;
797 }
798
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000799 rtc::scoped_refptr<DtmfSenderInterface> sender(
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000800 DtmfSender::Create(track, signaling_thread(), session_.get()));
801 if (!sender.get()) {
802 LOG(LS_ERROR) << "CreateDtmfSender failed on DtmfSender::Create.";
803 return NULL;
804 }
805 return DtmfSenderProxy::Create(signaling_thread(), sender.get());
806}
807
deadbeeffac06552015-11-25 11:26:01 -0800808rtc::scoped_refptr<RtpSenderInterface> PeerConnection::CreateSender(
deadbeefbd7d8f72015-12-18 16:58:44 -0800809 const std::string& kind,
810 const std::string& stream_id) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100811 TRACE_EVENT0("webrtc", "PeerConnection::CreateSender");
deadbeefe1f9d832016-01-14 15:35:42 -0800812 rtc::scoped_refptr<RtpSenderInterface> new_sender;
deadbeeffac06552015-11-25 11:26:01 -0800813 if (kind == MediaStreamTrackInterface::kAudioKind) {
deadbeefe1f9d832016-01-14 15:35:42 -0800814 new_sender = RtpSenderProxy::Create(
815 signaling_thread(), new AudioRtpSender(session_.get(), stats_.get()));
deadbeeffac06552015-11-25 11:26:01 -0800816 } else if (kind == MediaStreamTrackInterface::kVideoKind) {
deadbeefe1f9d832016-01-14 15:35:42 -0800817 new_sender = RtpSenderProxy::Create(signaling_thread(),
818 new VideoRtpSender(session_.get()));
deadbeeffac06552015-11-25 11:26:01 -0800819 } else {
820 LOG(LS_ERROR) << "CreateSender called with invalid kind: " << kind;
deadbeefe1f9d832016-01-14 15:35:42 -0800821 return new_sender;
deadbeeffac06552015-11-25 11:26:01 -0800822 }
deadbeefbd7d8f72015-12-18 16:58:44 -0800823 if (!stream_id.empty()) {
824 new_sender->set_stream_id(stream_id);
825 }
deadbeeffac06552015-11-25 11:26:01 -0800826 senders_.push_back(new_sender);
deadbeefe1f9d832016-01-14 15:35:42 -0800827 return new_sender;
deadbeeffac06552015-11-25 11:26:01 -0800828}
829
deadbeef70ab1a12015-09-28 16:53:55 -0700830std::vector<rtc::scoped_refptr<RtpSenderInterface>> PeerConnection::GetSenders()
831 const {
deadbeefe1f9d832016-01-14 15:35:42 -0800832 return senders_;
deadbeef70ab1a12015-09-28 16:53:55 -0700833}
834
835std::vector<rtc::scoped_refptr<RtpReceiverInterface>>
836PeerConnection::GetReceivers() const {
deadbeefe1f9d832016-01-14 15:35:42 -0800837 return receivers_;
deadbeef70ab1a12015-09-28 16:53:55 -0700838}
839
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000840bool PeerConnection::GetStats(StatsObserver* observer,
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000841 MediaStreamTrackInterface* track,
842 StatsOutputLevel level) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100843 TRACE_EVENT0("webrtc", "PeerConnection::GetStats");
deadbeef0a6c4ca2015-10-06 11:38:28 -0700844 RTC_DCHECK(signaling_thread()->IsCurrent());
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000845 if (!VERIFY(observer != NULL)) {
846 LOG(LS_ERROR) << "GetStats - observer is NULL.";
847 return false;
848 }
849
tommi@webrtc.org03505bc2014-07-14 20:15:26 +0000850 stats_->UpdateStats(level);
tommi@webrtc.org5b06b062014-08-15 08:38:30 +0000851 signaling_thread()->Post(this, MSG_GETSTATS,
852 new GetStatsMsg(observer, track));
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000853 return true;
854}
855
856PeerConnectionInterface::SignalingState PeerConnection::signaling_state() {
857 return signaling_state_;
858}
859
860PeerConnectionInterface::IceState PeerConnection::ice_state() {
861 return ice_state_;
862}
863
864PeerConnectionInterface::IceConnectionState
865PeerConnection::ice_connection_state() {
866 return ice_connection_state_;
867}
868
869PeerConnectionInterface::IceGatheringState
870PeerConnection::ice_gathering_state() {
871 return ice_gathering_state_;
872}
873
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000874rtc::scoped_refptr<DataChannelInterface>
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000875PeerConnection::CreateDataChannel(
876 const std::string& label,
877 const DataChannelInit* config) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100878 TRACE_EVENT0("webrtc", "PeerConnection::CreateDataChannel");
deadbeefab9b2d12015-10-14 11:33:11 -0700879 bool first_datachannel = !HasDataChannels();
jiayl@webrtc.org001fd2d2014-05-29 15:31:11 +0000880
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000881 rtc::scoped_ptr<InternalDataChannelInit> internal_config;
henrika@webrtc.orgaebb1ad2014-01-14 10:00:58 +0000882 if (config) {
883 internal_config.reset(new InternalDataChannelInit(*config));
884 }
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000885 rtc::scoped_refptr<DataChannelInterface> channel(
deadbeefab9b2d12015-10-14 11:33:11 -0700886 InternalCreateDataChannel(label, internal_config.get()));
887 if (!channel.get()) {
888 return nullptr;
889 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000890
jiayl@webrtc.org001fd2d2014-05-29 15:31:11 +0000891 // Trigger the onRenegotiationNeeded event for every new RTP DataChannel, or
892 // the first SCTP DataChannel.
893 if (session_->data_channel_type() == cricket::DCT_RTP || first_datachannel) {
894 observer_->OnRenegotiationNeeded();
895 }
wu@webrtc.org91053e72013-08-10 07:18:04 +0000896
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000897 return DataChannelProxy::Create(signaling_thread(), channel.get());
898}
899
900void PeerConnection::CreateOffer(CreateSessionDescriptionObserver* observer,
901 const MediaConstraintsInterface* constraints) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100902 TRACE_EVENT0("webrtc", "PeerConnection::CreateOffer");
deadbeefab9b2d12015-10-14 11:33:11 -0700903 if (!VERIFY(observer != nullptr)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000904 LOG(LS_ERROR) << "CreateOffer - observer is NULL.";
905 return;
906 }
jiayl@webrtc.orgb18bf5e2014-08-04 18:34:16 +0000907 RTCOfferAnswerOptions options;
jiayl@webrtc.orgb18bf5e2014-08-04 18:34:16 +0000908
909 bool value;
910 size_t mandatory_constraints = 0;
911
912 if (FindConstraint(constraints,
913 MediaConstraintsInterface::kOfferToReceiveAudio,
914 &value,
915 &mandatory_constraints)) {
916 options.offer_to_receive_audio =
917 value ? RTCOfferAnswerOptions::kOfferToReceiveMediaTrue : 0;
918 }
919
920 if (FindConstraint(constraints,
921 MediaConstraintsInterface::kOfferToReceiveVideo,
922 &value,
923 &mandatory_constraints)) {
924 options.offer_to_receive_video =
925 value ? RTCOfferAnswerOptions::kOfferToReceiveMediaTrue : 0;
926 }
927
928 if (FindConstraint(constraints,
929 MediaConstraintsInterface::kVoiceActivityDetection,
930 &value,
931 &mandatory_constraints)) {
932 options.voice_activity_detection = value;
933 }
934
935 if (FindConstraint(constraints,
936 MediaConstraintsInterface::kIceRestart,
937 &value,
938 &mandatory_constraints)) {
939 options.ice_restart = value;
940 }
941
942 if (FindConstraint(constraints,
943 MediaConstraintsInterface::kUseRtpMux,
944 &value,
945 &mandatory_constraints)) {
946 options.use_rtp_mux = value;
947 }
948
949 CreateOffer(observer, options);
950}
951
952void PeerConnection::CreateOffer(CreateSessionDescriptionObserver* observer,
953 const RTCOfferAnswerOptions& options) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100954 TRACE_EVENT0("webrtc", "PeerConnection::CreateOffer");
deadbeefab9b2d12015-10-14 11:33:11 -0700955 if (!VERIFY(observer != nullptr)) {
jiayl@webrtc.orgb18bf5e2014-08-04 18:34:16 +0000956 LOG(LS_ERROR) << "CreateOffer - observer is NULL.";
957 return;
958 }
deadbeefab9b2d12015-10-14 11:33:11 -0700959
960 cricket::MediaSessionOptions session_options;
961 if (!GetOptionsForOffer(options, &session_options)) {
962 std::string error = "CreateOffer called with invalid options.";
963 LOG(LS_ERROR) << error;
964 PostCreateSessionDescriptionFailure(observer, error);
965 return;
966 }
967
968 session_->CreateOffer(observer, options, session_options);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000969}
970
971void PeerConnection::CreateAnswer(
972 CreateSessionDescriptionObserver* observer,
973 const MediaConstraintsInterface* constraints) {
Peter Boström1a9d6152015-12-08 22:15:17 +0100974 TRACE_EVENT0("webrtc", "PeerConnection::CreateAnswer");
deadbeefab9b2d12015-10-14 11:33:11 -0700975 if (!VERIFY(observer != nullptr)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000976 LOG(LS_ERROR) << "CreateAnswer - observer is NULL.";
977 return;
978 }
deadbeefab9b2d12015-10-14 11:33:11 -0700979
980 cricket::MediaSessionOptions session_options;
981 if (!GetOptionsForAnswer(constraints, &session_options)) {
982 std::string error = "CreateAnswer called with invalid constraints.";
983 LOG(LS_ERROR) << error;
984 PostCreateSessionDescriptionFailure(observer, error);
985 return;
986 }
987
htaa2a49d92016-03-04 02:51:39 -0800988 session_->CreateAnswer(observer, session_options);
989}
990
991void PeerConnection::CreateAnswer(CreateSessionDescriptionObserver* observer,
992 const RTCOfferAnswerOptions& options) {
993 TRACE_EVENT0("webrtc", "PeerConnection::CreateAnswer");
994 if (!VERIFY(observer != nullptr)) {
995 LOG(LS_ERROR) << "CreateAnswer - observer is NULL.";
996 return;
997 }
998
999 cricket::MediaSessionOptions session_options;
1000 if (!GetOptionsForAnswer(options, &session_options)) {
1001 std::string error = "CreateAnswer called with invalid options.";
1002 LOG(LS_ERROR) << error;
1003 PostCreateSessionDescriptionFailure(observer, error);
1004 return;
1005 }
1006
1007 session_->CreateAnswer(observer, session_options);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001008}
1009
1010void PeerConnection::SetLocalDescription(
1011 SetSessionDescriptionObserver* observer,
1012 SessionDescriptionInterface* desc) {
Peter Boström1a9d6152015-12-08 22:15:17 +01001013 TRACE_EVENT0("webrtc", "PeerConnection::SetLocalDescription");
deadbeefab9b2d12015-10-14 11:33:11 -07001014 if (!VERIFY(observer != nullptr)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001015 LOG(LS_ERROR) << "SetLocalDescription - observer is NULL.";
1016 return;
1017 }
1018 if (!desc) {
1019 PostSetSessionDescriptionFailure(observer, "SessionDescription is NULL.");
1020 return;
1021 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001022 // Update stats here so that we have the most recent stats for tracks and
1023 // streams that might be removed by updating the session description.
tommi@webrtc.org03505bc2014-07-14 20:15:26 +00001024 stats_->UpdateStats(kStatsOutputLevelStandard);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001025 std::string error;
1026 if (!session_->SetLocalDescription(desc, &error)) {
1027 PostSetSessionDescriptionFailure(observer, error);
1028 return;
1029 }
deadbeefab9b2d12015-10-14 11:33:11 -07001030
1031 // If setting the description decided our SSL role, allocate any necessary
1032 // SCTP sids.
1033 rtc::SSLRole role;
1034 if (session_->data_channel_type() == cricket::DCT_SCTP &&
Taylor Brandstetterf475d362016-01-08 15:35:57 -08001035 session_->GetSslRole(session_->data_channel(), &role)) {
deadbeefab9b2d12015-10-14 11:33:11 -07001036 AllocateSctpSids(role);
1037 }
1038
1039 // Update state and SSRC of local MediaStreams and DataChannels based on the
1040 // local session description.
1041 const cricket::ContentInfo* audio_content =
1042 GetFirstAudioContent(desc->description());
1043 if (audio_content) {
deadbeeffaac4972015-11-12 15:33:07 -08001044 if (audio_content->rejected) {
1045 RemoveTracks(cricket::MEDIA_TYPE_AUDIO);
1046 } else {
1047 const cricket::AudioContentDescription* audio_desc =
1048 static_cast<const cricket::AudioContentDescription*>(
1049 audio_content->description);
1050 UpdateLocalTracks(audio_desc->streams(), audio_desc->type());
1051 }
deadbeefab9b2d12015-10-14 11:33:11 -07001052 }
1053
1054 const cricket::ContentInfo* video_content =
1055 GetFirstVideoContent(desc->description());
1056 if (video_content) {
deadbeeffaac4972015-11-12 15:33:07 -08001057 if (video_content->rejected) {
1058 RemoveTracks(cricket::MEDIA_TYPE_VIDEO);
1059 } else {
1060 const cricket::VideoContentDescription* video_desc =
1061 static_cast<const cricket::VideoContentDescription*>(
1062 video_content->description);
1063 UpdateLocalTracks(video_desc->streams(), video_desc->type());
1064 }
deadbeefab9b2d12015-10-14 11:33:11 -07001065 }
1066
1067 const cricket::ContentInfo* data_content =
1068 GetFirstDataContent(desc->description());
1069 if (data_content) {
1070 const cricket::DataContentDescription* data_desc =
1071 static_cast<const cricket::DataContentDescription*>(
1072 data_content->description);
1073 if (rtc::starts_with(data_desc->protocol().data(),
1074 cricket::kMediaProtocolRtpPrefix)) {
1075 UpdateLocalRtpDataChannels(data_desc->streams());
1076 }
1077 }
1078
1079 SetSessionDescriptionMsg* msg = new SetSessionDescriptionMsg(observer);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001080 signaling_thread()->Post(this, MSG_SET_SESSIONDESCRIPTION_SUCCESS, msg);
deadbeefab9b2d12015-10-14 11:33:11 -07001081
deadbeefcbecd352015-09-23 11:50:27 -07001082 // MaybeStartGathering needs to be called after posting
1083 // MSG_SET_SESSIONDESCRIPTION_SUCCESS, so that we don't signal any candidates
1084 // before signaling that SetLocalDescription completed.
1085 session_->MaybeStartGathering();
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001086}
1087
1088void PeerConnection::SetRemoteDescription(
1089 SetSessionDescriptionObserver* observer,
1090 SessionDescriptionInterface* desc) {
Peter Boström1a9d6152015-12-08 22:15:17 +01001091 TRACE_EVENT0("webrtc", "PeerConnection::SetRemoteDescription");
deadbeefab9b2d12015-10-14 11:33:11 -07001092 if (!VERIFY(observer != nullptr)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001093 LOG(LS_ERROR) << "SetRemoteDescription - observer is NULL.";
1094 return;
1095 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001096 if (!desc) {
1097 PostSetSessionDescriptionFailure(observer, "SessionDescription is NULL.");
1098 return;
1099 }
1100 // Update stats here so that we have the most recent stats for tracks and
1101 // streams that might be removed by updating the session description.
tommi@webrtc.org03505bc2014-07-14 20:15:26 +00001102 stats_->UpdateStats(kStatsOutputLevelStandard);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001103 std::string error;
1104 if (!session_->SetRemoteDescription(desc, &error)) {
1105 PostSetSessionDescriptionFailure(observer, error);
1106 return;
1107 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001108
deadbeefab9b2d12015-10-14 11:33:11 -07001109 // If setting the description decided our SSL role, allocate any necessary
1110 // SCTP sids.
1111 rtc::SSLRole role;
1112 if (session_->data_channel_type() == cricket::DCT_SCTP &&
Taylor Brandstetterf475d362016-01-08 15:35:57 -08001113 session_->GetSslRole(session_->data_channel(), &role)) {
deadbeefab9b2d12015-10-14 11:33:11 -07001114 AllocateSctpSids(role);
1115 }
1116
1117 const cricket::SessionDescription* remote_desc = desc->description();
deadbeefbda7e0b2015-12-08 17:13:40 -08001118 const cricket::ContentInfo* audio_content = GetFirstAudioContent(remote_desc);
1119 const cricket::ContentInfo* video_content = GetFirstVideoContent(remote_desc);
1120 const cricket::AudioContentDescription* audio_desc =
1121 GetFirstAudioContentDescription(remote_desc);
1122 const cricket::VideoContentDescription* video_desc =
1123 GetFirstVideoContentDescription(remote_desc);
1124 const cricket::DataContentDescription* data_desc =
1125 GetFirstDataContentDescription(remote_desc);
1126
1127 // Check if the descriptions include streams, just in case the peer supports
1128 // MSID, but doesn't indicate so with "a=msid-semantic".
1129 if (remote_desc->msid_supported() ||
1130 (audio_desc && !audio_desc->streams().empty()) ||
1131 (video_desc && !video_desc->streams().empty())) {
1132 remote_peer_supports_msid_ = true;
1133 }
deadbeefab9b2d12015-10-14 11:33:11 -07001134
1135 // We wait to signal new streams until we finish processing the description,
1136 // since only at that point will new streams have all their tracks.
1137 rtc::scoped_refptr<StreamCollection> new_streams(StreamCollection::Create());
1138
1139 // Find all audio rtp streams and create corresponding remote AudioTracks
1140 // and MediaStreams.
deadbeefab9b2d12015-10-14 11:33:11 -07001141 if (audio_content) {
deadbeeffaac4972015-11-12 15:33:07 -08001142 if (audio_content->rejected) {
1143 RemoveTracks(cricket::MEDIA_TYPE_AUDIO);
1144 } else {
deadbeefbda7e0b2015-12-08 17:13:40 -08001145 bool default_audio_track_needed =
1146 !remote_peer_supports_msid_ &&
1147 MediaContentDirectionHasSend(audio_desc->direction());
1148 UpdateRemoteStreamsList(GetActiveStreams(audio_desc),
1149 default_audio_track_needed, audio_desc->type(),
deadbeeffaac4972015-11-12 15:33:07 -08001150 new_streams);
deadbeeffaac4972015-11-12 15:33:07 -08001151 }
deadbeefab9b2d12015-10-14 11:33:11 -07001152 }
1153
1154 // Find all video rtp streams and create corresponding remote VideoTracks
1155 // and MediaStreams.
deadbeefab9b2d12015-10-14 11:33:11 -07001156 if (video_content) {
deadbeeffaac4972015-11-12 15:33:07 -08001157 if (video_content->rejected) {
1158 RemoveTracks(cricket::MEDIA_TYPE_VIDEO);
1159 } else {
deadbeefbda7e0b2015-12-08 17:13:40 -08001160 bool default_video_track_needed =
1161 !remote_peer_supports_msid_ &&
1162 MediaContentDirectionHasSend(video_desc->direction());
1163 UpdateRemoteStreamsList(GetActiveStreams(video_desc),
1164 default_video_track_needed, video_desc->type(),
deadbeeffaac4972015-11-12 15:33:07 -08001165 new_streams);
deadbeeffaac4972015-11-12 15:33:07 -08001166 }
deadbeefab9b2d12015-10-14 11:33:11 -07001167 }
1168
1169 // Update the DataChannels with the information from the remote peer.
deadbeefbda7e0b2015-12-08 17:13:40 -08001170 if (data_desc) {
1171 if (rtc::starts_with(data_desc->protocol().data(),
deadbeefab9b2d12015-10-14 11:33:11 -07001172 cricket::kMediaProtocolRtpPrefix)) {
deadbeefbda7e0b2015-12-08 17:13:40 -08001173 UpdateRemoteRtpDataChannels(GetActiveStreams(data_desc));
deadbeefab9b2d12015-10-14 11:33:11 -07001174 }
1175 }
1176
1177 // Iterate new_streams and notify the observer about new MediaStreams.
1178 for (size_t i = 0; i < new_streams->count(); ++i) {
1179 MediaStreamInterface* new_stream = new_streams->at(i);
1180 stats_->AddStream(new_stream);
1181 observer_->OnAddStream(new_stream);
1182 }
1183
deadbeefbda7e0b2015-12-08 17:13:40 -08001184 UpdateEndedRemoteMediaStreams();
deadbeefab9b2d12015-10-14 11:33:11 -07001185
1186 SetSessionDescriptionMsg* msg = new SetSessionDescriptionMsg(observer);
1187 signaling_thread()->Post(this, MSG_SET_SESSIONDESCRIPTION_SUCCESS, msg);
deadbeeffc648b62015-10-13 16:42:33 -07001188}
1189
deadbeefa67696b2015-09-29 11:56:26 -07001190bool PeerConnection::SetConfiguration(const RTCConfiguration& config) {
Peter Boström1a9d6152015-12-08 22:15:17 +01001191 TRACE_EVENT0("webrtc", "PeerConnection::SetConfiguration");
buildbot@webrtc.org41451d42014-05-03 05:39:45 +00001192 if (port_allocator_) {
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -08001193 cricket::ServerAddresses stun_servers;
1194 std::vector<cricket::RelayServerConfig> turn_servers;
1195 if (!ParseIceServers(config.servers, &stun_servers, &turn_servers)) {
buildbot@webrtc.org41451d42014-05-03 05:39:45 +00001196 return false;
1197 }
Taylor Brandstetter0c7e9f52015-12-29 14:14:52 -08001198 port_allocator_->SetIceServers(stun_servers, turn_servers);
buildbot@webrtc.org41451d42014-05-03 05:39:45 +00001199 }
honghaiz1f429e32015-09-28 07:57:34 -07001200 session_->SetIceConfig(session_->ParseIceConfig(config));
mallinath@webrtc.org3d81b1b2014-09-09 14:38:10 +00001201 return session_->SetIceTransports(config.type);
buildbot@webrtc.org41451d42014-05-03 05:39:45 +00001202}
1203
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001204bool PeerConnection::AddIceCandidate(
1205 const IceCandidateInterface* ice_candidate) {
Peter Boström1a9d6152015-12-08 22:15:17 +01001206 TRACE_EVENT0("webrtc", "PeerConnection::AddIceCandidate");
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001207 return session_->ProcessIceMessage(ice_candidate);
1208}
1209
buildbot@webrtc.org1567b8c2014-05-08 19:54:16 +00001210void PeerConnection::RegisterUMAObserver(UMAObserver* observer) {
Peter Boström1a9d6152015-12-08 22:15:17 +01001211 TRACE_EVENT0("webrtc", "PeerConnection::RegisterUmaObserver");
buildbot@webrtc.org1567b8c2014-05-08 19:54:16 +00001212 uma_observer_ = observer;
guoweis@webrtc.org7169afd2014-12-04 17:59:29 +00001213
1214 if (session_) {
1215 session_->set_metrics_observer(uma_observer_);
1216 }
1217
mallinath@webrtc.orgd37bcfa2014-05-12 23:10:18 +00001218 // Send information about IPv4/IPv6 status.
1219 if (uma_observer_ && port_allocator_) {
1220 if (port_allocator_->flags() & cricket::PORTALLOCATOR_ENABLE_IPV6) {
Guo-wei Shiehdfbe6792015-09-03 17:12:07 -07001221 uma_observer_->IncrementEnumCounter(
1222 kEnumCounterAddressFamily, kPeerConnection_IPv6,
1223 kPeerConnectionAddressFamilyCounter_Max);
mallinath@webrtc.orgb445f262014-05-23 22:19:37 +00001224 } else {
Guo-wei Shiehdfbe6792015-09-03 17:12:07 -07001225 uma_observer_->IncrementEnumCounter(
1226 kEnumCounterAddressFamily, kPeerConnection_IPv4,
1227 kPeerConnectionAddressFamilyCounter_Max);
mallinath@webrtc.orgd37bcfa2014-05-12 23:10:18 +00001228 }
1229 }
buildbot@webrtc.org1567b8c2014-05-08 19:54:16 +00001230}
1231
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001232const SessionDescriptionInterface* PeerConnection::local_description() const {
1233 return session_->local_description();
1234}
1235
1236const SessionDescriptionInterface* PeerConnection::remote_description() const {
1237 return session_->remote_description();
1238}
1239
1240void PeerConnection::Close() {
Peter Boström1a9d6152015-12-08 22:15:17 +01001241 TRACE_EVENT0("webrtc", "PeerConnection::Close");
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001242 // Update stats here so that we have the most recent stats for tracks and
1243 // streams before the channels are closed.
tommi@webrtc.org03505bc2014-07-14 20:15:26 +00001244 stats_->UpdateStats(kStatsOutputLevelStandard);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001245
deadbeefd59daf82015-10-14 15:02:44 -07001246 session_->Close();
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001247}
1248
deadbeefd59daf82015-10-14 15:02:44 -07001249void PeerConnection::OnSessionStateChange(WebRtcSession* /*session*/,
1250 WebRtcSession::State state) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001251 switch (state) {
deadbeefd59daf82015-10-14 15:02:44 -07001252 case WebRtcSession::STATE_INIT:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001253 ChangeSignalingState(PeerConnectionInterface::kStable);
mallinath@webrtc.org19f27e62013-10-13 17:18:27 +00001254 break;
deadbeefd59daf82015-10-14 15:02:44 -07001255 case WebRtcSession::STATE_SENTOFFER:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001256 ChangeSignalingState(PeerConnectionInterface::kHaveLocalOffer);
1257 break;
deadbeefd59daf82015-10-14 15:02:44 -07001258 case WebRtcSession::STATE_SENTPRANSWER:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001259 ChangeSignalingState(PeerConnectionInterface::kHaveLocalPrAnswer);
1260 break;
deadbeefd59daf82015-10-14 15:02:44 -07001261 case WebRtcSession::STATE_RECEIVEDOFFER:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001262 ChangeSignalingState(PeerConnectionInterface::kHaveRemoteOffer);
1263 break;
deadbeefd59daf82015-10-14 15:02:44 -07001264 case WebRtcSession::STATE_RECEIVEDPRANSWER:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001265 ChangeSignalingState(PeerConnectionInterface::kHaveRemotePrAnswer);
1266 break;
deadbeefd59daf82015-10-14 15:02:44 -07001267 case WebRtcSession::STATE_INPROGRESS:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001268 ChangeSignalingState(PeerConnectionInterface::kStable);
1269 break;
deadbeefd59daf82015-10-14 15:02:44 -07001270 case WebRtcSession::STATE_CLOSED:
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001271 ChangeSignalingState(PeerConnectionInterface::kClosed);
1272 break;
1273 default:
1274 break;
1275 }
1276}
1277
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001278void PeerConnection::OnMessage(rtc::Message* msg) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001279 switch (msg->message_id) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001280 case MSG_SET_SESSIONDESCRIPTION_SUCCESS: {
1281 SetSessionDescriptionMsg* param =
1282 static_cast<SetSessionDescriptionMsg*>(msg->pdata);
1283 param->observer->OnSuccess();
1284 delete param;
1285 break;
1286 }
1287 case MSG_SET_SESSIONDESCRIPTION_FAILED: {
1288 SetSessionDescriptionMsg* param =
1289 static_cast<SetSessionDescriptionMsg*>(msg->pdata);
1290 param->observer->OnFailure(param->error);
1291 delete param;
1292 break;
1293 }
deadbeefab9b2d12015-10-14 11:33:11 -07001294 case MSG_CREATE_SESSIONDESCRIPTION_FAILED: {
1295 CreateSessionDescriptionMsg* param =
1296 static_cast<CreateSessionDescriptionMsg*>(msg->pdata);
1297 param->observer->OnFailure(param->error);
1298 delete param;
1299 break;
1300 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001301 case MSG_GETSTATS: {
1302 GetStatsMsg* param = static_cast<GetStatsMsg*>(msg->pdata);
tommi@webrtc.org5b06b062014-08-15 08:38:30 +00001303 StatsReports reports;
1304 stats_->GetStats(param->track, &reports);
1305 param->observer->OnComplete(reports);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001306 delete param;
1307 break;
1308 }
deadbeefbd292462015-12-14 18:15:29 -08001309 case MSG_FREE_DATACHANNELS: {
1310 sctp_data_channels_to_free_.clear();
1311 break;
1312 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001313 default:
deadbeef0a6c4ca2015-10-06 11:38:28 -07001314 RTC_DCHECK(false && "Not implemented");
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001315 break;
1316 }
1317}
1318
deadbeefab9b2d12015-10-14 11:33:11 -07001319void PeerConnection::CreateAudioReceiver(MediaStreamInterface* stream,
1320 AudioTrackInterface* audio_track,
1321 uint32_t ssrc) {
deadbeefe1f9d832016-01-14 15:35:42 -08001322 receivers_.push_back(RtpReceiverProxy::Create(
1323 signaling_thread(),
1324 new AudioRtpReceiver(audio_track, ssrc, session_.get())));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001325}
1326
deadbeefab9b2d12015-10-14 11:33:11 -07001327void PeerConnection::CreateVideoReceiver(MediaStreamInterface* stream,
1328 VideoTrackInterface* video_track,
1329 uint32_t ssrc) {
deadbeefe1f9d832016-01-14 15:35:42 -08001330 receivers_.push_back(RtpReceiverProxy::Create(
1331 signaling_thread(),
1332 new VideoRtpReceiver(video_track, ssrc, session_.get())));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001333}
1334
deadbeef70ab1a12015-09-28 16:53:55 -07001335// TODO(deadbeef): Keep RtpReceivers around even if track goes away in remote
1336// description.
deadbeefab9b2d12015-10-14 11:33:11 -07001337void PeerConnection::DestroyAudioReceiver(MediaStreamInterface* stream,
1338 AudioTrackInterface* audio_track) {
deadbeef70ab1a12015-09-28 16:53:55 -07001339 auto it = FindReceiverForTrack(audio_track);
1340 if (it == receivers_.end()) {
1341 LOG(LS_WARNING) << "RtpReceiver for track with id " << audio_track->id()
1342 << " doesn't exist.";
1343 } else {
1344 (*it)->Stop();
1345 receivers_.erase(it);
1346 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001347}
1348
deadbeefab9b2d12015-10-14 11:33:11 -07001349void PeerConnection::DestroyVideoReceiver(MediaStreamInterface* stream,
1350 VideoTrackInterface* video_track) {
deadbeef70ab1a12015-09-28 16:53:55 -07001351 auto it = FindReceiverForTrack(video_track);
1352 if (it == receivers_.end()) {
1353 LOG(LS_WARNING) << "RtpReceiver for track with id " << video_track->id()
1354 << " doesn't exist.";
1355 } else {
1356 (*it)->Stop();
1357 receivers_.erase(it);
1358 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001359}
deadbeef70ab1a12015-09-28 16:53:55 -07001360
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001361void PeerConnection::OnIceConnectionChange(
1362 PeerConnectionInterface::IceConnectionState new_state) {
deadbeef0a6c4ca2015-10-06 11:38:28 -07001363 RTC_DCHECK(signaling_thread()->IsCurrent());
deadbeefcbecd352015-09-23 11:50:27 -07001364 // After transitioning to "closed", ignore any additional states from
1365 // WebRtcSession (such as "disconnected").
deadbeefab9b2d12015-10-14 11:33:11 -07001366 if (IsClosed()) {
deadbeefcbecd352015-09-23 11:50:27 -07001367 return;
1368 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001369 ice_connection_state_ = new_state;
mallinath@webrtc.orgd3dc4242014-03-01 00:05:52 +00001370 observer_->OnIceConnectionChange(ice_connection_state_);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001371}
1372
1373void PeerConnection::OnIceGatheringChange(
1374 PeerConnectionInterface::IceGatheringState new_state) {
deadbeef0a6c4ca2015-10-06 11:38:28 -07001375 RTC_DCHECK(signaling_thread()->IsCurrent());
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001376 if (IsClosed()) {
1377 return;
1378 }
1379 ice_gathering_state_ = new_state;
mallinath@webrtc.orgd3dc4242014-03-01 00:05:52 +00001380 observer_->OnIceGatheringChange(ice_gathering_state_);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001381}
1382
1383void PeerConnection::OnIceCandidate(const IceCandidateInterface* candidate) {
deadbeef0a6c4ca2015-10-06 11:38:28 -07001384 RTC_DCHECK(signaling_thread()->IsCurrent());
mallinath@webrtc.orgd3dc4242014-03-01 00:05:52 +00001385 observer_->OnIceCandidate(candidate);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001386}
1387
Peter Thatcher54360512015-07-08 11:08:35 -07001388void PeerConnection::OnIceConnectionReceivingChange(bool receiving) {
deadbeef0a6c4ca2015-10-06 11:38:28 -07001389 RTC_DCHECK(signaling_thread()->IsCurrent());
Peter Thatcher54360512015-07-08 11:08:35 -07001390 observer_->OnIceConnectionReceivingChange(receiving);
1391}
1392
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001393void PeerConnection::ChangeSignalingState(
1394 PeerConnectionInterface::SignalingState signaling_state) {
1395 signaling_state_ = signaling_state;
1396 if (signaling_state == kClosed) {
1397 ice_connection_state_ = kIceConnectionClosed;
1398 observer_->OnIceConnectionChange(ice_connection_state_);
1399 if (ice_gathering_state_ != kIceGatheringComplete) {
1400 ice_gathering_state_ = kIceGatheringComplete;
1401 observer_->OnIceGatheringChange(ice_gathering_state_);
1402 }
1403 }
1404 observer_->OnSignalingChange(signaling_state_);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001405}
1406
deadbeefeb459812015-12-15 19:24:43 -08001407void PeerConnection::OnAudioTrackAdded(AudioTrackInterface* track,
1408 MediaStreamInterface* stream) {
1409 auto sender = FindSenderForTrack(track);
1410 if (sender != senders_.end()) {
1411 // We already have a sender for this track, so just change the stream_id
1412 // so that it's correct in the next call to CreateOffer.
1413 (*sender)->set_stream_id(stream->label());
1414 return;
1415 }
1416
1417 // Normal case; we've never seen this track before.
deadbeefe1f9d832016-01-14 15:35:42 -08001418 rtc::scoped_refptr<RtpSenderInterface> new_sender = RtpSenderProxy::Create(
1419 signaling_thread(),
1420 new AudioRtpSender(track, stream->label(), session_.get(), stats_.get()));
deadbeefeb459812015-12-15 19:24:43 -08001421 senders_.push_back(new_sender);
1422 // If the sender has already been configured in SDP, we call SetSsrc,
1423 // which will connect the sender to the underlying transport. This can
1424 // occur if a local session description that contains the ID of the sender
1425 // is set before AddStream is called. It can also occur if the local
1426 // session description is not changed and RemoveStream is called, and
1427 // later AddStream is called again with the same stream.
1428 const TrackInfo* track_info =
1429 FindTrackInfo(local_audio_tracks_, stream->label(), track->id());
1430 if (track_info) {
1431 new_sender->SetSsrc(track_info->ssrc);
1432 }
1433}
1434
1435// TODO(deadbeef): Don't destroy RtpSenders here; they should be kept around
1436// indefinitely, when we have unified plan SDP.
1437void PeerConnection::OnAudioTrackRemoved(AudioTrackInterface* track,
1438 MediaStreamInterface* stream) {
1439 auto sender = FindSenderForTrack(track);
1440 if (sender == senders_.end()) {
1441 LOG(LS_WARNING) << "RtpSender for track with id " << track->id()
1442 << " doesn't exist.";
1443 return;
1444 }
1445 (*sender)->Stop();
1446 senders_.erase(sender);
1447}
1448
1449void PeerConnection::OnVideoTrackAdded(VideoTrackInterface* track,
1450 MediaStreamInterface* stream) {
1451 auto sender = FindSenderForTrack(track);
1452 if (sender != senders_.end()) {
1453 // We already have a sender for this track, so just change the stream_id
1454 // so that it's correct in the next call to CreateOffer.
1455 (*sender)->set_stream_id(stream->label());
1456 return;
1457 }
1458
1459 // Normal case; we've never seen this track before.
deadbeefe1f9d832016-01-14 15:35:42 -08001460 rtc::scoped_refptr<RtpSenderInterface> new_sender = RtpSenderProxy::Create(
1461 signaling_thread(),
1462 new VideoRtpSender(track, stream->label(), session_.get()));
deadbeefeb459812015-12-15 19:24:43 -08001463 senders_.push_back(new_sender);
1464 const TrackInfo* track_info =
1465 FindTrackInfo(local_video_tracks_, stream->label(), track->id());
1466 if (track_info) {
1467 new_sender->SetSsrc(track_info->ssrc);
1468 }
1469}
1470
1471void PeerConnection::OnVideoTrackRemoved(VideoTrackInterface* track,
1472 MediaStreamInterface* stream) {
1473 auto sender = FindSenderForTrack(track);
1474 if (sender == senders_.end()) {
1475 LOG(LS_WARNING) << "RtpSender for track with id " << track->id()
1476 << " doesn't exist.";
1477 return;
1478 }
1479 (*sender)->Stop();
1480 senders_.erase(sender);
1481}
1482
deadbeefab9b2d12015-10-14 11:33:11 -07001483void PeerConnection::PostSetSessionDescriptionFailure(
1484 SetSessionDescriptionObserver* observer,
1485 const std::string& error) {
1486 SetSessionDescriptionMsg* msg = new SetSessionDescriptionMsg(observer);
1487 msg->error = error;
1488 signaling_thread()->Post(this, MSG_SET_SESSIONDESCRIPTION_FAILED, msg);
1489}
1490
1491void PeerConnection::PostCreateSessionDescriptionFailure(
1492 CreateSessionDescriptionObserver* observer,
1493 const std::string& error) {
1494 CreateSessionDescriptionMsg* msg = new CreateSessionDescriptionMsg(observer);
1495 msg->error = error;
1496 signaling_thread()->Post(this, MSG_CREATE_SESSIONDESCRIPTION_FAILED, msg);
1497}
1498
1499bool PeerConnection::GetOptionsForOffer(
1500 const PeerConnectionInterface::RTCOfferAnswerOptions& rtc_options,
1501 cricket::MediaSessionOptions* session_options) {
deadbeef0ed85b22016-02-23 17:24:52 -08001502 // TODO(deadbeef): Once we have transceivers, enumerate them here instead of
1503 // ContentInfos.
1504 if (session_->local_description()) {
1505 for (const cricket::ContentInfo& content :
1506 session_->local_description()->description()->contents()) {
1507 session_options->transport_options[content.name] =
1508 cricket::TransportOptions();
1509 }
1510 }
htaa2a49d92016-03-04 02:51:39 -08001511 if (!ExtractMediaSessionOptions(rtc_options, session_options)) {
deadbeefab9b2d12015-10-14 11:33:11 -07001512 return false;
1513 }
1514
deadbeeffac06552015-11-25 11:26:01 -08001515 AddSendStreams(session_options, senders_, rtp_data_channels_);
deadbeefc80741f2015-10-22 13:14:45 -07001516 // Offer to receive audio/video if the constraint is not set and there are
1517 // send streams, or we're currently receiving.
1518 if (rtc_options.offer_to_receive_audio == RTCOfferAnswerOptions::kUndefined) {
1519 session_options->recv_audio =
1520 session_options->HasSendMediaStream(cricket::MEDIA_TYPE_AUDIO) ||
1521 !remote_audio_tracks_.empty();
1522 }
1523 if (rtc_options.offer_to_receive_video == RTCOfferAnswerOptions::kUndefined) {
1524 session_options->recv_video =
1525 session_options->HasSendMediaStream(cricket::MEDIA_TYPE_VIDEO) ||
1526 !remote_video_tracks_.empty();
1527 }
1528 session_options->bundle_enabled =
1529 session_options->bundle_enabled &&
1530 (session_options->has_audio() || session_options->has_video() ||
1531 session_options->has_data());
1532
deadbeefab9b2d12015-10-14 11:33:11 -07001533 if (session_->data_channel_type() == cricket::DCT_SCTP && HasDataChannels()) {
1534 session_options->data_channel_type = cricket::DCT_SCTP;
1535 }
1536 return true;
1537}
1538
htaa2a49d92016-03-04 02:51:39 -08001539void PeerConnection::FinishOptionsForAnswer(
deadbeefab9b2d12015-10-14 11:33:11 -07001540 cricket::MediaSessionOptions* session_options) {
deadbeef0ed85b22016-02-23 17:24:52 -08001541 // TODO(deadbeef): Once we have transceivers, enumerate them here instead of
1542 // ContentInfos.
1543 if (session_->remote_description()) {
1544 // Initialize the transport_options map.
1545 for (const cricket::ContentInfo& content :
1546 session_->remote_description()->description()->contents()) {
1547 session_options->transport_options[content.name] =
1548 cricket::TransportOptions();
1549 }
1550 }
deadbeeffac06552015-11-25 11:26:01 -08001551 AddSendStreams(session_options, senders_, rtp_data_channels_);
deadbeefc80741f2015-10-22 13:14:45 -07001552 session_options->bundle_enabled =
1553 session_options->bundle_enabled &&
1554 (session_options->has_audio() || session_options->has_video() ||
1555 session_options->has_data());
1556
deadbeefab9b2d12015-10-14 11:33:11 -07001557 // RTP data channel is handled in MediaSessionOptions::AddStream. SCTP streams
1558 // are not signaled in the SDP so does not go through that path and must be
1559 // handled here.
1560 if (session_->data_channel_type() == cricket::DCT_SCTP) {
1561 session_options->data_channel_type = cricket::DCT_SCTP;
1562 }
htaa2a49d92016-03-04 02:51:39 -08001563}
1564
1565bool PeerConnection::GetOptionsForAnswer(
1566 const MediaConstraintsInterface* constraints,
1567 cricket::MediaSessionOptions* session_options) {
1568 session_options->recv_audio = false;
1569 session_options->recv_video = false;
1570 if (!ParseConstraintsForAnswer(constraints, session_options)) {
1571 return false;
1572 }
1573 FinishOptionsForAnswer(session_options);
1574 return true;
1575}
1576
1577bool PeerConnection::GetOptionsForAnswer(
1578 const RTCOfferAnswerOptions& options,
1579 cricket::MediaSessionOptions* session_options) {
1580 session_options->recv_audio = false;
1581 session_options->recv_video = false;
1582 if (!ExtractMediaSessionOptions(options, session_options)) {
1583 return false;
1584 }
1585 FinishOptionsForAnswer(session_options);
deadbeefab9b2d12015-10-14 11:33:11 -07001586 return true;
1587}
1588
deadbeeffaac4972015-11-12 15:33:07 -08001589void PeerConnection::RemoveTracks(cricket::MediaType media_type) {
1590 UpdateLocalTracks(std::vector<cricket::StreamParams>(), media_type);
deadbeefbda7e0b2015-12-08 17:13:40 -08001591 UpdateRemoteStreamsList(std::vector<cricket::StreamParams>(), false,
1592 media_type, nullptr);
deadbeeffaac4972015-11-12 15:33:07 -08001593}
1594
deadbeefab9b2d12015-10-14 11:33:11 -07001595void PeerConnection::UpdateRemoteStreamsList(
1596 const cricket::StreamParamsVec& streams,
deadbeefbda7e0b2015-12-08 17:13:40 -08001597 bool default_track_needed,
deadbeefab9b2d12015-10-14 11:33:11 -07001598 cricket::MediaType media_type,
1599 StreamCollection* new_streams) {
1600 TrackInfos* current_tracks = GetRemoteTracks(media_type);
1601
1602 // Find removed tracks. I.e., tracks where the track id or ssrc don't match
deadbeeffac06552015-11-25 11:26:01 -08001603 // the new StreamParam.
deadbeefab9b2d12015-10-14 11:33:11 -07001604 auto track_it = current_tracks->begin();
1605 while (track_it != current_tracks->end()) {
1606 const TrackInfo& info = *track_it;
1607 const cricket::StreamParams* params =
1608 cricket::GetStreamBySsrc(streams, info.ssrc);
deadbeefbda7e0b2015-12-08 17:13:40 -08001609 bool track_exists = params && params->id == info.track_id;
1610 // If this is a default track, and we still need it, don't remove it.
1611 if ((info.stream_label == kDefaultStreamLabel && default_track_needed) ||
1612 track_exists) {
1613 ++track_it;
1614 } else {
deadbeefab9b2d12015-10-14 11:33:11 -07001615 OnRemoteTrackRemoved(info.stream_label, info.track_id, media_type);
1616 track_it = current_tracks->erase(track_it);
deadbeefab9b2d12015-10-14 11:33:11 -07001617 }
1618 }
1619
1620 // Find new and active tracks.
1621 for (const cricket::StreamParams& params : streams) {
1622 // The sync_label is the MediaStream label and the |stream.id| is the
1623 // track id.
1624 const std::string& stream_label = params.sync_label;
1625 const std::string& track_id = params.id;
1626 uint32_t ssrc = params.first_ssrc();
1627
1628 rtc::scoped_refptr<MediaStreamInterface> stream =
1629 remote_streams_->find(stream_label);
1630 if (!stream) {
1631 // This is a new MediaStream. Create a new remote MediaStream.
1632 stream = remote_stream_factory_->CreateMediaStream(stream_label);
1633 remote_streams_->AddStream(stream);
1634 new_streams->AddStream(stream);
1635 }
1636
1637 const TrackInfo* track_info =
1638 FindTrackInfo(*current_tracks, stream_label, track_id);
1639 if (!track_info) {
1640 current_tracks->push_back(TrackInfo(stream_label, track_id, ssrc));
1641 OnRemoteTrackSeen(stream_label, track_id, ssrc, media_type);
1642 }
1643 }
deadbeefbda7e0b2015-12-08 17:13:40 -08001644
1645 // Add default track if necessary.
1646 if (default_track_needed) {
1647 rtc::scoped_refptr<MediaStreamInterface> default_stream =
1648 remote_streams_->find(kDefaultStreamLabel);
1649 if (!default_stream) {
1650 // Create the new default MediaStream.
1651 default_stream =
1652 remote_stream_factory_->CreateMediaStream(kDefaultStreamLabel);
1653 remote_streams_->AddStream(default_stream);
1654 new_streams->AddStream(default_stream);
1655 }
1656 std::string default_track_id = (media_type == cricket::MEDIA_TYPE_AUDIO)
1657 ? kDefaultAudioTrackLabel
1658 : kDefaultVideoTrackLabel;
1659 const TrackInfo* default_track_info =
1660 FindTrackInfo(*current_tracks, kDefaultStreamLabel, default_track_id);
1661 if (!default_track_info) {
1662 current_tracks->push_back(
1663 TrackInfo(kDefaultStreamLabel, default_track_id, 0));
1664 OnRemoteTrackSeen(kDefaultStreamLabel, default_track_id, 0, media_type);
1665 }
1666 }
deadbeefab9b2d12015-10-14 11:33:11 -07001667}
1668
1669void PeerConnection::OnRemoteTrackSeen(const std::string& stream_label,
1670 const std::string& track_id,
1671 uint32_t ssrc,
1672 cricket::MediaType media_type) {
1673 MediaStreamInterface* stream = remote_streams_->find(stream_label);
1674
1675 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
Tommif888bb52015-12-12 01:37:01 +01001676 AudioTrackInterface* audio_track = remote_stream_factory_->AddAudioTrack(
1677 ssrc, session_.get(), stream, track_id);
deadbeefab9b2d12015-10-14 11:33:11 -07001678 CreateAudioReceiver(stream, audio_track, ssrc);
1679 } else if (media_type == cricket::MEDIA_TYPE_VIDEO) {
1680 VideoTrackInterface* video_track =
1681 remote_stream_factory_->AddVideoTrack(stream, track_id);
1682 CreateVideoReceiver(stream, video_track, ssrc);
1683 } else {
1684 RTC_DCHECK(false && "Invalid media type");
1685 }
1686}
1687
1688void PeerConnection::OnRemoteTrackRemoved(const std::string& stream_label,
1689 const std::string& track_id,
1690 cricket::MediaType media_type) {
1691 MediaStreamInterface* stream = remote_streams_->find(stream_label);
1692
1693 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
1694 rtc::scoped_refptr<AudioTrackInterface> audio_track =
1695 stream->FindAudioTrack(track_id);
1696 if (audio_track) {
1697 audio_track->set_state(webrtc::MediaStreamTrackInterface::kEnded);
1698 stream->RemoveTrack(audio_track);
1699 DestroyAudioReceiver(stream, audio_track);
1700 }
1701 } else if (media_type == cricket::MEDIA_TYPE_VIDEO) {
1702 rtc::scoped_refptr<VideoTrackInterface> video_track =
1703 stream->FindVideoTrack(track_id);
1704 if (video_track) {
1705 video_track->set_state(webrtc::MediaStreamTrackInterface::kEnded);
1706 stream->RemoveTrack(video_track);
1707 DestroyVideoReceiver(stream, video_track);
1708 }
1709 } else {
1710 ASSERT(false && "Invalid media type");
1711 }
1712}
1713
1714void PeerConnection::UpdateEndedRemoteMediaStreams() {
1715 std::vector<rtc::scoped_refptr<MediaStreamInterface>> streams_to_remove;
1716 for (size_t i = 0; i < remote_streams_->count(); ++i) {
1717 MediaStreamInterface* stream = remote_streams_->at(i);
1718 if (stream->GetAudioTracks().empty() && stream->GetVideoTracks().empty()) {
1719 streams_to_remove.push_back(stream);
1720 }
1721 }
1722
1723 for (const auto& stream : streams_to_remove) {
1724 remote_streams_->RemoveStream(stream);
1725 observer_->OnRemoveStream(stream);
1726 }
1727}
1728
deadbeefab9b2d12015-10-14 11:33:11 -07001729void PeerConnection::EndRemoteTracks(cricket::MediaType media_type) {
1730 TrackInfos* current_tracks = GetRemoteTracks(media_type);
1731 for (TrackInfos::iterator track_it = current_tracks->begin();
1732 track_it != current_tracks->end(); ++track_it) {
1733 const TrackInfo& info = *track_it;
1734 MediaStreamInterface* stream = remote_streams_->find(info.stream_label);
1735 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
1736 AudioTrackInterface* track = stream->FindAudioTrack(info.track_id);
1737 // There's no guarantee the track is still available, e.g. the track may
1738 // have been removed from the stream by javascript.
1739 if (track) {
1740 track->set_state(webrtc::MediaStreamTrackInterface::kEnded);
1741 }
1742 }
1743 if (media_type == cricket::MEDIA_TYPE_VIDEO) {
1744 VideoTrackInterface* track = stream->FindVideoTrack(info.track_id);
1745 // There's no guarantee the track is still available, e.g. the track may
1746 // have been removed from the stream by javascript.
1747 if (track) {
1748 track->set_state(webrtc::MediaStreamTrackInterface::kEnded);
1749 }
1750 }
1751 }
1752}
1753
1754void PeerConnection::UpdateLocalTracks(
1755 const std::vector<cricket::StreamParams>& streams,
1756 cricket::MediaType media_type) {
1757 TrackInfos* current_tracks = GetLocalTracks(media_type);
1758
1759 // Find removed tracks. I.e., tracks where the track id, stream label or ssrc
1760 // don't match the new StreamParam.
1761 TrackInfos::iterator track_it = current_tracks->begin();
1762 while (track_it != current_tracks->end()) {
1763 const TrackInfo& info = *track_it;
1764 const cricket::StreamParams* params =
1765 cricket::GetStreamBySsrc(streams, info.ssrc);
1766 if (!params || params->id != info.track_id ||
1767 params->sync_label != info.stream_label) {
1768 OnLocalTrackRemoved(info.stream_label, info.track_id, info.ssrc,
1769 media_type);
1770 track_it = current_tracks->erase(track_it);
1771 } else {
1772 ++track_it;
1773 }
1774 }
1775
1776 // Find new and active tracks.
1777 for (const cricket::StreamParams& params : streams) {
1778 // The sync_label is the MediaStream label and the |stream.id| is the
1779 // track id.
1780 const std::string& stream_label = params.sync_label;
1781 const std::string& track_id = params.id;
1782 uint32_t ssrc = params.first_ssrc();
1783 const TrackInfo* track_info =
1784 FindTrackInfo(*current_tracks, stream_label, track_id);
1785 if (!track_info) {
1786 current_tracks->push_back(TrackInfo(stream_label, track_id, ssrc));
1787 OnLocalTrackSeen(stream_label, track_id, params.first_ssrc(), media_type);
1788 }
1789 }
1790}
1791
1792void PeerConnection::OnLocalTrackSeen(const std::string& stream_label,
1793 const std::string& track_id,
1794 uint32_t ssrc,
1795 cricket::MediaType media_type) {
deadbeeffac06552015-11-25 11:26:01 -08001796 RtpSenderInterface* sender = FindSenderById(track_id);
1797 if (!sender) {
1798 LOG(LS_WARNING) << "An unknown RtpSender with id " << track_id
1799 << " has been configured in the local description.";
deadbeefab9b2d12015-10-14 11:33:11 -07001800 return;
1801 }
1802
deadbeeffac06552015-11-25 11:26:01 -08001803 if (sender->media_type() != media_type) {
1804 LOG(LS_WARNING) << "An RtpSender has been configured in the local"
1805 << " description with an unexpected media type.";
1806 return;
deadbeefab9b2d12015-10-14 11:33:11 -07001807 }
deadbeeffac06552015-11-25 11:26:01 -08001808
1809 sender->set_stream_id(stream_label);
1810 sender->SetSsrc(ssrc);
deadbeefab9b2d12015-10-14 11:33:11 -07001811}
1812
1813void PeerConnection::OnLocalTrackRemoved(const std::string& stream_label,
1814 const std::string& track_id,
1815 uint32_t ssrc,
1816 cricket::MediaType media_type) {
deadbeeffac06552015-11-25 11:26:01 -08001817 RtpSenderInterface* sender = FindSenderById(track_id);
1818 if (!sender) {
1819 // This is the normal case. I.e., RemoveStream has been called and the
deadbeefab9b2d12015-10-14 11:33:11 -07001820 // SessionDescriptions has been renegotiated.
1821 return;
1822 }
deadbeeffac06552015-11-25 11:26:01 -08001823
1824 // A sender has been removed from the SessionDescription but it's still
1825 // associated with the PeerConnection. This only occurs if the SDP doesn't
1826 // match with the calls to CreateSender, AddStream and RemoveStream.
1827 if (sender->media_type() != media_type) {
1828 LOG(LS_WARNING) << "An RtpSender has been configured in the local"
1829 << " description with an unexpected media type.";
1830 return;
deadbeefab9b2d12015-10-14 11:33:11 -07001831 }
deadbeeffac06552015-11-25 11:26:01 -08001832
1833 sender->SetSsrc(0);
deadbeefab9b2d12015-10-14 11:33:11 -07001834}
1835
1836void PeerConnection::UpdateLocalRtpDataChannels(
1837 const cricket::StreamParamsVec& streams) {
1838 std::vector<std::string> existing_channels;
1839
1840 // Find new and active data channels.
1841 for (const cricket::StreamParams& params : streams) {
1842 // |it->sync_label| is actually the data channel label. The reason is that
1843 // we use the same naming of data channels as we do for
1844 // MediaStreams and Tracks.
1845 // For MediaStreams, the sync_label is the MediaStream label and the
1846 // track label is the same as |streamid|.
1847 const std::string& channel_label = params.sync_label;
1848 auto data_channel_it = rtp_data_channels_.find(channel_label);
1849 if (!VERIFY(data_channel_it != rtp_data_channels_.end())) {
1850 continue;
1851 }
1852 // Set the SSRC the data channel should use for sending.
1853 data_channel_it->second->SetSendSsrc(params.first_ssrc());
1854 existing_channels.push_back(data_channel_it->first);
1855 }
1856
1857 UpdateClosingRtpDataChannels(existing_channels, true);
1858}
1859
1860void PeerConnection::UpdateRemoteRtpDataChannels(
1861 const cricket::StreamParamsVec& streams) {
1862 std::vector<std::string> existing_channels;
1863
1864 // Find new and active data channels.
1865 for (const cricket::StreamParams& params : streams) {
1866 // The data channel label is either the mslabel or the SSRC if the mslabel
1867 // does not exist. Ex a=ssrc:444330170 mslabel:test1.
1868 std::string label = params.sync_label.empty()
1869 ? rtc::ToString(params.first_ssrc())
1870 : params.sync_label;
1871 auto data_channel_it = rtp_data_channels_.find(label);
1872 if (data_channel_it == rtp_data_channels_.end()) {
1873 // This is a new data channel.
1874 CreateRemoteRtpDataChannel(label, params.first_ssrc());
1875 } else {
1876 data_channel_it->second->SetReceiveSsrc(params.first_ssrc());
1877 }
1878 existing_channels.push_back(label);
1879 }
1880
1881 UpdateClosingRtpDataChannels(existing_channels, false);
1882}
1883
1884void PeerConnection::UpdateClosingRtpDataChannels(
1885 const std::vector<std::string>& active_channels,
1886 bool is_local_update) {
1887 auto it = rtp_data_channels_.begin();
1888 while (it != rtp_data_channels_.end()) {
1889 DataChannel* data_channel = it->second;
1890 if (std::find(active_channels.begin(), active_channels.end(),
1891 data_channel->label()) != active_channels.end()) {
1892 ++it;
1893 continue;
1894 }
1895
1896 if (is_local_update) {
1897 data_channel->SetSendSsrc(0);
1898 } else {
1899 data_channel->RemotePeerRequestClose();
1900 }
1901
1902 if (data_channel->state() == DataChannel::kClosed) {
1903 rtp_data_channels_.erase(it);
1904 it = rtp_data_channels_.begin();
1905 } else {
1906 ++it;
1907 }
1908 }
1909}
1910
1911void PeerConnection::CreateRemoteRtpDataChannel(const std::string& label,
1912 uint32_t remote_ssrc) {
1913 rtc::scoped_refptr<DataChannel> channel(
1914 InternalCreateDataChannel(label, nullptr));
1915 if (!channel.get()) {
1916 LOG(LS_WARNING) << "Remote peer requested a DataChannel but"
1917 << "CreateDataChannel failed.";
1918 return;
1919 }
1920 channel->SetReceiveSsrc(remote_ssrc);
1921 observer_->OnDataChannel(
1922 DataChannelProxy::Create(signaling_thread(), channel));
1923}
1924
1925rtc::scoped_refptr<DataChannel> PeerConnection::InternalCreateDataChannel(
1926 const std::string& label,
1927 const InternalDataChannelInit* config) {
1928 if (IsClosed()) {
1929 return nullptr;
1930 }
1931 if (session_->data_channel_type() == cricket::DCT_NONE) {
1932 LOG(LS_ERROR)
1933 << "InternalCreateDataChannel: Data is not supported in this call.";
1934 return nullptr;
1935 }
1936 InternalDataChannelInit new_config =
1937 config ? (*config) : InternalDataChannelInit();
1938 if (session_->data_channel_type() == cricket::DCT_SCTP) {
1939 if (new_config.id < 0) {
1940 rtc::SSLRole role;
Taylor Brandstetterf475d362016-01-08 15:35:57 -08001941 if ((session_->GetSslRole(session_->data_channel(), &role)) &&
deadbeefab9b2d12015-10-14 11:33:11 -07001942 !sid_allocator_.AllocateSid(role, &new_config.id)) {
1943 LOG(LS_ERROR) << "No id can be allocated for the SCTP data channel.";
1944 return nullptr;
1945 }
1946 } else if (!sid_allocator_.ReserveSid(new_config.id)) {
1947 LOG(LS_ERROR) << "Failed to create a SCTP data channel "
1948 << "because the id is already in use or out of range.";
1949 return nullptr;
1950 }
1951 }
1952
1953 rtc::scoped_refptr<DataChannel> channel(DataChannel::Create(
1954 session_.get(), session_->data_channel_type(), label, new_config));
1955 if (!channel) {
1956 sid_allocator_.ReleaseSid(new_config.id);
1957 return nullptr;
1958 }
1959
1960 if (channel->data_channel_type() == cricket::DCT_RTP) {
1961 if (rtp_data_channels_.find(channel->label()) != rtp_data_channels_.end()) {
1962 LOG(LS_ERROR) << "DataChannel with label " << channel->label()
1963 << " already exists.";
1964 return nullptr;
1965 }
1966 rtp_data_channels_[channel->label()] = channel;
1967 } else {
1968 RTC_DCHECK(channel->data_channel_type() == cricket::DCT_SCTP);
1969 sctp_data_channels_.push_back(channel);
1970 channel->SignalClosed.connect(this,
1971 &PeerConnection::OnSctpDataChannelClosed);
1972 }
1973
1974 return channel;
1975}
1976
1977bool PeerConnection::HasDataChannels() const {
1978 return !rtp_data_channels_.empty() || !sctp_data_channels_.empty();
1979}
1980
1981void PeerConnection::AllocateSctpSids(rtc::SSLRole role) {
1982 for (const auto& channel : sctp_data_channels_) {
1983 if (channel->id() < 0) {
1984 int sid;
1985 if (!sid_allocator_.AllocateSid(role, &sid)) {
1986 LOG(LS_ERROR) << "Failed to allocate SCTP sid.";
1987 continue;
1988 }
1989 channel->SetSctpSid(sid);
1990 }
1991 }
1992}
1993
1994void PeerConnection::OnSctpDataChannelClosed(DataChannel* channel) {
deadbeefbd292462015-12-14 18:15:29 -08001995 RTC_DCHECK(signaling_thread()->IsCurrent());
deadbeefab9b2d12015-10-14 11:33:11 -07001996 for (auto it = sctp_data_channels_.begin(); it != sctp_data_channels_.end();
1997 ++it) {
1998 if (it->get() == channel) {
1999 if (channel->id() >= 0) {
2000 sid_allocator_.ReleaseSid(channel->id());
2001 }
deadbeefbd292462015-12-14 18:15:29 -08002002 // Since this method is triggered by a signal from the DataChannel,
2003 // we can't free it directly here; we need to free it asynchronously.
2004 sctp_data_channels_to_free_.push_back(*it);
deadbeefab9b2d12015-10-14 11:33:11 -07002005 sctp_data_channels_.erase(it);
deadbeefbd292462015-12-14 18:15:29 -08002006 signaling_thread()->Post(this, MSG_FREE_DATACHANNELS, nullptr);
deadbeefab9b2d12015-10-14 11:33:11 -07002007 return;
2008 }
2009 }
2010}
2011
2012void PeerConnection::OnVoiceChannelDestroyed() {
2013 EndRemoteTracks(cricket::MEDIA_TYPE_AUDIO);
2014}
2015
2016void PeerConnection::OnVideoChannelDestroyed() {
2017 EndRemoteTracks(cricket::MEDIA_TYPE_VIDEO);
2018}
2019
2020void PeerConnection::OnDataChannelCreated() {
2021 for (const auto& channel : sctp_data_channels_) {
2022 channel->OnTransportChannelCreated();
2023 }
2024}
2025
2026void PeerConnection::OnDataChannelDestroyed() {
2027 // Use a temporary copy of the RTP/SCTP DataChannel list because the
2028 // DataChannel may callback to us and try to modify the list.
2029 std::map<std::string, rtc::scoped_refptr<DataChannel>> temp_rtp_dcs;
2030 temp_rtp_dcs.swap(rtp_data_channels_);
2031 for (const auto& kv : temp_rtp_dcs) {
2032 kv.second->OnTransportChannelDestroyed();
2033 }
2034
2035 std::vector<rtc::scoped_refptr<DataChannel>> temp_sctp_dcs;
2036 temp_sctp_dcs.swap(sctp_data_channels_);
2037 for (const auto& channel : temp_sctp_dcs) {
2038 channel->OnTransportChannelDestroyed();
2039 }
2040}
2041
2042void PeerConnection::OnDataChannelOpenMessage(
2043 const std::string& label,
2044 const InternalDataChannelInit& config) {
2045 rtc::scoped_refptr<DataChannel> channel(
2046 InternalCreateDataChannel(label, &config));
2047 if (!channel.get()) {
2048 LOG(LS_ERROR) << "Failed to create DataChannel from the OPEN message.";
2049 return;
2050 }
2051
2052 observer_->OnDataChannel(
2053 DataChannelProxy::Create(signaling_thread(), channel));
2054}
2055
deadbeeffac06552015-11-25 11:26:01 -08002056RtpSenderInterface* PeerConnection::FindSenderById(const std::string& id) {
2057 auto it =
2058 std::find_if(senders_.begin(), senders_.end(),
2059 [id](const rtc::scoped_refptr<RtpSenderInterface>& sender) {
2060 return sender->id() == id;
2061 });
2062 return it != senders_.end() ? it->get() : nullptr;
2063}
2064
deadbeef70ab1a12015-09-28 16:53:55 -07002065std::vector<rtc::scoped_refptr<RtpSenderInterface>>::iterator
2066PeerConnection::FindSenderForTrack(MediaStreamTrackInterface* track) {
2067 return std::find_if(
2068 senders_.begin(), senders_.end(),
2069 [track](const rtc::scoped_refptr<RtpSenderInterface>& sender) {
2070 return sender->track() == track;
2071 });
2072}
2073
2074std::vector<rtc::scoped_refptr<RtpReceiverInterface>>::iterator
2075PeerConnection::FindReceiverForTrack(MediaStreamTrackInterface* track) {
2076 return std::find_if(
2077 receivers_.begin(), receivers_.end(),
2078 [track](const rtc::scoped_refptr<RtpReceiverInterface>& receiver) {
2079 return receiver->track() == track;
2080 });
2081}
2082
deadbeefab9b2d12015-10-14 11:33:11 -07002083PeerConnection::TrackInfos* PeerConnection::GetRemoteTracks(
2084 cricket::MediaType media_type) {
2085 RTC_DCHECK(media_type == cricket::MEDIA_TYPE_AUDIO ||
2086 media_type == cricket::MEDIA_TYPE_VIDEO);
2087 return (media_type == cricket::MEDIA_TYPE_AUDIO) ? &remote_audio_tracks_
2088 : &remote_video_tracks_;
2089}
2090
2091PeerConnection::TrackInfos* PeerConnection::GetLocalTracks(
2092 cricket::MediaType media_type) {
2093 RTC_DCHECK(media_type == cricket::MEDIA_TYPE_AUDIO ||
2094 media_type == cricket::MEDIA_TYPE_VIDEO);
2095 return (media_type == cricket::MEDIA_TYPE_AUDIO) ? &local_audio_tracks_
2096 : &local_video_tracks_;
2097}
2098
2099const PeerConnection::TrackInfo* PeerConnection::FindTrackInfo(
2100 const PeerConnection::TrackInfos& infos,
2101 const std::string& stream_label,
2102 const std::string track_id) const {
2103 for (const TrackInfo& track_info : infos) {
2104 if (track_info.stream_label == stream_label &&
2105 track_info.track_id == track_id) {
2106 return &track_info;
2107 }
2108 }
2109 return nullptr;
2110}
2111
2112DataChannel* PeerConnection::FindDataChannelBySid(int sid) const {
2113 for (const auto& channel : sctp_data_channels_) {
2114 if (channel->id() == sid) {
2115 return channel;
2116 }
2117 }
2118 return nullptr;
2119}
2120
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002121} // namespace webrtc