blob: 07a4eb92f494479691df646959c5d49350bfffa5 [file] [log] [blame]
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001/*
2 * libjingle
jlmiller@webrtc.org5f93d0a2015-01-20 21:36:13 +00003 * Copyright 2011 Google Inc.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00004 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 * 1. Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright notice,
11 * this list of conditions and the following disclaimer in the documentation
12 * and/or other materials provided with the distribution.
13 * 3. The name of the author may not be used to endorse or promote products
14 * derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
19 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
20 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
22 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
23 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
24 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
25 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28#include "talk/app/webrtc/webrtcsdp.h"
29
30#include <limits.h>
31#include <stdio.h>
32#include <algorithm>
33#include <string>
34#include <vector>
decurtis@webrtc.org8af11042015-01-07 19:15:51 +000035#include <ctype.h>
henrike@webrtc.org28e20752013-07-10 00:45:36 +000036
37#include "talk/app/webrtc/jsepicecandidate.h"
38#include "talk/app/webrtc/jsepsessiondescription.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000039#include "talk/media/base/codec.h"
40#include "talk/media/base/constants.h"
41#include "talk/media/base/cryptoparams.h"
pkasting@chromium.orge9facf82015-02-17 20:36:28 +000042#include "talk/media/base/rtputils.h"
mallinath@webrtc.org1112c302013-09-23 20:34:45 +000043#include "talk/media/sctp/sctpdataengine.h"
henrike@webrtc.org269fb4b2014-10-28 22:20:11 +000044#include "webrtc/p2p/base/candidate.h"
45#include "webrtc/p2p/base/constants.h"
46#include "webrtc/p2p/base/port.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000047#include "talk/session/media/mediasession.h"
tfarina5237aaf2015-11-10 23:44:30 -080048#include "webrtc/base/arraysize.h"
buildbot@webrtc.orga09a9992014-08-13 17:26:08 +000049#include "webrtc/base/common.h"
50#include "webrtc/base/logging.h"
51#include "webrtc/base/messagedigest.h"
52#include "webrtc/base/stringutils.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000053
54using cricket::AudioContentDescription;
55using cricket::Candidate;
56using cricket::Candidates;
57using cricket::ContentDescription;
58using cricket::ContentInfo;
59using cricket::CryptoParams;
60using cricket::DataContentDescription;
61using cricket::ICE_CANDIDATE_COMPONENT_RTP;
62using cricket::ICE_CANDIDATE_COMPONENT_RTCP;
63using cricket::kCodecParamMaxBitrate;
64using cricket::kCodecParamMaxPTime;
65using cricket::kCodecParamMaxQuantization;
66using cricket::kCodecParamMinBitrate;
67using cricket::kCodecParamMinPTime;
68using cricket::kCodecParamPTime;
69using cricket::kCodecParamSPropStereo;
buildbot@webrtc.orged97bb02014-05-07 11:15:20 +000070using cricket::kCodecParamStartBitrate;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000071using cricket::kCodecParamStereo;
72using cricket::kCodecParamUseInbandFec;
Minyue Li7100dcd2015-03-27 05:05:59 +010073using cricket::kCodecParamUseDtx;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000074using cricket::kCodecParamSctpProtocol;
75using cricket::kCodecParamSctpStreams;
henrike@webrtc.org1e09a712013-07-26 19:17:59 +000076using cricket::kCodecParamMaxAverageBitrate;
buildbot@webrtc.org5d639b32014-09-10 07:57:12 +000077using cricket::kCodecParamMaxPlaybackRate;
stefan@webrtc.org85d27942014-06-09 12:51:39 +000078using cricket::kCodecParamAssociatedPayloadType;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000079using cricket::MediaContentDescription;
80using cricket::MediaType;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000081using cricket::RtpHeaderExtension;
82using cricket::SsrcGroup;
83using cricket::StreamParams;
84using cricket::StreamParamsVec;
85using cricket::TransportDescription;
86using cricket::TransportInfo;
87using cricket::VideoContentDescription;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +000088using rtc::SocketAddress;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000089
90typedef std::vector<RtpHeaderExtension> RtpHeaderExtensions;
91
92namespace cricket {
93class SessionDescription;
94}
95
96namespace webrtc {
97
98// Line type
99// RFC 4566
100// An SDP session description consists of a number of lines of text of
101// the form:
102// <type>=<value>
103// where <type> MUST be exactly one case-significant character.
104static const int kLinePrefixLength = 2; // Lenght of <type>=
105static const char kLineTypeVersion = 'v';
106static const char kLineTypeOrigin = 'o';
107static const char kLineTypeSessionName = 's';
108static const char kLineTypeSessionInfo = 'i';
109static const char kLineTypeSessionUri = 'u';
110static const char kLineTypeSessionEmail = 'e';
111static const char kLineTypeSessionPhone = 'p';
112static const char kLineTypeSessionBandwidth = 'b';
113static const char kLineTypeTiming = 't';
114static const char kLineTypeRepeatTimes = 'r';
115static const char kLineTypeTimeZone = 'z';
116static const char kLineTypeEncryptionKey = 'k';
117static const char kLineTypeMedia = 'm';
118static const char kLineTypeConnection = 'c';
119static const char kLineTypeAttributes = 'a';
120
121// Attributes
122static const char kAttributeGroup[] = "group";
123static const char kAttributeMid[] = "mid";
124static const char kAttributeRtcpMux[] = "rtcp-mux";
deadbeef13871492015-12-09 12:37:51 -0800125static const char kAttributeRtcpReducedSize[] = "rtcp-rsize";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000126static const char kAttributeSsrc[] = "ssrc";
127static const char kSsrcAttributeCname[] = "cname";
128static const char kAttributeExtmap[] = "extmap";
129// draft-alvestrand-mmusic-msid-01
130// a=msid-semantic: WMS
131static const char kAttributeMsidSemantics[] = "msid-semantic";
132static const char kMediaStreamSemantic[] = "WMS";
133static const char kSsrcAttributeMsid[] = "msid";
134static const char kDefaultMsid[] = "default";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000135static const char kSsrcAttributeMslabel[] = "mslabel";
136static const char kSSrcAttributeLabel[] = "label";
137static const char kAttributeSsrcGroup[] = "ssrc-group";
138static const char kAttributeCrypto[] = "crypto";
139static const char kAttributeCandidate[] = "candidate";
140static const char kAttributeCandidateTyp[] = "typ";
141static const char kAttributeCandidateRaddr[] = "raddr";
142static const char kAttributeCandidateRport[] = "rport";
honghaiza54a0802015-12-16 18:37:23 -0800143static const char kAttributeCandidateUfrag[] = "ufrag";
144static const char kAttributeCandidatePwd[] = "pwd";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000145static const char kAttributeCandidateGeneration[] = "generation";
146static const char kAttributeFingerprint[] = "fingerprint";
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +0000147static const char kAttributeSetup[] = "setup";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000148static const char kAttributeFmtp[] = "fmtp";
149static const char kAttributeRtpmap[] = "rtpmap";
wu@webrtc.org78187522013-10-07 23:32:02 +0000150static const char kAttributeSctpmap[] = "sctpmap";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000151static const char kAttributeRtcp[] = "rtcp";
152static const char kAttributeIceUfrag[] = "ice-ufrag";
153static const char kAttributeIcePwd[] = "ice-pwd";
154static const char kAttributeIceLite[] = "ice-lite";
155static const char kAttributeIceOption[] = "ice-options";
156static const char kAttributeSendOnly[] = "sendonly";
157static const char kAttributeRecvOnly[] = "recvonly";
158static const char kAttributeRtcpFb[] = "rtcp-fb";
159static const char kAttributeSendRecv[] = "sendrecv";
160static const char kAttributeInactive[] = "inactive";
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +0000161// draft-ietf-mmusic-sctp-sdp-07
162// a=sctp-port
163static const char kAttributeSctpPort[] = "sctp-port";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000164
165// Experimental flags
166static const char kAttributeXGoogleFlag[] = "x-google-flag";
167static const char kValueConference[] = "conference";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000168
169// Candidate
170static const char kCandidateHost[] = "host";
171static const char kCandidateSrflx[] = "srflx";
172// TODO: How to map the prflx with circket candidate type
173// static const char kCandidatePrflx[] = "prflx";
174static const char kCandidateRelay[] = "relay";
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +0000175static const char kTcpCandidateType[] = "tcptype";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000176
177static const char kSdpDelimiterEqual = '=';
178static const char kSdpDelimiterSpace = ' ';
179static const char kSdpDelimiterColon = ':';
180static const char kSdpDelimiterSemicolon = ';';
181static const char kSdpDelimiterSlash = '/';
182static const char kNewLine = '\n';
183static const char kReturn = '\r';
184static const char kLineBreak[] = "\r\n";
185
186// TODO: Generate the Session and Time description
187// instead of hardcoding.
188static const char kSessionVersion[] = "v=0";
189// RFC 4566
190static const char kSessionOriginUsername[] = "-";
191static const char kSessionOriginSessionId[] = "0";
192static const char kSessionOriginSessionVersion[] = "0";
193static const char kSessionOriginNettype[] = "IN";
194static const char kSessionOriginAddrtype[] = "IP4";
195static const char kSessionOriginAddress[] = "127.0.0.1";
196static const char kSessionName[] = "s=-";
197static const char kTimeDescription[] = "t=0 0";
198static const char kAttrGroup[] = "a=group:BUNDLE";
199static const char kConnectionNettype[] = "IN";
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000200static const char kConnectionIpv4Addrtype[] = "IP4";
201static const char kConnectionIpv6Addrtype[] = "IP6";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000202static const char kMediaTypeVideo[] = "video";
203static const char kMediaTypeAudio[] = "audio";
204static const char kMediaTypeData[] = "application";
205static const char kMediaPortRejected[] = "0";
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000206// draft-ietf-mmusic-trickle-ice-01
207// When no candidates have been gathered, set the connection
208// address to IP6 ::.
perkj@webrtc.orgd105cc82014-11-07 11:22:06 +0000209// TODO(perkj): FF can not parse IP6 ::. See http://crbug/430333
210// Use IPV4 per default.
211static const char kDummyAddress[] = "0.0.0.0";
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000212static const char kDummyPort[] = "9";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000213// RFC 3556
214static const char kApplicationSpecificMaximum[] = "AS";
215
216static const int kDefaultVideoClockrate = 90000;
217
218// ISAC special-case.
219static const char kIsacCodecName[] = "ISAC"; // From webrtcvoiceengine.cc
220static const int kIsacWbDefaultRate = 32000; // From acm_common_defs.h
221static const int kIsacSwbDefaultRate = 56000; // From acm_common_defs.h
222
wu@webrtc.org78187522013-10-07 23:32:02 +0000223static const char kDefaultSctpmapProtocol[] = "webrtc-datachannel";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000224
pkasting@chromium.orgd3245462015-02-23 21:28:22 +0000225// RTP payload type is in the 0-127 range. Use -1 to indicate "all" payload
226// types.
227const int kWildcardPayloadType = -1;
228
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000229struct SsrcInfo {
230 SsrcInfo()
231 : msid_identifier(kDefaultMsid),
232 // TODO(ronghuawu): What should we do if the appdata doesn't appear?
233 // Create random string (which will be used as track label later)?
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000234 msid_appdata(rtc::CreateRandomString(8)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000235 }
Peter Boström0c4e06b2015-10-07 12:23:21 +0200236 uint32_t ssrc_id;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000237 std::string cname;
238 std::string msid_identifier;
239 std::string msid_appdata;
240
241 // For backward compatibility.
242 // TODO(ronghuawu): Remove below 2 fields once all the clients support msid.
243 std::string label;
244 std::string mslabel;
245};
246typedef std::vector<SsrcInfo> SsrcInfoVec;
247typedef std::vector<SsrcGroup> SsrcGroupVec;
248
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000249template <class T>
250static void AddFmtpLine(const T& codec, std::string* message);
251static void BuildMediaDescription(const ContentInfo* content_info,
252 const TransportInfo* transport_info,
253 const MediaType media_type,
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000254 const std::vector<Candidate>& candidates,
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000255 std::string* message);
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +0000256static void BuildSctpContentAttributes(std::string* message, int sctp_port);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000257static void BuildRtpContentAttributes(
258 const MediaContentDescription* media_desc,
259 const MediaType media_type,
260 std::string* message);
261static void BuildRtpMap(const MediaContentDescription* media_desc,
262 const MediaType media_type,
263 std::string* message);
264static void BuildCandidate(const std::vector<Candidate>& candidates,
honghaiza54a0802015-12-16 18:37:23 -0800265 bool include_ufrag,
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000266 std::string* message);
267static void BuildIceOptions(const std::vector<std::string>& transport_options,
268 std::string* message);
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +0000269static bool IsRtp(const std::string& protocol);
270static bool IsDtlsSctp(const std::string& protocol);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000271static bool ParseSessionDescription(const std::string& message, size_t* pos,
272 std::string* session_id,
273 std::string* session_version,
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000274 TransportDescription* session_td,
275 RtpHeaderExtensions* session_extmaps,
276 cricket::SessionDescription* desc,
277 SdpParseError* error);
278static bool ParseGroupAttribute(const std::string& line,
279 cricket::SessionDescription* desc,
280 SdpParseError* error);
281static bool ParseMediaDescription(
282 const std::string& message,
283 const TransportDescription& session_td,
284 const RtpHeaderExtensions& session_extmaps,
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000285 size_t* pos, cricket::SessionDescription* desc,
286 std::vector<JsepIceCandidate*>* candidates,
287 SdpParseError* error);
288static bool ParseContent(const std::string& message,
289 const MediaType media_type,
290 int mline_index,
291 const std::string& protocol,
292 const std::vector<int>& codec_preference,
293 size_t* pos,
294 std::string* content_name,
295 MediaContentDescription* media_desc,
296 TransportDescription* transport,
297 std::vector<JsepIceCandidate*>* candidates,
298 SdpParseError* error);
299static bool ParseSsrcAttribute(const std::string& line,
300 SsrcInfoVec* ssrc_infos,
301 SdpParseError* error);
302static bool ParseSsrcGroupAttribute(const std::string& line,
303 SsrcGroupVec* ssrc_groups,
304 SdpParseError* error);
305static bool ParseCryptoAttribute(const std::string& line,
306 MediaContentDescription* media_desc,
307 SdpParseError* error);
308static bool ParseRtpmapAttribute(const std::string& line,
309 const MediaType media_type,
310 const std::vector<int>& codec_preference,
311 MediaContentDescription* media_desc,
312 SdpParseError* error);
313static bool ParseFmtpAttributes(const std::string& line,
314 const MediaType media_type,
315 MediaContentDescription* media_desc,
316 SdpParseError* error);
317static bool ParseFmtpParam(const std::string& line, std::string* parameter,
318 std::string* value, SdpParseError* error);
319static bool ParseCandidate(const std::string& message, Candidate* candidate,
320 SdpParseError* error, bool is_raw);
321static bool ParseRtcpFbAttribute(const std::string& line,
322 const MediaType media_type,
323 MediaContentDescription* media_desc,
324 SdpParseError* error);
325static bool ParseIceOptions(const std::string& line,
326 std::vector<std::string>* transport_options,
327 SdpParseError* error);
328static bool ParseExtmap(const std::string& line,
329 RtpHeaderExtension* extmap,
330 SdpParseError* error);
331static bool ParseFingerprintAttribute(const std::string& line,
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000332 rtc::SSLFingerprint** fingerprint,
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000333 SdpParseError* error);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +0000334static bool ParseDtlsSetup(const std::string& line,
335 cricket::ConnectionRole* role,
336 SdpParseError* error);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000337
338// Helper functions
339
340// Below ParseFailed*** functions output the line that caused the parsing
341// failure and the detailed reason (|description|) of the failure to |error|.
342// The functions always return false so that they can be used directly in the
343// following way when error happens:
344// "return ParseFailed***(...);"
345
346// The line starting at |line_start| of |message| is the failing line.
347// The reason for the failure should be provided in the |description|.
348// An example of a description could be "unknown character".
349static bool ParseFailed(const std::string& message,
350 size_t line_start,
351 const std::string& description,
352 SdpParseError* error) {
353 // Get the first line of |message| from |line_start|.
sergeyu@chromium.org5bc25c42013-12-05 00:24:06 +0000354 std::string first_line;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000355 size_t line_end = message.find(kNewLine, line_start);
356 if (line_end != std::string::npos) {
357 if (line_end > 0 && (message.at(line_end - 1) == kReturn)) {
358 --line_end;
359 }
360 first_line = message.substr(line_start, (line_end - line_start));
sergeyu@chromium.org5bc25c42013-12-05 00:24:06 +0000361 } else {
362 first_line = message.substr(line_start);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000363 }
364
365 if (error) {
366 error->line = first_line;
367 error->description = description;
368 }
369 LOG(LS_ERROR) << "Failed to parse: \"" << first_line
370 << "\". Reason: " << description;
371 return false;
372}
373
374// |line| is the failing line. The reason for the failure should be
375// provided in the |description|.
376static bool ParseFailed(const std::string& line,
377 const std::string& description,
378 SdpParseError* error) {
379 return ParseFailed(line, 0, description, error);
380}
381
382// Parses failure where the failing SDP line isn't know or there are multiple
383// failing lines.
384static bool ParseFailed(const std::string& description,
385 SdpParseError* error) {
386 return ParseFailed("", description, error);
387}
388
389// |line| is the failing line. The failure is due to the fact that |line|
390// doesn't have |expected_fields| fields.
391static bool ParseFailedExpectFieldNum(const std::string& line,
392 int expected_fields,
393 SdpParseError* error) {
394 std::ostringstream description;
395 description << "Expects " << expected_fields << " fields.";
396 return ParseFailed(line, description.str(), error);
397}
398
399// |line| is the failing line. The failure is due to the fact that |line| has
400// less than |expected_min_fields| fields.
401static bool ParseFailedExpectMinFieldNum(const std::string& line,
402 int expected_min_fields,
403 SdpParseError* error) {
404 std::ostringstream description;
405 description << "Expects at least " << expected_min_fields << " fields.";
406 return ParseFailed(line, description.str(), error);
407}
408
409// |line| is the failing line. The failure is due to the fact that it failed to
410// get the value of |attribute|.
411static bool ParseFailedGetValue(const std::string& line,
412 const std::string& attribute,
413 SdpParseError* error) {
414 std::ostringstream description;
415 description << "Failed to get the value of attribute: " << attribute;
416 return ParseFailed(line, description.str(), error);
417}
418
419// The line starting at |line_start| of |message| is the failing line. The
420// failure is due to the line type (e.g. the "m" part of the "m-line")
421// not matching what is expected. The expected line type should be
422// provided as |line_type|.
423static bool ParseFailedExpectLine(const std::string& message,
424 size_t line_start,
425 const char line_type,
426 const std::string& line_value,
427 SdpParseError* error) {
428 std::ostringstream description;
429 description << "Expect line: " << line_type << "=" << line_value;
430 return ParseFailed(message, line_start, description.str(), error);
431}
432
433static bool AddLine(const std::string& line, std::string* message) {
434 if (!message)
435 return false;
436
437 message->append(line);
438 message->append(kLineBreak);
439 return true;
440}
441
442static bool GetLine(const std::string& message,
443 size_t* pos,
444 std::string* line) {
445 size_t line_begin = *pos;
446 size_t line_end = message.find(kNewLine, line_begin);
447 if (line_end == std::string::npos) {
448 return false;
449 }
450 // Update the new start position
451 *pos = line_end + 1;
452 if (line_end > 0 && (message.at(line_end - 1) == kReturn)) {
453 --line_end;
454 }
455 *line = message.substr(line_begin, (line_end - line_begin));
456 const char* cline = line->c_str();
457 // RFC 4566
458 // An SDP session description consists of a number of lines of text of
459 // the form:
460 // <type>=<value>
461 // where <type> MUST be exactly one case-significant character and
462 // <value> is structured text whose format depends on <type>.
463 // Whitespace MUST NOT be used on either side of the "=" sign.
decurtis@webrtc.org8af11042015-01-07 19:15:51 +0000464 if (line->length() < 3 ||
465 !islower(cline[0]) ||
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000466 cline[1] != kSdpDelimiterEqual ||
467 cline[2] == kSdpDelimiterSpace) {
468 *pos = line_begin;
469 return false;
470 }
471 return true;
472}
473
474// Init |os| to "|type|=|value|".
475static void InitLine(const char type,
476 const std::string& value,
477 std::ostringstream* os) {
478 os->str("");
479 *os << type << kSdpDelimiterEqual << value;
480}
481
482// Init |os| to "a=|attribute|".
483static void InitAttrLine(const std::string& attribute, std::ostringstream* os) {
484 InitLine(kLineTypeAttributes, attribute, os);
485}
486
487// Writes a SDP attribute line based on |attribute| and |value| to |message|.
488static void AddAttributeLine(const std::string& attribute, int value,
489 std::string* message) {
490 std::ostringstream os;
491 InitAttrLine(attribute, &os);
492 os << kSdpDelimiterColon << value;
493 AddLine(os.str(), message);
494}
495
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000496static bool IsLineType(const std::string& message,
497 const char type,
498 size_t line_start) {
499 if (message.size() < line_start + kLinePrefixLength) {
500 return false;
501 }
502 const char* cmessage = message.c_str();
503 return (cmessage[line_start] == type &&
504 cmessage[line_start + 1] == kSdpDelimiterEqual);
505}
506
507static bool IsLineType(const std::string& line,
508 const char type) {
509 return IsLineType(line, type, 0);
510}
511
512static bool GetLineWithType(const std::string& message, size_t* pos,
513 std::string* line, const char type) {
514 if (!IsLineType(message, type, *pos)) {
515 return false;
516 }
517
518 if (!GetLine(message, pos, line))
519 return false;
520
521 return true;
522}
523
524static bool HasAttribute(const std::string& line,
525 const std::string& attribute) {
526 return (line.compare(kLinePrefixLength, attribute.size(), attribute) == 0);
527}
528
Peter Boström0c4e06b2015-10-07 12:23:21 +0200529static bool AddSsrcLine(uint32_t ssrc_id,
530 const std::string& attribute,
531 const std::string& value,
532 std::string* message) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000533 // RFC 5576
534 // a=ssrc:<ssrc-id> <attribute>:<value>
535 std::ostringstream os;
536 InitAttrLine(kAttributeSsrc, &os);
537 os << kSdpDelimiterColon << ssrc_id << kSdpDelimiterSpace
538 << attribute << kSdpDelimiterColon << value;
539 return AddLine(os.str(), message);
540}
541
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000542// Get value only from <attribute>:<value>.
543static bool GetValue(const std::string& message, const std::string& attribute,
544 std::string* value, SdpParseError* error) {
545 std::string leftpart;
Donald Curtis0e07f922015-05-15 09:21:23 -0700546 if (!rtc::tokenize_first(message, kSdpDelimiterColon, &leftpart, value)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000547 return ParseFailedGetValue(message, attribute, error);
548 }
549 // The left part should end with the expected attribute.
550 if (leftpart.length() < attribute.length() ||
551 leftpart.compare(leftpart.length() - attribute.length(),
552 attribute.length(), attribute) != 0) {
553 return ParseFailedGetValue(message, attribute, error);
554 }
555 return true;
556}
557
558static bool CaseInsensitiveFind(std::string str1, std::string str2) {
559 std::transform(str1.begin(), str1.end(), str1.begin(),
560 ::tolower);
561 std::transform(str2.begin(), str2.end(), str2.begin(),
562 ::tolower);
563 return str1.find(str2) != std::string::npos;
564}
565
wu@webrtc.org5e760e72014-04-02 23:19:09 +0000566template <class T>
567static bool GetValueFromString(const std::string& line,
568 const std::string& s,
569 T* t,
570 SdpParseError* error) {
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000571 if (!rtc::FromString(s, t)) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +0000572 std::ostringstream description;
573 description << "Invalid value: " << s << ".";
574 return ParseFailed(line, description.str(), error);
575 }
576 return true;
577}
578
pkasting@chromium.orge9facf82015-02-17 20:36:28 +0000579static bool GetPayloadTypeFromString(const std::string& line,
580 const std::string& s,
581 int* payload_type,
582 SdpParseError* error) {
583 return GetValueFromString(line, s, payload_type, error) &&
584 cricket::IsValidRtpPayloadType(*payload_type);
585}
586
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000587void CreateTracksFromSsrcInfos(const SsrcInfoVec& ssrc_infos,
588 StreamParamsVec* tracks) {
589 ASSERT(tracks != NULL);
590 for (SsrcInfoVec::const_iterator ssrc_info = ssrc_infos.begin();
591 ssrc_info != ssrc_infos.end(); ++ssrc_info) {
592 if (ssrc_info->cname.empty()) {
593 continue;
594 }
595
596 std::string sync_label;
597 std::string track_id;
598 if (ssrc_info->msid_identifier == kDefaultMsid &&
599 !ssrc_info->mslabel.empty()) {
600 // If there's no msid and there's mslabel, we consider this is a sdp from
601 // a older version of client that doesn't support msid.
602 // In that case, we use the mslabel and label to construct the track.
603 sync_label = ssrc_info->mslabel;
604 track_id = ssrc_info->label;
605 } else {
606 sync_label = ssrc_info->msid_identifier;
607 // The appdata consists of the "id" attribute of a MediaStreamTrack, which
608 // is corresponding to the "id" attribute of StreamParams.
609 track_id = ssrc_info->msid_appdata;
610 }
611 if (sync_label.empty() || track_id.empty()) {
612 ASSERT(false);
613 continue;
614 }
615
616 StreamParamsVec::iterator track = tracks->begin();
617 for (; track != tracks->end(); ++track) {
618 if (track->id == track_id) {
619 break;
620 }
621 }
622 if (track == tracks->end()) {
623 // If we don't find an existing track, create a new one.
624 tracks->push_back(StreamParams());
625 track = tracks->end() - 1;
626 }
627 track->add_ssrc(ssrc_info->ssrc_id);
628 track->cname = ssrc_info->cname;
629 track->sync_label = sync_label;
630 track->id = track_id;
631 }
632}
633
634void GetMediaStreamLabels(const ContentInfo* content,
635 std::set<std::string>* labels) {
636 const MediaContentDescription* media_desc =
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000637 static_cast<const MediaContentDescription*>(
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000638 content->description);
639 const cricket::StreamParamsVec& streams = media_desc->streams();
640 for (cricket::StreamParamsVec::const_iterator it = streams.begin();
641 it != streams.end(); ++it) {
642 labels->insert(it->sync_label);
643 }
644}
645
646// RFC 5245
647// It is RECOMMENDED that default candidates be chosen based on the
648// likelihood of those candidates to work with the peer that is being
649// contacted. It is RECOMMENDED that relayed > reflexive > host.
650static const int kPreferenceUnknown = 0;
651static const int kPreferenceHost = 1;
652static const int kPreferenceReflexive = 2;
653static const int kPreferenceRelayed = 3;
654
655static int GetCandidatePreferenceFromType(const std::string& type) {
656 int preference = kPreferenceUnknown;
657 if (type == cricket::LOCAL_PORT_TYPE) {
658 preference = kPreferenceHost;
659 } else if (type == cricket::STUN_PORT_TYPE) {
660 preference = kPreferenceReflexive;
661 } else if (type == cricket::RELAY_PORT_TYPE) {
662 preference = kPreferenceRelayed;
663 } else {
664 ASSERT(false);
665 }
666 return preference;
667}
668
guoweis@webrtc.org57ac2c82015-02-06 00:45:13 +0000669// Get ip and port of the default destination from the |candidates| with the
670// given value of |component_id|. The default candidate should be the one most
671// likely to work, typically IPv4 relay.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000672// RFC 5245
673// The value of |component_id| currently supported are 1 (RTP) and 2 (RTCP).
674// TODO: Decide the default destination in webrtcsession and
675// pass it down via SessionDescription.
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000676static void GetDefaultDestination(
677 const std::vector<Candidate>& candidates,
678 int component_id, std::string* port,
679 std::string* ip, std::string* addr_type) {
perkj@webrtc.orgd105cc82014-11-07 11:22:06 +0000680 *addr_type = kConnectionIpv4Addrtype;
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000681 *port = kDummyPort;
682 *ip = kDummyAddress;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000683 int current_preference = kPreferenceUnknown;
guoweis@webrtc.org57ac2c82015-02-06 00:45:13 +0000684 int current_family = AF_UNSPEC;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000685 for (std::vector<Candidate>::const_iterator it = candidates.begin();
686 it != candidates.end(); ++it) {
687 if (it->component() != component_id) {
688 continue;
689 }
guoweis@webrtc.org57ac2c82015-02-06 00:45:13 +0000690 // Default destination should be UDP only.
691 if (it->protocol() != cricket::UDP_PROTOCOL_NAME) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000692 continue;
693 }
guoweis@webrtc.org57ac2c82015-02-06 00:45:13 +0000694 const int preference = GetCandidatePreferenceFromType(it->type());
695 const int family = it->address().ipaddr().family();
696 // See if this candidate is more preferable then the current one if it's the
697 // same family. Or if the current family is IPv4 already so we could safely
698 // ignore all IPv6 ones. WebRTC bug 4269.
699 // http://code.google.com/p/webrtc/issues/detail?id=4269
700 if ((preference <= current_preference && current_family == family) ||
701 (current_family == AF_INET && family == AF_INET6)) {
702 continue;
703 }
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000704 if (family == AF_INET) {
705 addr_type->assign(kConnectionIpv4Addrtype);
706 } else if (family == AF_INET6) {
707 addr_type->assign(kConnectionIpv6Addrtype);
708 }
guoweis@webrtc.org57ac2c82015-02-06 00:45:13 +0000709 current_preference = preference;
710 current_family = family;
711 *port = it->address().PortAsString();
712 *ip = it->address().ipaddr().ToString();
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000713 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000714}
715
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000716// Update |mline|'s default destination and append a c line after it.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000717static void UpdateMediaDefaultDestination(
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000718 const std::vector<Candidate>& candidates,
jbauch083b73f2015-07-16 02:46:32 -0700719 const std::string& mline,
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000720 std::string* message) {
721 std::string new_lines;
722 AddLine(mline, &new_lines);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000723 // RFC 4566
724 // m=<media> <port> <proto> <fmt> ...
725 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +0000726 rtc::split(mline, kSdpDelimiterSpace, &fields);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000727 if (fields.size() < 3) {
728 return;
729 }
730
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000731 std::ostringstream os;
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000732 std::string rtp_port, rtp_ip, addr_type;
733 GetDefaultDestination(candidates, ICE_CANDIDATE_COMPONENT_RTP,
734 &rtp_port, &rtp_ip, &addr_type);
735 // Found default RTP candidate.
736 // RFC 5245
737 // The default candidates are added to the SDP as the default
738 // destination for media. For streams based on RTP, this is done by
739 // placing the IP address and port of the RTP candidate into the c and m
740 // lines, respectively.
741 // Update the port in the m line.
742 // If this is a m-line with port equal to 0, we don't change it.
743 if (fields[1] != kMediaPortRejected) {
744 new_lines.replace(fields[0].size() + 1,
745 fields[1].size(),
746 rtp_port);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000747 }
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000748 // Add the c line.
749 // RFC 4566
750 // c=<nettype> <addrtype> <connection-address>
751 InitLine(kLineTypeConnection, kConnectionNettype, &os);
752 os << " " << addr_type << " " << rtp_ip;
753 AddLine(os.str(), &new_lines);
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000754 message->append(new_lines);
755}
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000756
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000757// Gets "a=rtcp" line if found default RTCP candidate from |candidates|.
758static std::string GetRtcpLine(const std::vector<Candidate>& candidates) {
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000759 std::string rtcp_line, rtcp_port, rtcp_ip, addr_type;
760 GetDefaultDestination(candidates, ICE_CANDIDATE_COMPONENT_RTCP,
761 &rtcp_port, &rtcp_ip, &addr_type);
762 // Found default RTCP candidate.
763 // RFC 5245
764 // If the agent is utilizing RTCP, it MUST encode the RTCP candidate
765 // using the a=rtcp attribute as defined in RFC 3605.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000766
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +0000767 // RFC 3605
768 // rtcp-attribute = "a=rtcp:" port [nettype space addrtype space
769 // connection-address] CRLF
770 std::ostringstream os;
771 InitAttrLine(kAttributeRtcp, &os);
772 os << kSdpDelimiterColon
773 << rtcp_port << " "
774 << kConnectionNettype << " "
775 << addr_type << " "
776 << rtcp_ip;
777 rtcp_line = os.str();
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000778 return rtcp_line;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000779}
780
781// Get candidates according to the mline index from SessionDescriptionInterface.
782static void GetCandidatesByMindex(const SessionDescriptionInterface& desci,
783 int mline_index,
784 std::vector<Candidate>* candidates) {
785 if (!candidates) {
786 return;
787 }
788 const IceCandidateCollection* cc = desci.candidates(mline_index);
789 for (size_t i = 0; i < cc->count(); ++i) {
790 const IceCandidateInterface* candidate = cc->at(i);
791 candidates->push_back(candidate->candidate());
792 }
793}
794
795std::string SdpSerialize(const JsepSessionDescription& jdesc) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000796 const cricket::SessionDescription* desc = jdesc.description();
797 if (!desc) {
798 return "";
799 }
800
801 std::string message;
802
803 // Session Description.
804 AddLine(kSessionVersion, &message);
805 // Session Origin
806 // RFC 4566
807 // o=<username> <sess-id> <sess-version> <nettype> <addrtype>
808 // <unicast-address>
809 std::ostringstream os;
810 InitLine(kLineTypeOrigin, kSessionOriginUsername, &os);
jbauch083b73f2015-07-16 02:46:32 -0700811 const std::string& session_id = jdesc.session_id().empty() ?
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000812 kSessionOriginSessionId : jdesc.session_id();
jbauch083b73f2015-07-16 02:46:32 -0700813 const std::string& session_version = jdesc.session_version().empty() ?
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000814 kSessionOriginSessionVersion : jdesc.session_version();
815 os << " " << session_id << " " << session_version << " "
816 << kSessionOriginNettype << " " << kSessionOriginAddrtype << " "
817 << kSessionOriginAddress;
818 AddLine(os.str(), &message);
819 AddLine(kSessionName, &message);
820
821 // Time Description.
822 AddLine(kTimeDescription, &message);
823
824 // Group
825 if (desc->HasGroup(cricket::GROUP_TYPE_BUNDLE)) {
826 std::string group_line = kAttrGroup;
827 const cricket::ContentGroup* group =
828 desc->GetGroupByName(cricket::GROUP_TYPE_BUNDLE);
829 ASSERT(group != NULL);
830 const cricket::ContentNames& content_names = group->content_names();
831 for (cricket::ContentNames::const_iterator it = content_names.begin();
832 it != content_names.end(); ++it) {
833 group_line.append(" ");
834 group_line.append(*it);
835 }
836 AddLine(group_line, &message);
837 }
838
839 // MediaStream semantics
840 InitAttrLine(kAttributeMsidSemantics, &os);
841 os << kSdpDelimiterColon << " " << kMediaStreamSemantic;
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000842
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000843 std::set<std::string> media_stream_labels;
844 const ContentInfo* audio_content = GetFirstAudioContent(desc);
845 if (audio_content)
846 GetMediaStreamLabels(audio_content, &media_stream_labels);
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000847
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000848 const ContentInfo* video_content = GetFirstVideoContent(desc);
849 if (video_content)
850 GetMediaStreamLabels(video_content, &media_stream_labels);
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000851
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000852 for (std::set<std::string>::const_iterator it =
853 media_stream_labels.begin(); it != media_stream_labels.end(); ++it) {
854 os << " " << *it;
855 }
856 AddLine(os.str(), &message);
857
wu@webrtc.org4c3e9912014-07-16 21:03:13 +0000858 // Preserve the order of the media contents.
859 int mline_index = -1;
860 for (cricket::ContentInfos::const_iterator it = desc->contents().begin();
861 it != desc->contents().end(); ++it) {
862 const MediaContentDescription* mdesc =
863 static_cast<const MediaContentDescription*>(it->description);
864 std::vector<Candidate> candidates;
865 GetCandidatesByMindex(jdesc, ++mline_index, &candidates);
866 BuildMediaDescription(&*it,
867 desc->GetTransportInfoByName(it->name),
868 mdesc->type(),
869 candidates,
870 &message);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000871 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000872 return message;
873}
874
875// Serializes the passed in IceCandidateInterface to a SDP string.
876// candidate - The candidate to be serialized.
877std::string SdpSerializeCandidate(
878 const IceCandidateInterface& candidate) {
879 std::string message;
880 std::vector<cricket::Candidate> candidates;
881 candidates.push_back(candidate.candidate());
honghaiza54a0802015-12-16 18:37:23 -0800882 BuildCandidate(candidates, true, &message);
wu@webrtc.orgec9f5fb2014-06-24 17:05:10 +0000883 // From WebRTC draft section 4.8.1.1 candidate-attribute will be
884 // just candidate:<candidate> not a=candidate:<blah>CRLF
885 ASSERT(message.find("a=") == 0);
886 message.erase(0, 2);
887 ASSERT(message.find(kLineBreak) == message.size() - 2);
888 message.resize(message.size() - 2);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000889 return message;
890}
891
892bool SdpDeserialize(const std::string& message,
893 JsepSessionDescription* jdesc,
894 SdpParseError* error) {
895 std::string session_id;
896 std::string session_version;
Peter Thatcher7cbd1882015-09-17 18:54:52 -0700897 TransportDescription session_td("", "");
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000898 RtpHeaderExtensions session_extmaps;
899 cricket::SessionDescription* desc = new cricket::SessionDescription();
900 std::vector<JsepIceCandidate*> candidates;
901 size_t current_pos = 0;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000902
903 // Session Description
904 if (!ParseSessionDescription(message, &current_pos, &session_id,
deadbeefc80741f2015-10-22 13:14:45 -0700905 &session_version, &session_td, &session_extmaps,
906 desc, error)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000907 delete desc;
908 return false;
909 }
910
911 // Media Description
deadbeefc80741f2015-10-22 13:14:45 -0700912 if (!ParseMediaDescription(message, session_td, session_extmaps, &current_pos,
913 desc, &candidates, error)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000914 delete desc;
915 for (std::vector<JsepIceCandidate*>::const_iterator
916 it = candidates.begin(); it != candidates.end(); ++it) {
917 delete *it;
918 }
919 return false;
920 }
921
922 jdesc->Initialize(desc, session_id, session_version);
923
924 for (std::vector<JsepIceCandidate*>::const_iterator
925 it = candidates.begin(); it != candidates.end(); ++it) {
926 jdesc->AddCandidate(*it);
927 delete *it;
928 }
929 return true;
930}
931
932bool SdpDeserializeCandidate(const std::string& message,
933 JsepIceCandidate* jcandidate,
934 SdpParseError* error) {
935 ASSERT(jcandidate != NULL);
936 Candidate candidate;
937 if (!ParseCandidate(message, &candidate, error, true)) {
938 return false;
939 }
940 jcandidate->SetCandidate(candidate);
941 return true;
942}
943
944bool ParseCandidate(const std::string& message, Candidate* candidate,
945 SdpParseError* error, bool is_raw) {
946 ASSERT(candidate != NULL);
947
948 // Get the first line from |message|.
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000949 std::string first_line = message;
950 size_t pos = 0;
951 GetLine(message, &pos, &first_line);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000952
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000953 // Makes sure |message| contains only one line.
954 if (message.size() > first_line.size()) {
955 std::string left, right;
Donald Curtis0e07f922015-05-15 09:21:23 -0700956 if (rtc::tokenize_first(message, kNewLine, &left, &right) &&
957 !right.empty()) {
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000958 return ParseFailed(message, 0, "Expect one line only", error);
959 }
960 }
961
962 // From WebRTC draft section 4.8.1.1 candidate-attribute should be
963 // candidate:<candidate> when trickled, but we still support
964 // a=candidate:<blah>CRLF for backward compatibility and for parsing a line
965 // from the SDP.
966 if (IsLineType(first_line, kLineTypeAttributes)) {
967 first_line = first_line.substr(kLinePrefixLength);
968 }
969
970 std::string attribute_candidate;
971 std::string candidate_value;
972
973 // |first_line| must be in the form of "candidate:<value>".
Donald Curtis144d0182015-05-15 13:14:24 -0700974 if (!rtc::tokenize_first(first_line, kSdpDelimiterColon, &attribute_candidate,
975 &candidate_value) ||
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000976 attribute_candidate != kAttributeCandidate) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000977 if (is_raw) {
978 std::ostringstream description;
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000979 description << "Expect line: " << kAttributeCandidate
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000980 << ":" << "<candidate-str>";
981 return ParseFailed(first_line, 0, description.str(), error);
982 } else {
983 return ParseFailedExpectLine(first_line, 0, kLineTypeAttributes,
984 kAttributeCandidate, error);
985 }
986 }
987
988 std::vector<std::string> fields;
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +0000989 rtc::split(candidate_value, kSdpDelimiterSpace, &fields);
990
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000991 // RFC 5245
992 // a=candidate:<foundation> <component-id> <transport> <priority>
993 // <connection-address> <port> typ <candidate-types>
994 // [raddr <connection-address>] [rport <port>]
995 // *(SP extension-att-name SP extension-att-value)
996 const size_t expected_min_fields = 8;
997 if (fields.size() < expected_min_fields ||
998 (fields[6] != kAttributeCandidateTyp)) {
999 return ParseFailedExpectMinFieldNum(first_line, expected_min_fields, error);
1000 }
jbauch083b73f2015-07-16 02:46:32 -07001001 const std::string& foundation = fields[0];
jiayl@webrtc.org7ec3f9f2014-08-08 23:09:15 +00001002
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001003 int component_id = 0;
1004 if (!GetValueFromString(first_line, fields[1], &component_id, error)) {
1005 return false;
1006 }
jbauch083b73f2015-07-16 02:46:32 -07001007 const std::string& transport = fields[2];
Peter Boström0c4e06b2015-10-07 12:23:21 +02001008 uint32_t priority = 0;
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001009 if (!GetValueFromString(first_line, fields[3], &priority, error)) {
1010 return false;
1011 }
jbauch083b73f2015-07-16 02:46:32 -07001012 const std::string& connection_address = fields[4];
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001013 int port = 0;
1014 if (!GetValueFromString(first_line, fields[5], &port, error)) {
1015 return false;
1016 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001017 SocketAddress address(connection_address, port);
1018
1019 cricket::ProtocolType protocol;
1020 if (!StringToProto(transport.c_str(), &protocol)) {
1021 return ParseFailed(first_line, "Unsupported transport type.", error);
1022 }
1023
1024 std::string candidate_type;
jbauch083b73f2015-07-16 02:46:32 -07001025 const std::string& type = fields[7];
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001026 if (type == kCandidateHost) {
1027 candidate_type = cricket::LOCAL_PORT_TYPE;
1028 } else if (type == kCandidateSrflx) {
1029 candidate_type = cricket::STUN_PORT_TYPE;
1030 } else if (type == kCandidateRelay) {
1031 candidate_type = cricket::RELAY_PORT_TYPE;
1032 } else {
1033 return ParseFailed(first_line, "Unsupported candidate type.", error);
1034 }
1035
1036 size_t current_position = expected_min_fields;
1037 SocketAddress related_address;
1038 // The 2 optional fields for related address
1039 // [raddr <connection-address>] [rport <port>]
1040 if (fields.size() >= (current_position + 2) &&
1041 fields[current_position] == kAttributeCandidateRaddr) {
1042 related_address.SetIP(fields[++current_position]);
1043 ++current_position;
1044 }
1045 if (fields.size() >= (current_position + 2) &&
1046 fields[current_position] == kAttributeCandidateRport) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001047 int port = 0;
1048 if (!GetValueFromString(
1049 first_line, fields[++current_position], &port, error)) {
1050 return false;
1051 }
1052 related_address.SetPort(port);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001053 ++current_position;
1054 }
1055
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001056 // If this is a TCP candidate, it has additional extension as defined in
1057 // RFC 6544.
1058 std::string tcptype;
1059 if (fields.size() >= (current_position + 2) &&
1060 fields[current_position] == kTcpCandidateType) {
1061 tcptype = fields[++current_position];
1062 ++current_position;
1063
1064 if (tcptype != cricket::TCPTYPE_ACTIVE_STR &&
1065 tcptype != cricket::TCPTYPE_PASSIVE_STR &&
1066 tcptype != cricket::TCPTYPE_SIMOPEN_STR) {
1067 return ParseFailed(first_line, "Invalid TCP candidate type.", error);
1068 }
1069
1070 if (protocol != cricket::PROTO_TCP) {
1071 return ParseFailed(first_line, "Invalid non-TCP candidate", error);
1072 }
1073 }
1074
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001075 // Extension
honghaiza54a0802015-12-16 18:37:23 -08001076 // Though non-standard, we support the ICE ufrag and pwd being signaled on
1077 // the candidate to avoid issues with confusing which generation a candidate
1078 // belongs to when trickling multiple generations at the same time.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001079 std::string username;
1080 std::string password;
Peter Boström0c4e06b2015-10-07 12:23:21 +02001081 uint32_t generation = 0;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001082 for (size_t i = current_position; i + 1 < fields.size(); ++i) {
1083 // RFC 5245
1084 // *(SP extension-att-name SP extension-att-value)
1085 if (fields[i] == kAttributeCandidateGeneration) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001086 if (!GetValueFromString(first_line, fields[++i], &generation, error)) {
1087 return false;
1088 }
honghaiza54a0802015-12-16 18:37:23 -08001089 } else if (fields[i] == kAttributeCandidateUfrag) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001090 username = fields[++i];
honghaiza54a0802015-12-16 18:37:23 -08001091 } else if (fields[i] == kAttributeCandidatePwd) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001092 password = fields[++i];
1093 } else {
1094 // Skip the unknown extension.
1095 ++i;
1096 }
1097 }
1098
guoweis@webrtc.org61c12472015-01-15 06:53:07 +00001099 *candidate = Candidate(component_id, cricket::ProtoToString(protocol),
guoweis@webrtc.org950c5182014-12-16 23:01:31 +00001100 address, priority, username, password, candidate_type,
1101 generation, foundation);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001102 candidate->set_related_address(related_address);
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001103 candidate->set_tcptype(tcptype);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001104 return true;
1105}
1106
1107bool ParseIceOptions(const std::string& line,
1108 std::vector<std::string>* transport_options,
1109 SdpParseError* error) {
1110 std::string ice_options;
1111 if (!GetValue(line, kAttributeIceOption, &ice_options, error)) {
1112 return false;
1113 }
1114 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001115 rtc::split(ice_options, kSdpDelimiterSpace, &fields);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001116 for (size_t i = 0; i < fields.size(); ++i) {
1117 transport_options->push_back(fields[i]);
1118 }
1119 return true;
1120}
1121
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00001122bool ParseSctpPort(const std::string& line,
1123 int* sctp_port,
1124 SdpParseError* error) {
1125 // draft-ietf-mmusic-sctp-sdp-07
1126 // a=sctp-port
1127 std::vector<std::string> fields;
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00001128 const size_t expected_min_fields = 2;
lally69f57602015-10-08 10:15:04 -07001129 rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterColon, &fields);
1130 if (fields.size() < expected_min_fields) {
1131 fields.resize(0);
1132 rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterSpace, &fields);
1133 }
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00001134 if (fields.size() < expected_min_fields) {
1135 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
1136 }
1137 if (!rtc::FromString(fields[1], sctp_port)) {
lally69f57602015-10-08 10:15:04 -07001138 return ParseFailed(line, "Invalid sctp port value.", error);
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00001139 }
1140 return true;
1141}
1142
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001143bool ParseExtmap(const std::string& line, RtpHeaderExtension* extmap,
1144 SdpParseError* error) {
1145 // RFC 5285
1146 // a=extmap:<value>["/"<direction>] <URI> <extensionattributes>
1147 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001148 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001149 kSdpDelimiterSpace, &fields);
1150 const size_t expected_min_fields = 2;
1151 if (fields.size() < expected_min_fields) {
1152 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
1153 }
1154 std::string uri = fields[1];
1155
1156 std::string value_direction;
1157 if (!GetValue(fields[0], kAttributeExtmap, &value_direction, error)) {
1158 return false;
1159 }
1160 std::vector<std::string> sub_fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001161 rtc::split(value_direction, kSdpDelimiterSlash, &sub_fields);
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001162 int value = 0;
1163 if (!GetValueFromString(line, sub_fields[0], &value, error)) {
1164 return false;
1165 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001166
1167 *extmap = RtpHeaderExtension(uri, value);
1168 return true;
1169}
1170
1171void BuildMediaDescription(const ContentInfo* content_info,
1172 const TransportInfo* transport_info,
1173 const MediaType media_type,
wu@webrtc.org4c3e9912014-07-16 21:03:13 +00001174 const std::vector<Candidate>& candidates,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001175 std::string* message) {
1176 ASSERT(message != NULL);
1177 if (content_info == NULL || message == NULL) {
1178 return;
1179 }
1180 // TODO: Rethink if we should use sprintfn instead of stringstream.
1181 // According to the style guide, streams should only be used for logging.
1182 // http://google-styleguide.googlecode.com/svn/
1183 // trunk/cppguide.xml?showone=Streams#Streams
1184 std::ostringstream os;
1185 const MediaContentDescription* media_desc =
henrike@webrtc.org28654cb2013-07-22 21:07:49 +00001186 static_cast<const MediaContentDescription*>(
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001187 content_info->description);
1188 ASSERT(media_desc != NULL);
1189
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001190 int sctp_port = cricket::kSctpDefaultPort;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001191
1192 // RFC 4566
1193 // m=<media> <port> <proto> <fmt>
1194 // fmt is a list of payload type numbers that MAY be used in the session.
1195 const char* type = NULL;
1196 if (media_type == cricket::MEDIA_TYPE_AUDIO)
1197 type = kMediaTypeAudio;
1198 else if (media_type == cricket::MEDIA_TYPE_VIDEO)
1199 type = kMediaTypeVideo;
1200 else if (media_type == cricket::MEDIA_TYPE_DATA)
1201 type = kMediaTypeData;
1202 else
1203 ASSERT(false);
1204
1205 std::string fmt;
1206 if (media_type == cricket::MEDIA_TYPE_VIDEO) {
1207 const VideoContentDescription* video_desc =
1208 static_cast<const VideoContentDescription*>(media_desc);
1209 for (std::vector<cricket::VideoCodec>::const_iterator it =
1210 video_desc->codecs().begin();
1211 it != video_desc->codecs().end(); ++it) {
1212 fmt.append(" ");
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001213 fmt.append(rtc::ToString<int>(it->id));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001214 }
1215 } else if (media_type == cricket::MEDIA_TYPE_AUDIO) {
1216 const AudioContentDescription* audio_desc =
1217 static_cast<const AudioContentDescription*>(media_desc);
1218 for (std::vector<cricket::AudioCodec>::const_iterator it =
1219 audio_desc->codecs().begin();
1220 it != audio_desc->codecs().end(); ++it) {
1221 fmt.append(" ");
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001222 fmt.append(rtc::ToString<int>(it->id));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001223 }
1224 } else if (media_type == cricket::MEDIA_TYPE_DATA) {
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001225 const DataContentDescription* data_desc =
1226 static_cast<const DataContentDescription*>(media_desc);
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001227 if (IsDtlsSctp(media_desc->protocol())) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001228 fmt.append(" ");
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001229
1230 for (std::vector<cricket::DataCodec>::const_iterator it =
1231 data_desc->codecs().begin();
1232 it != data_desc->codecs().end(); ++it) {
1233 if (it->id == cricket::kGoogleSctpDataCodecId &&
1234 it->GetParam(cricket::kCodecParamPort, &sctp_port)) {
1235 break;
1236 }
1237 }
1238
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001239 fmt.append(rtc::ToString<int>(sctp_port));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001240 } else {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001241 for (std::vector<cricket::DataCodec>::const_iterator it =
1242 data_desc->codecs().begin();
1243 it != data_desc->codecs().end(); ++it) {
1244 fmt.append(" ");
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001245 fmt.append(rtc::ToString<int>(it->id));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001246 }
1247 }
1248 }
1249 // The fmt must never be empty. If no codecs are found, set the fmt attribute
1250 // to 0.
1251 if (fmt.empty()) {
1252 fmt = " 0";
1253 }
1254
1255 // The port number in the m line will be updated later when associate with
1256 // the candidates.
1257 // RFC 3264
1258 // To reject an offered stream, the port number in the corresponding stream in
1259 // the answer MUST be set to zero.
jbauch083b73f2015-07-16 02:46:32 -07001260 const std::string& port = content_info->rejected ?
pthatcher@webrtc.orgc9d6d142014-10-23 23:37:22 +00001261 kMediaPortRejected : kDummyPort;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001262
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001263 rtc::SSLFingerprint* fp = (transport_info) ?
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001264 transport_info->description.identity_fingerprint.get() : NULL;
1265
wu@webrtc.org4c3e9912014-07-16 21:03:13 +00001266 // Add the m and c lines.
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001267 InitLine(kLineTypeMedia, type, &os);
1268 os << " " << port << " " << media_desc->protocol() << fmt;
wu@webrtc.org4c3e9912014-07-16 21:03:13 +00001269 std::string mline = os.str();
1270 UpdateMediaDefaultDestination(candidates, mline, message);
1271
1272 // RFC 4566
1273 // b=AS:<bandwidth>
Peter Thatcherc0c3a862015-06-24 15:31:25 -07001274 if (media_desc->bandwidth() >= 1000) {
wu@webrtc.org4c3e9912014-07-16 21:03:13 +00001275 InitLine(kLineTypeSessionBandwidth, kApplicationSpecificMaximum, &os);
1276 os << kSdpDelimiterColon << (media_desc->bandwidth() / 1000);
1277 AddLine(os.str(), message);
1278 }
1279
1280 // Add the a=rtcp line.
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001281 if (IsRtp(media_desc->protocol())) {
wu@webrtc.org4c3e9912014-07-16 21:03:13 +00001282 std::string rtcp_line = GetRtcpLine(candidates);
1283 if (!rtcp_line.empty()) {
1284 AddLine(rtcp_line, message);
1285 }
1286 }
1287
honghaiza54a0802015-12-16 18:37:23 -08001288 // Build the a=candidate lines. We don't include ufrag and pwd in the
1289 // candidates in the SDP to avoid redundancy.
1290 BuildCandidate(candidates, false, message);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001291
1292 // Use the transport_info to build the media level ice-ufrag and ice-pwd.
1293 if (transport_info) {
1294 // RFC 5245
1295 // ice-pwd-att = "ice-pwd" ":" password
1296 // ice-ufrag-att = "ice-ufrag" ":" ufrag
1297 // ice-ufrag
deadbeef3f7219b2015-12-28 15:17:14 -08001298 if (!transport_info->description.ice_ufrag.empty()) {
1299 InitAttrLine(kAttributeIceUfrag, &os);
1300 os << kSdpDelimiterColon << transport_info->description.ice_ufrag;
1301 AddLine(os.str(), message);
1302 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001303 // ice-pwd
deadbeef3f7219b2015-12-28 15:17:14 -08001304 if (!transport_info->description.ice_pwd.empty()) {
1305 InitAttrLine(kAttributeIcePwd, &os);
1306 os << kSdpDelimiterColon << transport_info->description.ice_pwd;
1307 AddLine(os.str(), message);
1308 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001309
1310 // draft-petithuguenin-mmusic-ice-attributes-level-03
1311 BuildIceOptions(transport_info->description.transport_options, message);
1312
1313 // RFC 4572
1314 // fingerprint-attribute =
1315 // "fingerprint" ":" hash-func SP fingerprint
1316 if (fp) {
1317 // Insert the fingerprint attribute.
1318 InitAttrLine(kAttributeFingerprint, &os);
1319 os << kSdpDelimiterColon
1320 << fp->algorithm << kSdpDelimiterSpace
1321 << fp->GetRfc4572Fingerprint();
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001322 AddLine(os.str(), message);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00001323
1324 // Inserting setup attribute.
1325 if (transport_info->description.connection_role !=
1326 cricket::CONNECTIONROLE_NONE) {
1327 // Making sure we are not using "passive" mode.
1328 cricket::ConnectionRole role =
1329 transport_info->description.connection_role;
mallinath@webrtc.org19f27e62013-10-13 17:18:27 +00001330 std::string dtls_role_str;
1331 VERIFY(cricket::ConnectionRoleToString(role, &dtls_role_str));
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00001332 InitAttrLine(kAttributeSetup, &os);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00001333 os << kSdpDelimiterColon << dtls_role_str;
1334 AddLine(os.str(), message);
1335 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001336 }
1337 }
1338
1339 // RFC 3388
1340 // mid-attribute = "a=mid:" identification-tag
1341 // identification-tag = token
1342 // Use the content name as the mid identification-tag.
1343 InitAttrLine(kAttributeMid, &os);
1344 os << kSdpDelimiterColon << content_info->name;
1345 AddLine(os.str(), message);
1346
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001347 if (IsDtlsSctp(media_desc->protocol())) {
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001348 BuildSctpContentAttributes(message, sctp_port);
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001349 } else if (IsRtp(media_desc->protocol())) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001350 BuildRtpContentAttributes(media_desc, media_type, message);
1351 }
1352}
1353
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001354void BuildSctpContentAttributes(std::string* message, int sctp_port) {
wu@webrtc.org78187522013-10-07 23:32:02 +00001355 // draft-ietf-mmusic-sctp-sdp-04
1356 // a=sctpmap:sctpmap-number protocol [streams]
lally69f57602015-10-08 10:15:04 -07001357 // TODO(lally): switch this over to mmusic-sctp-sdp-12 (or later), with
1358 // 'a=sctp-port:'
wu@webrtc.org78187522013-10-07 23:32:02 +00001359 std::ostringstream os;
1360 InitAttrLine(kAttributeSctpmap, &os);
jiayl@webrtc.org9c16c392014-05-01 18:30:30 +00001361 os << kSdpDelimiterColon << sctp_port << kSdpDelimiterSpace
wu@webrtc.org78187522013-10-07 23:32:02 +00001362 << kDefaultSctpmapProtocol << kSdpDelimiterSpace
1363 << (cricket::kMaxSctpSid + 1);
1364 AddLine(os.str(), message);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001365}
1366
1367void BuildRtpContentAttributes(
1368 const MediaContentDescription* media_desc,
1369 const MediaType media_type,
1370 std::string* message) {
1371 std::ostringstream os;
1372 // RFC 5285
1373 // a=extmap:<value>["/"<direction>] <URI> <extensionattributes>
1374 // The definitions MUST be either all session level or all media level. This
1375 // implementation uses all media level.
1376 for (size_t i = 0; i < media_desc->rtp_header_extensions().size(); ++i) {
1377 InitAttrLine(kAttributeExtmap, &os);
1378 os << kSdpDelimiterColon << media_desc->rtp_header_extensions()[i].id
1379 << kSdpDelimiterSpace << media_desc->rtp_header_extensions()[i].uri;
1380 AddLine(os.str(), message);
1381 }
1382
1383 // RFC 3264
1384 // a=sendrecv || a=sendonly || a=sendrecv || a=inactive
deadbeefc80741f2015-10-22 13:14:45 -07001385 switch (media_desc->direction()) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001386 case cricket::MD_INACTIVE:
1387 InitAttrLine(kAttributeInactive, &os);
1388 break;
1389 case cricket::MD_SENDONLY:
1390 InitAttrLine(kAttributeSendOnly, &os);
1391 break;
1392 case cricket::MD_RECVONLY:
1393 InitAttrLine(kAttributeRecvOnly, &os);
1394 break;
1395 case cricket::MD_SENDRECV:
1396 default:
1397 InitAttrLine(kAttributeSendRecv, &os);
1398 break;
1399 }
1400 AddLine(os.str(), message);
1401
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001402 // RFC 5761
1403 // a=rtcp-mux
1404 if (media_desc->rtcp_mux()) {
1405 InitAttrLine(kAttributeRtcpMux, &os);
1406 AddLine(os.str(), message);
1407 }
1408
deadbeef13871492015-12-09 12:37:51 -08001409 // RFC 5506
1410 // a=rtcp-rsize
1411 if (media_desc->rtcp_reduced_size()) {
1412 InitAttrLine(kAttributeRtcpReducedSize, &os);
1413 AddLine(os.str(), message);
1414 }
1415
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001416 // RFC 4568
1417 // a=crypto:<tag> <crypto-suite> <key-params> [<session-params>]
1418 for (std::vector<CryptoParams>::const_iterator it =
1419 media_desc->cryptos().begin();
1420 it != media_desc->cryptos().end(); ++it) {
1421 InitAttrLine(kAttributeCrypto, &os);
1422 os << kSdpDelimiterColon << it->tag << " " << it->cipher_suite << " "
1423 << it->key_params;
1424 if (!it->session_params.empty()) {
1425 os << " " << it->session_params;
1426 }
1427 AddLine(os.str(), message);
1428 }
1429
1430 // RFC 4566
1431 // a=rtpmap:<payload type> <encoding name>/<clock rate>
1432 // [/<encodingparameters>]
1433 BuildRtpMap(media_desc, media_type, message);
1434
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001435 for (StreamParamsVec::const_iterator track = media_desc->streams().begin();
1436 track != media_desc->streams().end(); ++track) {
1437 // Require that the track belongs to a media stream,
1438 // ie the sync_label is set. This extra check is necessary since the
1439 // MediaContentDescription always contains a streamparam with an ssrc even
1440 // if no track or media stream have been created.
1441 if (track->sync_label.empty()) continue;
1442
1443 // Build the ssrc-group lines.
1444 for (size_t i = 0; i < track->ssrc_groups.size(); ++i) {
1445 // RFC 5576
1446 // a=ssrc-group:<semantics> <ssrc-id> ...
1447 if (track->ssrc_groups[i].ssrcs.empty()) {
1448 continue;
1449 }
1450 std::ostringstream os;
1451 InitAttrLine(kAttributeSsrcGroup, &os);
1452 os << kSdpDelimiterColon << track->ssrc_groups[i].semantics;
Peter Boström0c4e06b2015-10-07 12:23:21 +02001453 std::vector<uint32_t>::const_iterator ssrc =
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001454 track->ssrc_groups[i].ssrcs.begin();
1455 for (; ssrc != track->ssrc_groups[i].ssrcs.end(); ++ssrc) {
Peter Boström0c4e06b2015-10-07 12:23:21 +02001456 os << kSdpDelimiterSpace << rtc::ToString<uint32_t>(*ssrc);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001457 }
1458 AddLine(os.str(), message);
1459 }
1460 // Build the ssrc lines for each ssrc.
1461 for (size_t i = 0; i < track->ssrcs.size(); ++i) {
Peter Boström0c4e06b2015-10-07 12:23:21 +02001462 uint32_t ssrc = track->ssrcs[i];
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001463 // RFC 5576
1464 // a=ssrc:<ssrc-id> cname:<value>
1465 AddSsrcLine(ssrc, kSsrcAttributeCname,
1466 track->cname, message);
1467
1468 // draft-alvestrand-mmusic-msid-00
1469 // a=ssrc:<ssrc-id> msid:identifier [appdata]
1470 // The appdata consists of the "id" attribute of a MediaStreamTrack, which
1471 // is corresponding to the "name" attribute of StreamParams.
1472 std::string appdata = track->id;
1473 std::ostringstream os;
1474 InitAttrLine(kAttributeSsrc, &os);
1475 os << kSdpDelimiterColon << ssrc << kSdpDelimiterSpace
1476 << kSsrcAttributeMsid << kSdpDelimiterColon << track->sync_label
1477 << kSdpDelimiterSpace << appdata;
1478 AddLine(os.str(), message);
1479
1480 // TODO(ronghuawu): Remove below code which is for backward compatibility.
1481 // draft-alvestrand-rtcweb-mid-01
1482 // a=ssrc:<ssrc-id> mslabel:<value>
1483 // The label isn't yet defined.
1484 // a=ssrc:<ssrc-id> label:<value>
1485 AddSsrcLine(ssrc, kSsrcAttributeMslabel, track->sync_label, message);
1486 AddSsrcLine(ssrc, kSSrcAttributeLabel, track->id, message);
1487 }
1488 }
1489}
1490
1491void WriteFmtpHeader(int payload_type, std::ostringstream* os) {
1492 // fmtp header: a=fmtp:|payload_type| <parameters>
1493 // Add a=fmtp
1494 InitAttrLine(kAttributeFmtp, os);
1495 // Add :|payload_type|
1496 *os << kSdpDelimiterColon << payload_type;
1497}
1498
1499void WriteRtcpFbHeader(int payload_type, std::ostringstream* os) {
1500 // rtcp-fb header: a=rtcp-fb:|payload_type|
1501 // <parameters>/<ccm <ccm_parameters>>
1502 // Add a=rtcp-fb
1503 InitAttrLine(kAttributeRtcpFb, os);
1504 // Add :
1505 *os << kSdpDelimiterColon;
1506 if (payload_type == kWildcardPayloadType) {
1507 *os << "*";
1508 } else {
1509 *os << payload_type;
1510 }
1511}
1512
1513void WriteFmtpParameter(const std::string& parameter_name,
1514 const std::string& parameter_value,
1515 std::ostringstream* os) {
1516 // fmtp parameters: |parameter_name|=|parameter_value|
1517 *os << parameter_name << kSdpDelimiterEqual << parameter_value;
1518}
1519
1520void WriteFmtpParameters(const cricket::CodecParameterMap& parameters,
1521 std::ostringstream* os) {
1522 for (cricket::CodecParameterMap::const_iterator fmtp = parameters.begin();
1523 fmtp != parameters.end(); ++fmtp) {
1524 // Each new parameter, except the first one starts with ";" and " ".
1525 if (fmtp != parameters.begin()) {
1526 *os << kSdpDelimiterSemicolon;
1527 }
1528 *os << kSdpDelimiterSpace;
1529 WriteFmtpParameter(fmtp->first, fmtp->second, os);
1530 }
1531}
1532
1533bool IsFmtpParam(const std::string& name) {
1534 const char* kFmtpParams[] = {
1535 kCodecParamMinPTime, kCodecParamSPropStereo,
Minyue Li7100dcd2015-03-27 05:05:59 +01001536 kCodecParamStereo, kCodecParamUseInbandFec, kCodecParamUseDtx,
1537 kCodecParamStartBitrate, kCodecParamMaxBitrate, kCodecParamMinBitrate,
1538 kCodecParamMaxQuantization, kCodecParamSctpProtocol, kCodecParamSctpStreams,
buildbot@webrtc.org5d639b32014-09-10 07:57:12 +00001539 kCodecParamMaxAverageBitrate, kCodecParamMaxPlaybackRate,
1540 kCodecParamAssociatedPayloadType
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001541 };
tfarina5237aaf2015-11-10 23:44:30 -08001542 for (size_t i = 0; i < arraysize(kFmtpParams); ++i) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001543 if (_stricmp(name.c_str(), kFmtpParams[i]) == 0) {
1544 return true;
1545 }
1546 }
1547 return false;
1548}
1549
1550// Retreives fmtp parameters from |params|, which may contain other parameters
1551// as well, and puts them in |fmtp_parameters|.
1552void GetFmtpParams(const cricket::CodecParameterMap& params,
1553 cricket::CodecParameterMap* fmtp_parameters) {
1554 for (cricket::CodecParameterMap::const_iterator iter = params.begin();
1555 iter != params.end(); ++iter) {
1556 if (IsFmtpParam(iter->first)) {
1557 (*fmtp_parameters)[iter->first] = iter->second;
1558 }
1559 }
1560}
1561
1562template <class T>
1563void AddFmtpLine(const T& codec, std::string* message) {
1564 cricket::CodecParameterMap fmtp_parameters;
1565 GetFmtpParams(codec.params, &fmtp_parameters);
1566 if (fmtp_parameters.empty()) {
1567 // No need to add an fmtp if it will have no (optional) parameters.
1568 return;
1569 }
1570 std::ostringstream os;
1571 WriteFmtpHeader(codec.id, &os);
1572 WriteFmtpParameters(fmtp_parameters, &os);
1573 AddLine(os.str(), message);
1574 return;
1575}
1576
1577template <class T>
1578void AddRtcpFbLines(const T& codec, std::string* message) {
1579 for (std::vector<cricket::FeedbackParam>::const_iterator iter =
1580 codec.feedback_params.params().begin();
1581 iter != codec.feedback_params.params().end(); ++iter) {
1582 std::ostringstream os;
1583 WriteRtcpFbHeader(codec.id, &os);
1584 os << " " << iter->id();
1585 if (!iter->param().empty()) {
1586 os << " " << iter->param();
1587 }
1588 AddLine(os.str(), message);
1589 }
1590}
1591
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00001592bool AddSctpDataCodec(DataContentDescription* media_desc,
1593 int sctp_port) {
1594 if (media_desc->HasCodec(cricket::kGoogleSctpDataCodecId)) {
1595 return ParseFailed("",
1596 "Can't have multiple sctp port attributes.",
1597 NULL);
1598 }
1599 // Add the SCTP Port number as a pseudo-codec "port" parameter
1600 cricket::DataCodec codec_port(
1601 cricket::kGoogleSctpDataCodecId, cricket::kGoogleSctpDataCodecName,
1602 0);
1603 codec_port.SetParam(cricket::kCodecParamPort, sctp_port);
1604 LOG(INFO) << "AddSctpDataCodec: Got SCTP Port Number "
1605 << sctp_port;
1606 media_desc->AddCodec(codec_port);
1607 return true;
1608}
1609
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001610bool GetMinValue(const std::vector<int>& values, int* value) {
1611 if (values.empty()) {
1612 return false;
1613 }
1614 std::vector<int>::const_iterator found =
1615 std::min_element(values.begin(), values.end());
1616 *value = *found;
1617 return true;
1618}
1619
1620bool GetParameter(const std::string& name,
1621 const cricket::CodecParameterMap& params, int* value) {
1622 std::map<std::string, std::string>::const_iterator found =
1623 params.find(name);
1624 if (found == params.end()) {
1625 return false;
1626 }
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001627 if (!rtc::FromString(found->second, value)) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00001628 return false;
1629 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001630 return true;
1631}
1632
1633void BuildRtpMap(const MediaContentDescription* media_desc,
1634 const MediaType media_type,
1635 std::string* message) {
1636 ASSERT(message != NULL);
1637 ASSERT(media_desc != NULL);
1638 std::ostringstream os;
1639 if (media_type == cricket::MEDIA_TYPE_VIDEO) {
1640 const VideoContentDescription* video_desc =
1641 static_cast<const VideoContentDescription*>(media_desc);
1642 for (std::vector<cricket::VideoCodec>::const_iterator it =
1643 video_desc->codecs().begin();
1644 it != video_desc->codecs().end(); ++it) {
1645 // RFC 4566
1646 // a=rtpmap:<payload type> <encoding name>/<clock rate>
1647 // [/<encodingparameters>]
1648 if (it->id != kWildcardPayloadType) {
1649 InitAttrLine(kAttributeRtpmap, &os);
1650 os << kSdpDelimiterColon << it->id << " " << it->name
1651 << "/" << kDefaultVideoClockrate;
1652 AddLine(os.str(), message);
1653 }
1654 AddRtcpFbLines(*it, message);
1655 AddFmtpLine(*it, message);
1656 }
1657 } else if (media_type == cricket::MEDIA_TYPE_AUDIO) {
1658 const AudioContentDescription* audio_desc =
1659 static_cast<const AudioContentDescription*>(media_desc);
1660 std::vector<int> ptimes;
1661 std::vector<int> maxptimes;
1662 int max_minptime = 0;
1663 for (std::vector<cricket::AudioCodec>::const_iterator it =
1664 audio_desc->codecs().begin();
1665 it != audio_desc->codecs().end(); ++it) {
1666 ASSERT(!it->name.empty());
1667 // RFC 4566
1668 // a=rtpmap:<payload type> <encoding name>/<clock rate>
1669 // [/<encodingparameters>]
1670 InitAttrLine(kAttributeRtpmap, &os);
1671 os << kSdpDelimiterColon << it->id << " ";
1672 os << it->name << "/" << it->clockrate;
1673 if (it->channels != 1) {
1674 os << "/" << it->channels;
1675 }
1676 AddLine(os.str(), message);
1677 AddRtcpFbLines(*it, message);
1678 AddFmtpLine(*it, message);
1679 int minptime = 0;
1680 if (GetParameter(kCodecParamMinPTime, it->params, &minptime)) {
1681 max_minptime = std::max(minptime, max_minptime);
1682 }
1683 int ptime;
1684 if (GetParameter(kCodecParamPTime, it->params, &ptime)) {
1685 ptimes.push_back(ptime);
1686 }
1687 int maxptime;
1688 if (GetParameter(kCodecParamMaxPTime, it->params, &maxptime)) {
1689 maxptimes.push_back(maxptime);
1690 }
1691 }
1692 // Populate the maxptime attribute with the smallest maxptime of all codecs
1693 // under the same m-line.
1694 int min_maxptime = INT_MAX;
1695 if (GetMinValue(maxptimes, &min_maxptime)) {
1696 AddAttributeLine(kCodecParamMaxPTime, min_maxptime, message);
1697 }
1698 ASSERT(min_maxptime > max_minptime);
1699 // Populate the ptime attribute with the smallest ptime or the largest
1700 // minptime, whichever is the largest, for all codecs under the same m-line.
1701 int ptime = INT_MAX;
1702 if (GetMinValue(ptimes, &ptime)) {
1703 ptime = std::min(ptime, min_maxptime);
1704 ptime = std::max(ptime, max_minptime);
1705 AddAttributeLine(kCodecParamPTime, ptime, message);
1706 }
1707 } else if (media_type == cricket::MEDIA_TYPE_DATA) {
1708 const DataContentDescription* data_desc =
1709 static_cast<const DataContentDescription*>(media_desc);
1710 for (std::vector<cricket::DataCodec>::const_iterator it =
1711 data_desc->codecs().begin();
1712 it != data_desc->codecs().end(); ++it) {
1713 // RFC 4566
1714 // a=rtpmap:<payload type> <encoding name>/<clock rate>
1715 // [/<encodingparameters>]
1716 InitAttrLine(kAttributeRtpmap, &os);
1717 os << kSdpDelimiterColon << it->id << " "
1718 << it->name << "/" << it->clockrate;
1719 AddLine(os.str(), message);
1720 }
1721 }
1722}
1723
1724void BuildCandidate(const std::vector<Candidate>& candidates,
honghaiza54a0802015-12-16 18:37:23 -08001725 bool include_ufrag,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001726 std::string* message) {
1727 std::ostringstream os;
1728
1729 for (std::vector<Candidate>::const_iterator it = candidates.begin();
1730 it != candidates.end(); ++it) {
1731 // RFC 5245
1732 // a=candidate:<foundation> <component-id> <transport> <priority>
1733 // <connection-address> <port> typ <candidate-types>
1734 // [raddr <connection-address>] [rport <port>]
1735 // *(SP extension-att-name SP extension-att-value)
1736 std::string type;
1737 // Map the cricket candidate type to "host" / "srflx" / "prflx" / "relay"
1738 if (it->type() == cricket::LOCAL_PORT_TYPE) {
1739 type = kCandidateHost;
1740 } else if (it->type() == cricket::STUN_PORT_TYPE) {
1741 type = kCandidateSrflx;
1742 } else if (it->type() == cricket::RELAY_PORT_TYPE) {
1743 type = kCandidateRelay;
1744 } else {
1745 ASSERT(false);
Peter Thatcher019087f2015-04-28 09:06:26 -07001746 // Never write out candidates if we don't know the type.
1747 continue;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001748 }
1749
1750 InitAttrLine(kAttributeCandidate, &os);
1751 os << kSdpDelimiterColon
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001752 << it->foundation() << " "
1753 << it->component() << " "
1754 << it->protocol() << " "
1755 << it->priority() << " "
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001756 << it->address().ipaddr().ToString() << " "
1757 << it->address().PortAsString() << " "
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001758 << kAttributeCandidateTyp << " "
1759 << type << " ";
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001760
1761 // Related address
1762 if (!it->related_address().IsNil()) {
1763 os << kAttributeCandidateRaddr << " "
1764 << it->related_address().ipaddr().ToString() << " "
1765 << kAttributeCandidateRport << " "
1766 << it->related_address().PortAsString() << " ";
1767 }
1768
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001769 if (it->protocol() == cricket::TCP_PROTOCOL_NAME) {
mallinath@webrtc.orge999bd02014-08-13 06:05:55 +00001770 os << kTcpCandidateType << " " << it->tcptype() << " ";
mallinath@webrtc.org2d60c5e2014-08-08 22:29:20 +00001771 }
1772
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001773 // Extensions
1774 os << kAttributeCandidateGeneration << " " << it->generation();
honghaiza54a0802015-12-16 18:37:23 -08001775 if (include_ufrag && !it->username().empty()) {
1776 os << " " << kAttributeCandidateUfrag << " " << it->username();
1777 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001778
1779 AddLine(os.str(), message);
1780 }
1781}
1782
1783void BuildIceOptions(const std::vector<std::string>& transport_options,
1784 std::string* message) {
1785 if (!transport_options.empty()) {
1786 std::ostringstream os;
1787 InitAttrLine(kAttributeIceOption, &os);
1788 os << kSdpDelimiterColon << transport_options[0];
1789 for (size_t i = 1; i < transport_options.size(); ++i) {
1790 os << kSdpDelimiterSpace << transport_options[i];
1791 }
1792 AddLine(os.str(), message);
1793 }
1794}
1795
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001796bool IsRtp(const std::string& protocol) {
1797 return protocol.empty() ||
1798 (protocol.find(cricket::kMediaProtocolRtpPrefix) != std::string::npos);
1799}
1800
1801bool IsDtlsSctp(const std::string& protocol) {
1802 // This intentionally excludes "SCTP" and "SCTP/DTLS".
lally@webrtc.orga7470932015-02-24 20:19:21 +00001803 return protocol.find(cricket::kMediaProtocolDtlsSctp) != std::string::npos;
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00001804}
1805
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001806bool ParseSessionDescription(const std::string& message, size_t* pos,
1807 std::string* session_id,
1808 std::string* session_version,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001809 TransportDescription* session_td,
1810 RtpHeaderExtensions* session_extmaps,
1811 cricket::SessionDescription* desc,
1812 SdpParseError* error) {
1813 std::string line;
1814
deadbeefc80741f2015-10-22 13:14:45 -07001815 desc->set_msid_supported(false);
1816
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001817 // RFC 4566
1818 // v= (protocol version)
1819 if (!GetLineWithType(message, pos, &line, kLineTypeVersion)) {
1820 return ParseFailedExpectLine(message, *pos, kLineTypeVersion,
1821 std::string(), error);
1822 }
1823 // RFC 4566
1824 // o=<username> <sess-id> <sess-version> <nettype> <addrtype>
1825 // <unicast-address>
1826 if (!GetLineWithType(message, pos, &line, kLineTypeOrigin)) {
1827 return ParseFailedExpectLine(message, *pos, kLineTypeOrigin,
1828 std::string(), error);
1829 }
1830 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001831 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001832 kSdpDelimiterSpace, &fields);
1833 const size_t expected_fields = 6;
1834 if (fields.size() != expected_fields) {
1835 return ParseFailedExpectFieldNum(line, expected_fields, error);
1836 }
1837 *session_id = fields[1];
1838 *session_version = fields[2];
1839
1840 // RFC 4566
1841 // s= (session name)
1842 if (!GetLineWithType(message, pos, &line, kLineTypeSessionName)) {
1843 return ParseFailedExpectLine(message, *pos, kLineTypeSessionName,
1844 std::string(), error);
1845 }
1846
1847 // Optional lines
1848 // Those are the optional lines, so shouldn't return false if not present.
1849 // RFC 4566
1850 // i=* (session information)
1851 GetLineWithType(message, pos, &line, kLineTypeSessionInfo);
1852
1853 // RFC 4566
1854 // u=* (URI of description)
1855 GetLineWithType(message, pos, &line, kLineTypeSessionUri);
1856
1857 // RFC 4566
1858 // e=* (email address)
1859 GetLineWithType(message, pos, &line, kLineTypeSessionEmail);
1860
1861 // RFC 4566
1862 // p=* (phone number)
1863 GetLineWithType(message, pos, &line, kLineTypeSessionPhone);
1864
1865 // RFC 4566
1866 // c=* (connection information -- not required if included in
1867 // all media)
1868 GetLineWithType(message, pos, &line, kLineTypeConnection);
1869
1870 // RFC 4566
1871 // b=* (zero or more bandwidth information lines)
1872 while (GetLineWithType(message, pos, &line, kLineTypeSessionBandwidth)) {
1873 // By pass zero or more b lines.
1874 }
1875
1876 // RFC 4566
1877 // One or more time descriptions ("t=" and "r=" lines; see below)
1878 // t= (time the session is active)
1879 // r=* (zero or more repeat times)
1880 // Ensure there's at least one time description
1881 if (!GetLineWithType(message, pos, &line, kLineTypeTiming)) {
1882 return ParseFailedExpectLine(message, *pos, kLineTypeTiming, std::string(),
1883 error);
1884 }
1885
1886 while (GetLineWithType(message, pos, &line, kLineTypeRepeatTimes)) {
1887 // By pass zero or more r lines.
1888 }
1889
1890 // Go through the rest of the time descriptions
1891 while (GetLineWithType(message, pos, &line, kLineTypeTiming)) {
1892 while (GetLineWithType(message, pos, &line, kLineTypeRepeatTimes)) {
1893 // By pass zero or more r lines.
1894 }
1895 }
1896
1897 // RFC 4566
1898 // z=* (time zone adjustments)
1899 GetLineWithType(message, pos, &line, kLineTypeTimeZone);
1900
1901 // RFC 4566
1902 // k=* (encryption key)
1903 GetLineWithType(message, pos, &line, kLineTypeEncryptionKey);
1904
1905 // RFC 4566
1906 // a=* (zero or more session attribute lines)
1907 while (GetLineWithType(message, pos, &line, kLineTypeAttributes)) {
1908 if (HasAttribute(line, kAttributeGroup)) {
1909 if (!ParseGroupAttribute(line, desc, error)) {
1910 return false;
1911 }
1912 } else if (HasAttribute(line, kAttributeIceUfrag)) {
1913 if (!GetValue(line, kAttributeIceUfrag,
1914 &(session_td->ice_ufrag), error)) {
1915 return false;
1916 }
1917 } else if (HasAttribute(line, kAttributeIcePwd)) {
1918 if (!GetValue(line, kAttributeIcePwd, &(session_td->ice_pwd), error)) {
1919 return false;
1920 }
1921 } else if (HasAttribute(line, kAttributeIceLite)) {
1922 session_td->ice_mode = cricket::ICEMODE_LITE;
1923 } else if (HasAttribute(line, kAttributeIceOption)) {
1924 if (!ParseIceOptions(line, &(session_td->transport_options), error)) {
1925 return false;
1926 }
1927 } else if (HasAttribute(line, kAttributeFingerprint)) {
1928 if (session_td->identity_fingerprint.get()) {
1929 return ParseFailed(
1930 line,
1931 "Can't have multiple fingerprint attributes at the same level.",
1932 error);
1933 }
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001934 rtc::SSLFingerprint* fingerprint = NULL;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001935 if (!ParseFingerprintAttribute(line, &fingerprint, error)) {
1936 return false;
1937 }
1938 session_td->identity_fingerprint.reset(fingerprint);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00001939 } else if (HasAttribute(line, kAttributeSetup)) {
1940 if (!ParseDtlsSetup(line, &(session_td->connection_role), error)) {
1941 return false;
1942 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001943 } else if (HasAttribute(line, kAttributeMsidSemantics)) {
1944 std::string semantics;
1945 if (!GetValue(line, kAttributeMsidSemantics, &semantics, error)) {
1946 return false;
1947 }
deadbeefc80741f2015-10-22 13:14:45 -07001948 desc->set_msid_supported(
1949 CaseInsensitiveFind(semantics, kMediaStreamSemantic));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001950 } else if (HasAttribute(line, kAttributeExtmap)) {
1951 RtpHeaderExtension extmap;
1952 if (!ParseExtmap(line, &extmap, error)) {
1953 return false;
1954 }
1955 session_extmaps->push_back(extmap);
1956 }
1957 }
1958
1959 return true;
1960}
1961
1962bool ParseGroupAttribute(const std::string& line,
1963 cricket::SessionDescription* desc,
1964 SdpParseError* error) {
1965 ASSERT(desc != NULL);
1966
1967 // RFC 5888 and draft-holmberg-mmusic-sdp-bundle-negotiation-00
1968 // a=group:BUNDLE video voice
1969 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001970 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001971 kSdpDelimiterSpace, &fields);
1972 std::string semantics;
1973 if (!GetValue(fields[0], kAttributeGroup, &semantics, error)) {
1974 return false;
1975 }
1976 cricket::ContentGroup group(semantics);
1977 for (size_t i = 1; i < fields.size(); ++i) {
1978 group.AddContentName(fields[i]);
1979 }
1980 desc->AddGroup(group);
1981 return true;
1982}
1983
1984static bool ParseFingerprintAttribute(const std::string& line,
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001985 rtc::SSLFingerprint** fingerprint,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001986 SdpParseError* error) {
1987 if (!IsLineType(line, kLineTypeAttributes) ||
1988 !HasAttribute(line, kAttributeFingerprint)) {
1989 return ParseFailedExpectLine(line, 0, kLineTypeAttributes,
1990 kAttributeFingerprint, error);
1991 }
1992
1993 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00001994 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001995 kSdpDelimiterSpace, &fields);
1996 const size_t expected_fields = 2;
1997 if (fields.size() != expected_fields) {
1998 return ParseFailedExpectFieldNum(line, expected_fields, error);
1999 }
2000
2001 // The first field here is "fingerprint:<hash>.
2002 std::string algorithm;
2003 if (!GetValue(fields[0], kAttributeFingerprint, &algorithm, error)) {
2004 return false;
2005 }
2006
2007 // Downcase the algorithm. Note that we don't need to downcase the
2008 // fingerprint because hex_decode can handle upper-case.
2009 std::transform(algorithm.begin(), algorithm.end(), algorithm.begin(),
2010 ::tolower);
2011
2012 // The second field is the digest value. De-hexify it.
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002013 *fingerprint = rtc::SSLFingerprint::CreateFromRfc4572(
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002014 algorithm, fields[1]);
2015 if (!*fingerprint) {
2016 return ParseFailed(line,
2017 "Failed to create fingerprint from the digest.",
2018 error);
2019 }
2020
2021 return true;
2022}
2023
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00002024static bool ParseDtlsSetup(const std::string& line,
2025 cricket::ConnectionRole* role,
2026 SdpParseError* error) {
2027 // setup-attr = "a=setup:" role
2028 // role = "active" / "passive" / "actpass" / "holdconn"
2029 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002030 rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterColon, &fields);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00002031 const size_t expected_fields = 2;
2032 if (fields.size() != expected_fields) {
2033 return ParseFailedExpectFieldNum(line, expected_fields, error);
2034 }
2035 std::string role_str = fields[1];
2036 if (!cricket::StringToConnectionRole(role_str, role)) {
2037 return ParseFailed(line, "Invalid attribute value.", error);
2038 }
2039 return true;
2040}
2041
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002042// RFC 3551
2043// PT encoding media type clock rate channels
2044// name (Hz)
2045// 0 PCMU A 8,000 1
2046// 1 reserved A
2047// 2 reserved A
2048// 3 GSM A 8,000 1
2049// 4 G723 A 8,000 1
2050// 5 DVI4 A 8,000 1
2051// 6 DVI4 A 16,000 1
2052// 7 LPC A 8,000 1
2053// 8 PCMA A 8,000 1
2054// 9 G722 A 8,000 1
2055// 10 L16 A 44,100 2
2056// 11 L16 A 44,100 1
2057// 12 QCELP A 8,000 1
2058// 13 CN A 8,000 1
2059// 14 MPA A 90,000 (see text)
2060// 15 G728 A 8,000 1
2061// 16 DVI4 A 11,025 1
2062// 17 DVI4 A 22,050 1
2063// 18 G729 A 8,000 1
2064struct StaticPayloadAudioCodec {
2065 const char* name;
2066 int clockrate;
2067 int channels;
2068};
2069static const StaticPayloadAudioCodec kStaticPayloadAudioCodecs[] = {
2070 { "PCMU", 8000, 1 },
2071 { "reserved", 0, 0 },
2072 { "reserved", 0, 0 },
2073 { "GSM", 8000, 1 },
2074 { "G723", 8000, 1 },
2075 { "DVI4", 8000, 1 },
2076 { "DVI4", 16000, 1 },
2077 { "LPC", 8000, 1 },
2078 { "PCMA", 8000, 1 },
2079 { "G722", 8000, 1 },
2080 { "L16", 44100, 2 },
2081 { "L16", 44100, 1 },
2082 { "QCELP", 8000, 1 },
2083 { "CN", 8000, 1 },
2084 { "MPA", 90000, 1 },
2085 { "G728", 8000, 1 },
2086 { "DVI4", 11025, 1 },
2087 { "DVI4", 22050, 1 },
2088 { "G729", 8000, 1 },
2089};
2090
2091void MaybeCreateStaticPayloadAudioCodecs(
2092 const std::vector<int>& fmts, AudioContentDescription* media_desc) {
2093 if (!media_desc) {
2094 return;
2095 }
henrike@webrtc.org28654cb2013-07-22 21:07:49 +00002096 int preference = static_cast<int>(fmts.size());
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002097 std::vector<int>::const_iterator it = fmts.begin();
2098 bool add_new_codec = false;
2099 for (; it != fmts.end(); ++it) {
2100 int payload_type = *it;
2101 if (!media_desc->HasCodec(payload_type) &&
2102 payload_type >= 0 &&
tfarina5237aaf2015-11-10 23:44:30 -08002103 payload_type < arraysize(kStaticPayloadAudioCodecs)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002104 std::string encoding_name = kStaticPayloadAudioCodecs[payload_type].name;
2105 int clock_rate = kStaticPayloadAudioCodecs[payload_type].clockrate;
2106 int channels = kStaticPayloadAudioCodecs[payload_type].channels;
2107 media_desc->AddCodec(cricket::AudioCodec(payload_type, encoding_name,
2108 clock_rate, 0, channels,
2109 preference));
2110 add_new_codec = true;
2111 }
2112 --preference;
2113 }
2114 if (add_new_codec) {
2115 media_desc->SortCodecs();
2116 }
2117}
2118
2119template <class C>
2120static C* ParseContentDescription(const std::string& message,
2121 const MediaType media_type,
2122 int mline_index,
2123 const std::string& protocol,
2124 const std::vector<int>& codec_preference,
2125 size_t* pos,
2126 std::string* content_name,
2127 TransportDescription* transport,
2128 std::vector<JsepIceCandidate*>* candidates,
2129 webrtc::SdpParseError* error) {
2130 C* media_desc = new C();
2131 switch (media_type) {
2132 case cricket::MEDIA_TYPE_AUDIO:
2133 *content_name = cricket::CN_AUDIO;
2134 break;
2135 case cricket::MEDIA_TYPE_VIDEO:
2136 *content_name = cricket::CN_VIDEO;
2137 break;
2138 case cricket::MEDIA_TYPE_DATA:
2139 *content_name = cricket::CN_DATA;
2140 break;
2141 default:
2142 ASSERT(false);
2143 break;
2144 }
2145 if (!ParseContent(message, media_type, mline_index, protocol,
2146 codec_preference, pos, content_name,
2147 media_desc, transport, candidates, error)) {
2148 delete media_desc;
2149 return NULL;
2150 }
2151 // Sort the codecs according to the m-line fmt list.
2152 media_desc->SortCodecs();
2153 return media_desc;
2154}
2155
2156bool ParseMediaDescription(const std::string& message,
2157 const TransportDescription& session_td,
2158 const RtpHeaderExtensions& session_extmaps,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002159 size_t* pos,
2160 cricket::SessionDescription* desc,
2161 std::vector<JsepIceCandidate*>* candidates,
2162 SdpParseError* error) {
2163 ASSERT(desc != NULL);
2164 std::string line;
2165 int mline_index = -1;
2166
2167 // Zero or more media descriptions
2168 // RFC 4566
2169 // m=<media> <port> <proto> <fmt>
2170 while (GetLineWithType(message, pos, &line, kLineTypeMedia)) {
2171 ++mline_index;
2172
2173 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002174 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002175 kSdpDelimiterSpace, &fields);
2176 const size_t expected_min_fields = 4;
2177 if (fields.size() < expected_min_fields) {
2178 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
2179 }
2180 bool rejected = false;
2181 // RFC 3264
2182 // To reject an offered stream, the port number in the corresponding stream
2183 // in the answer MUST be set to zero.
2184 if (fields[1] == kMediaPortRejected) {
2185 rejected = true;
2186 }
2187
2188 std::string protocol = fields[2];
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002189
2190 // <fmt>
2191 std::vector<int> codec_preference;
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002192 if (IsRtp(protocol)) {
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002193 for (size_t j = 3 ; j < fields.size(); ++j) {
2194 // TODO(wu): Remove when below bug is fixed.
2195 // https://bugzilla.mozilla.org/show_bug.cgi?id=996329
pbosbb36fdf2015-07-09 07:48:14 -07002196 if (fields[j].empty() && j == fields.size() - 1) {
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002197 continue;
2198 }
wu@webrtc.org36eda7c2014-04-15 20:37:30 +00002199
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002200 int pl = 0;
pkasting@chromium.orge9facf82015-02-17 20:36:28 +00002201 if (!GetPayloadTypeFromString(line, fields[j], &pl, error)) {
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002202 return false;
2203 }
2204 codec_preference.push_back(pl);
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002205 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002206 }
2207
2208 // Make a temporary TransportDescription based on |session_td|.
2209 // Some of this gets overwritten by ParseContent.
Peter Thatcher7cbd1882015-09-17 18:54:52 -07002210 TransportDescription transport(session_td.transport_options,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002211 session_td.ice_ufrag,
2212 session_td.ice_pwd,
2213 session_td.ice_mode,
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00002214 session_td.connection_role,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002215 session_td.identity_fingerprint.get(),
2216 Candidates());
2217
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002218 rtc::scoped_ptr<MediaContentDescription> content;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002219 std::string content_name;
2220 if (HasAttribute(line, kMediaTypeVideo)) {
2221 content.reset(ParseContentDescription<VideoContentDescription>(
2222 message, cricket::MEDIA_TYPE_VIDEO, mline_index, protocol,
2223 codec_preference, pos, &content_name,
2224 &transport, candidates, error));
2225 } else if (HasAttribute(line, kMediaTypeAudio)) {
2226 content.reset(ParseContentDescription<AudioContentDescription>(
2227 message, cricket::MEDIA_TYPE_AUDIO, mline_index, protocol,
2228 codec_preference, pos, &content_name,
2229 &transport, candidates, error));
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002230 } else if (HasAttribute(line, kMediaTypeData)) {
jiayl@webrtc.org0e527722014-09-08 21:43:43 +00002231 DataContentDescription* data_desc =
wu@webrtc.org78187522013-10-07 23:32:02 +00002232 ParseContentDescription<DataContentDescription>(
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002233 message, cricket::MEDIA_TYPE_DATA, mline_index, protocol,
2234 codec_preference, pos, &content_name,
wu@webrtc.org78187522013-10-07 23:32:02 +00002235 &transport, candidates, error);
jiayl@webrtc.org0e527722014-09-08 21:43:43 +00002236 content.reset(data_desc);
wu@webrtc.org78187522013-10-07 23:32:02 +00002237
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002238 int p;
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002239 if (data_desc && IsDtlsSctp(protocol) && rtc::FromString(fields[3], &p)) {
jiayl@webrtc.org0e527722014-09-08 21:43:43 +00002240 if (!AddSctpDataCodec(data_desc, p))
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002241 return false;
wu@webrtc.org78187522013-10-07 23:32:02 +00002242 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002243 } else {
2244 LOG(LS_WARNING) << "Unsupported media type: " << line;
2245 continue;
2246 }
2247 if (!content.get()) {
2248 // ParseContentDescription returns NULL if failed.
2249 return false;
2250 }
2251
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002252 if (IsRtp(protocol)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002253 // Set the extmap.
2254 if (!session_extmaps.empty() &&
2255 !content->rtp_header_extensions().empty()) {
2256 return ParseFailed("",
2257 "The a=extmap MUST be either all session level or "
2258 "all media level.",
2259 error);
2260 }
2261 for (size_t i = 0; i < session_extmaps.size(); ++i) {
2262 content->AddRtpHeaderExtension(session_extmaps[i]);
2263 }
2264 }
2265 content->set_protocol(protocol);
2266 desc->AddContent(content_name,
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002267 IsDtlsSctp(protocol) ? cricket::NS_JINGLE_DRAFT_SCTP :
2268 cricket::NS_JINGLE_RTP,
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002269 rejected,
2270 content.release());
2271 // Create TransportInfo with the media level "ice-pwd" and "ice-ufrag".
2272 TransportInfo transport_info(content_name, transport);
2273
2274 if (!desc->AddTransportInfo(transport_info)) {
2275 std::ostringstream description;
2276 description << "Failed to AddTransportInfo with content name: "
2277 << content_name;
2278 return ParseFailed("", description.str(), error);
2279 }
2280 }
wu@webrtc.orgcecfd182013-10-30 05:18:12 +00002281
2282 size_t end_of_message = message.size();
2283 if (mline_index == -1 && *pos != end_of_message) {
2284 ParseFailed(message, *pos, "Expects m line.", error);
2285 return false;
2286 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002287 return true;
2288}
2289
2290bool VerifyCodec(const cricket::Codec& codec) {
2291 // Codec has not been populated correctly unless the name has been set. This
2292 // can happen if an SDP has an fmtp or rtcp-fb with a payload type but doesn't
2293 // have a corresponding "rtpmap" line.
2294 cricket::Codec default_codec;
2295 return default_codec.name != codec.name;
2296}
2297
2298bool VerifyAudioCodecs(const AudioContentDescription* audio_desc) {
2299 const std::vector<cricket::AudioCodec>& codecs = audio_desc->codecs();
2300 for (std::vector<cricket::AudioCodec>::const_iterator iter = codecs.begin();
2301 iter != codecs.end(); ++iter) {
2302 if (!VerifyCodec(*iter)) {
2303 return false;
2304 }
2305 }
2306 return true;
2307}
2308
2309bool VerifyVideoCodecs(const VideoContentDescription* video_desc) {
2310 const std::vector<cricket::VideoCodec>& codecs = video_desc->codecs();
2311 for (std::vector<cricket::VideoCodec>::const_iterator iter = codecs.begin();
2312 iter != codecs.end(); ++iter) {
2313 if (!VerifyCodec(*iter)) {
2314 return false;
2315 }
2316 }
2317 return true;
2318}
2319
2320void AddParameters(const cricket::CodecParameterMap& parameters,
2321 cricket::Codec* codec) {
2322 for (cricket::CodecParameterMap::const_iterator iter =
2323 parameters.begin(); iter != parameters.end(); ++iter) {
2324 codec->SetParam(iter->first, iter->second);
2325 }
2326}
2327
2328void AddFeedbackParameter(const cricket::FeedbackParam& feedback_param,
2329 cricket::Codec* codec) {
2330 codec->AddFeedbackParam(feedback_param);
2331}
2332
2333void AddFeedbackParameters(const cricket::FeedbackParams& feedback_params,
2334 cricket::Codec* codec) {
2335 for (std::vector<cricket::FeedbackParam>::const_iterator iter =
2336 feedback_params.params().begin();
2337 iter != feedback_params.params().end(); ++iter) {
2338 codec->AddFeedbackParam(*iter);
2339 }
2340}
2341
2342// Gets the current codec setting associated with |payload_type|. If there
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002343// is no Codec associated with that payload type it returns an empty codec
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002344// with that payload type.
2345template <class T>
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002346T GetCodecWithPayloadType(const std::vector<T>& codecs, int payload_type) {
2347 T ret_val;
2348 if (!FindCodecById(codecs, payload_type, &ret_val)) {
2349 ret_val.id = payload_type;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002350 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002351 return ret_val;
2352}
2353
2354// Updates or creates a new codec entry in the audio description.
2355template <class T, class U>
2356void AddOrReplaceCodec(MediaContentDescription* content_desc, const U& codec) {
2357 T* desc = static_cast<T*>(content_desc);
2358 std::vector<U> codecs = desc->codecs();
2359 bool found = false;
2360
2361 typename std::vector<U>::iterator iter;
2362 for (iter = codecs.begin(); iter != codecs.end(); ++iter) {
2363 if (iter->id == codec.id) {
2364 *iter = codec;
2365 found = true;
2366 break;
2367 }
2368 }
2369 if (!found) {
2370 desc->AddCodec(codec);
2371 return;
2372 }
2373 desc->set_codecs(codecs);
2374}
2375
2376// Adds or updates existing codec corresponding to |payload_type| according
2377// to |parameters|.
2378template <class T, class U>
2379void UpdateCodec(MediaContentDescription* content_desc, int payload_type,
2380 const cricket::CodecParameterMap& parameters) {
2381 // Codec might already have been populated (from rtpmap).
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002382 U new_codec = GetCodecWithPayloadType(static_cast<T*>(content_desc)->codecs(),
2383 payload_type);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002384 AddParameters(parameters, &new_codec);
2385 AddOrReplaceCodec<T, U>(content_desc, new_codec);
2386}
2387
2388// Adds or updates existing codec corresponding to |payload_type| according
2389// to |feedback_param|.
2390template <class T, class U>
2391void UpdateCodec(MediaContentDescription* content_desc, int payload_type,
2392 const cricket::FeedbackParam& feedback_param) {
2393 // Codec might already have been populated (from rtpmap).
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002394 U new_codec = GetCodecWithPayloadType(static_cast<T*>(content_desc)->codecs(),
2395 payload_type);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002396 AddFeedbackParameter(feedback_param, &new_codec);
2397 AddOrReplaceCodec<T, U>(content_desc, new_codec);
2398}
2399
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002400template <class T>
2401bool PopWildcardCodec(std::vector<T>* codecs, T* wildcard_codec) {
2402 for (auto iter = codecs->begin(); iter != codecs->end(); ++iter) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002403 if (iter->id == kWildcardPayloadType) {
2404 *wildcard_codec = *iter;
2405 codecs->erase(iter);
2406 return true;
2407 }
2408 }
2409 return false;
2410}
2411
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002412template<class T>
2413void UpdateFromWildcardCodecs(cricket::MediaContentDescriptionImpl<T>* desc) {
2414 auto codecs = desc->codecs();
2415 T wildcard_codec;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002416 if (!PopWildcardCodec(&codecs, &wildcard_codec)) {
2417 return;
2418 }
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002419 for (auto& codec : codecs) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002420 AddFeedbackParameters(wildcard_codec.feedback_params, &codec);
2421 }
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002422 desc->set_codecs(codecs);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002423}
2424
2425void AddAudioAttribute(const std::string& name, const std::string& value,
2426 AudioContentDescription* audio_desc) {
2427 if (value.empty()) {
2428 return;
2429 }
2430 std::vector<cricket::AudioCodec> codecs = audio_desc->codecs();
2431 for (std::vector<cricket::AudioCodec>::iterator iter = codecs.begin();
2432 iter != codecs.end(); ++iter) {
2433 iter->params[name] = value;
2434 }
2435 audio_desc->set_codecs(codecs);
2436}
2437
2438bool ParseContent(const std::string& message,
2439 const MediaType media_type,
2440 int mline_index,
2441 const std::string& protocol,
2442 const std::vector<int>& codec_preference,
2443 size_t* pos,
2444 std::string* content_name,
2445 MediaContentDescription* media_desc,
2446 TransportDescription* transport,
2447 std::vector<JsepIceCandidate*>* candidates,
2448 SdpParseError* error) {
2449 ASSERT(media_desc != NULL);
2450 ASSERT(content_name != NULL);
2451 ASSERT(transport != NULL);
2452
henrike@webrtc.org704bf9e2014-02-27 17:52:04 +00002453 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
2454 MaybeCreateStaticPayloadAudioCodecs(
2455 codec_preference, static_cast<AudioContentDescription*>(media_desc));
2456 }
2457
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002458 // The media level "ice-ufrag" and "ice-pwd".
2459 // The candidates before update the media level "ice-pwd" and "ice-ufrag".
2460 Candidates candidates_orig;
2461 std::string line;
2462 std::string mline_id;
2463 // Tracks created out of the ssrc attributes.
2464 StreamParamsVec tracks;
2465 SsrcInfoVec ssrc_infos;
2466 SsrcGroupVec ssrc_groups;
2467 std::string maxptime_as_string;
2468 std::string ptime_as_string;
2469
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002470 // Loop until the next m line
2471 while (!IsLineType(message, kLineTypeMedia, *pos)) {
2472 if (!GetLine(message, pos, &line)) {
2473 if (*pos >= message.size()) {
2474 break; // Done parsing
2475 } else {
sergeyu@chromium.org5bc25c42013-12-05 00:24:06 +00002476 return ParseFailed(message, *pos, "Invalid SDP line.", error);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002477 }
2478 }
2479
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002480 // RFC 4566
2481 // b=* (zero or more bandwidth information lines)
2482 if (IsLineType(line, kLineTypeSessionBandwidth)) {
2483 std::string bandwidth;
2484 if (HasAttribute(line, kApplicationSpecificMaximum)) {
2485 if (!GetValue(line, kApplicationSpecificMaximum, &bandwidth, error)) {
2486 return false;
2487 } else {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002488 int b = 0;
2489 if (!GetValueFromString(line, bandwidth, &b, error)) {
2490 return false;
2491 }
Peter Thatcherc0c3a862015-06-24 15:31:25 -07002492 // We should never use more than the default bandwidth for RTP-based
2493 // data channels. Don't allow SDP to set the bandwidth, because
2494 // that would give JS the opportunity to "break the Internet".
2495 // See: https://code.google.com/p/chromium/issues/detail?id=280726
2496 if (media_type == cricket::MEDIA_TYPE_DATA && IsRtp(protocol) &&
2497 b > cricket::kDataMaxBandwidth / 1000) {
2498 std::ostringstream description;
2499 description << "RTP-based data channels may not send more than "
2500 << cricket::kDataMaxBandwidth / 1000 << "kbps.";
2501 return ParseFailed(line, description.str(), error);
2502 }
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002503 media_desc->set_bandwidth(b * 1000);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002504 }
2505 }
2506 continue;
2507 }
2508
2509 if (!IsLineType(line, kLineTypeAttributes)) {
2510 // TODO: Handle other lines if needed.
2511 LOG(LS_INFO) << "Ignored line: " << line;
2512 continue;
2513 }
2514
2515 // Handle attributes common to SCTP and RTP.
2516 if (HasAttribute(line, kAttributeMid)) {
2517 // RFC 3388
2518 // mid-attribute = "a=mid:" identification-tag
2519 // identification-tag = token
2520 // Use the mid identification-tag as the content name.
2521 if (!GetValue(line, kAttributeMid, &mline_id, error)) {
2522 return false;
2523 }
2524 *content_name = mline_id;
2525 } else if (HasAttribute(line, kAttributeCandidate)) {
2526 Candidate candidate;
2527 if (!ParseCandidate(line, &candidate, error, false)) {
2528 return false;
2529 }
2530 candidates_orig.push_back(candidate);
2531 } else if (HasAttribute(line, kAttributeIceUfrag)) {
2532 if (!GetValue(line, kAttributeIceUfrag, &transport->ice_ufrag, error)) {
2533 return false;
2534 }
2535 } else if (HasAttribute(line, kAttributeIcePwd)) {
2536 if (!GetValue(line, kAttributeIcePwd, &transport->ice_pwd, error)) {
2537 return false;
2538 }
2539 } else if (HasAttribute(line, kAttributeIceOption)) {
2540 if (!ParseIceOptions(line, &transport->transport_options, error)) {
2541 return false;
2542 }
2543 } else if (HasAttribute(line, kAttributeFmtp)) {
2544 if (!ParseFmtpAttributes(line, media_type, media_desc, error)) {
2545 return false;
2546 }
2547 } else if (HasAttribute(line, kAttributeFingerprint)) {
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002548 rtc::SSLFingerprint* fingerprint = NULL;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002549
2550 if (!ParseFingerprintAttribute(line, &fingerprint, error)) {
2551 return false;
2552 }
2553 transport->identity_fingerprint.reset(fingerprint);
sergeyu@chromium.org0be6aa02013-08-23 23:21:25 +00002554 } else if (HasAttribute(line, kAttributeSetup)) {
2555 if (!ParseDtlsSetup(line, &(transport->connection_role), error)) {
2556 return false;
2557 }
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002558 } else if (IsDtlsSctp(protocol) && HasAttribute(line, kAttributeSctpPort)) {
jiayl@webrtc.orgddb85ab2014-09-05 16:31:56 +00002559 int sctp_port;
2560 if (!ParseSctpPort(line, &sctp_port, error)) {
2561 return false;
2562 }
2563 if (!AddSctpDataCodec(static_cast<DataContentDescription*>(media_desc),
2564 sctp_port)) {
2565 return false;
2566 }
pthatcher@webrtc.org3341b402015-02-13 21:14:22 +00002567 } else if (IsRtp(protocol)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002568 //
2569 // RTP specific attrubtes
2570 //
2571 if (HasAttribute(line, kAttributeRtcpMux)) {
2572 media_desc->set_rtcp_mux(true);
deadbeef13871492015-12-09 12:37:51 -08002573 } else if (HasAttribute(line, kAttributeRtcpReducedSize)) {
2574 media_desc->set_rtcp_reduced_size(true);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002575 } else if (HasAttribute(line, kAttributeSsrcGroup)) {
2576 if (!ParseSsrcGroupAttribute(line, &ssrc_groups, error)) {
2577 return false;
2578 }
2579 } else if (HasAttribute(line, kAttributeSsrc)) {
2580 if (!ParseSsrcAttribute(line, &ssrc_infos, error)) {
2581 return false;
2582 }
2583 } else if (HasAttribute(line, kAttributeCrypto)) {
2584 if (!ParseCryptoAttribute(line, media_desc, error)) {
2585 return false;
2586 }
2587 } else if (HasAttribute(line, kAttributeRtpmap)) {
2588 if (!ParseRtpmapAttribute(line, media_type, codec_preference,
2589 media_desc, error)) {
2590 return false;
2591 }
2592 } else if (HasAttribute(line, kCodecParamMaxPTime)) {
2593 if (!GetValue(line, kCodecParamMaxPTime, &maxptime_as_string, error)) {
2594 return false;
2595 }
2596 } else if (HasAttribute(line, kAttributeRtcpFb)) {
2597 if (!ParseRtcpFbAttribute(line, media_type, media_desc, error)) {
2598 return false;
2599 }
2600 } else if (HasAttribute(line, kCodecParamPTime)) {
2601 if (!GetValue(line, kCodecParamPTime, &ptime_as_string, error)) {
2602 return false;
2603 }
2604 } else if (HasAttribute(line, kAttributeSendOnly)) {
2605 media_desc->set_direction(cricket::MD_SENDONLY);
2606 } else if (HasAttribute(line, kAttributeRecvOnly)) {
2607 media_desc->set_direction(cricket::MD_RECVONLY);
2608 } else if (HasAttribute(line, kAttributeInactive)) {
2609 media_desc->set_direction(cricket::MD_INACTIVE);
2610 } else if (HasAttribute(line, kAttributeSendRecv)) {
2611 media_desc->set_direction(cricket::MD_SENDRECV);
2612 } else if (HasAttribute(line, kAttributeExtmap)) {
2613 RtpHeaderExtension extmap;
2614 if (!ParseExtmap(line, &extmap, error)) {
2615 return false;
2616 }
2617 media_desc->AddRtpHeaderExtension(extmap);
2618 } else if (HasAttribute(line, kAttributeXGoogleFlag)) {
2619 // Experimental attribute. Conference mode activates more aggressive
2620 // AEC and NS settings.
2621 // TODO: expose API to set these directly.
2622 std::string flag_value;
2623 if (!GetValue(line, kAttributeXGoogleFlag, &flag_value, error)) {
2624 return false;
2625 }
2626 if (flag_value.compare(kValueConference) == 0)
2627 media_desc->set_conference_mode(true);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002628 }
2629 } else {
2630 // Only parse lines that we are interested of.
2631 LOG(LS_INFO) << "Ignored line: " << line;
2632 continue;
2633 }
2634 }
2635
2636 // Create tracks from the |ssrc_infos|.
2637 CreateTracksFromSsrcInfos(ssrc_infos, &tracks);
2638
2639 // Add the ssrc group to the track.
2640 for (SsrcGroupVec::iterator ssrc_group = ssrc_groups.begin();
2641 ssrc_group != ssrc_groups.end(); ++ssrc_group) {
2642 if (ssrc_group->ssrcs.empty()) {
2643 continue;
2644 }
Peter Boström0c4e06b2015-10-07 12:23:21 +02002645 uint32_t ssrc = ssrc_group->ssrcs.front();
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002646 for (StreamParamsVec::iterator track = tracks.begin();
2647 track != tracks.end(); ++track) {
2648 if (track->has_ssrc(ssrc)) {
2649 track->ssrc_groups.push_back(*ssrc_group);
2650 }
2651 }
2652 }
2653
2654 // Add the new tracks to the |media_desc|.
2655 for (StreamParamsVec::iterator track = tracks.begin();
2656 track != tracks.end(); ++track) {
2657 media_desc->AddStream(*track);
2658 }
2659
2660 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
2661 AudioContentDescription* audio_desc =
2662 static_cast<AudioContentDescription*>(media_desc);
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002663 UpdateFromWildcardCodecs(audio_desc);
2664
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002665 // Verify audio codec ensures that no audio codec has been populated with
2666 // only fmtp.
2667 if (!VerifyAudioCodecs(audio_desc)) {
2668 return ParseFailed("Failed to parse audio codecs correctly.", error);
2669 }
2670 AddAudioAttribute(kCodecParamMaxPTime, maxptime_as_string, audio_desc);
2671 AddAudioAttribute(kCodecParamPTime, ptime_as_string, audio_desc);
2672 }
2673
2674 if (media_type == cricket::MEDIA_TYPE_VIDEO) {
jlmiller@webrtc.orga744a282015-02-18 21:37:46 +00002675 VideoContentDescription* video_desc =
2676 static_cast<VideoContentDescription*>(media_desc);
2677 UpdateFromWildcardCodecs(video_desc);
2678 // Verify video codec ensures that no video codec has been populated with
2679 // only rtcp-fb.
2680 if (!VerifyVideoCodecs(video_desc)) {
2681 return ParseFailed("Failed to parse video codecs correctly.", error);
2682 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002683 }
2684
2685 // RFC 5245
2686 // Update the candidates with the media level "ice-pwd" and "ice-ufrag".
2687 for (Candidates::iterator it = candidates_orig.begin();
2688 it != candidates_orig.end(); ++it) {
honghaiza54a0802015-12-16 18:37:23 -08002689 ASSERT((*it).username().empty() ||
2690 (*it).username() == transport->ice_ufrag);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002691 (*it).set_username(transport->ice_ufrag);
2692 ASSERT((*it).password().empty());
2693 (*it).set_password(transport->ice_pwd);
2694 candidates->push_back(
2695 new JsepIceCandidate(mline_id, mline_index, *it));
2696 }
2697 return true;
2698}
2699
2700bool ParseSsrcAttribute(const std::string& line, SsrcInfoVec* ssrc_infos,
2701 SdpParseError* error) {
2702 ASSERT(ssrc_infos != NULL);
2703 // RFC 5576
2704 // a=ssrc:<ssrc-id> <attribute>
2705 // a=ssrc:<ssrc-id> <attribute>:<value>
2706 std::string field1, field2;
Donald Curtis144d0182015-05-15 13:14:24 -07002707 if (!rtc::tokenize_first(line.substr(kLinePrefixLength), kSdpDelimiterSpace,
2708 &field1, &field2)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002709 const size_t expected_fields = 2;
2710 return ParseFailedExpectFieldNum(line, expected_fields, error);
2711 }
2712
2713 // ssrc:<ssrc-id>
2714 std::string ssrc_id_s;
2715 if (!GetValue(field1, kAttributeSsrc, &ssrc_id_s, error)) {
2716 return false;
2717 }
Peter Boström0c4e06b2015-10-07 12:23:21 +02002718 uint32_t ssrc_id = 0;
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002719 if (!GetValueFromString(line, ssrc_id_s, &ssrc_id, error)) {
2720 return false;
2721 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002722
2723 std::string attribute;
2724 std::string value;
Donald Curtis144d0182015-05-15 13:14:24 -07002725 if (!rtc::tokenize_first(field2, kSdpDelimiterColon, &attribute, &value)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002726 std::ostringstream description;
2727 description << "Failed to get the ssrc attribute value from " << field2
2728 << ". Expected format <attribute>:<value>.";
2729 return ParseFailed(line, description.str(), error);
2730 }
2731
2732 // Check if there's already an item for this |ssrc_id|. Create a new one if
2733 // there isn't.
2734 SsrcInfoVec::iterator ssrc_info = ssrc_infos->begin();
2735 for (; ssrc_info != ssrc_infos->end(); ++ssrc_info) {
2736 if (ssrc_info->ssrc_id == ssrc_id) {
2737 break;
2738 }
2739 }
2740 if (ssrc_info == ssrc_infos->end()) {
2741 SsrcInfo info;
2742 info.ssrc_id = ssrc_id;
2743 ssrc_infos->push_back(info);
2744 ssrc_info = ssrc_infos->end() - 1;
2745 }
2746
2747 // Store the info to the |ssrc_info|.
2748 if (attribute == kSsrcAttributeCname) {
2749 // RFC 5576
2750 // cname:<value>
2751 ssrc_info->cname = value;
2752 } else if (attribute == kSsrcAttributeMsid) {
2753 // draft-alvestrand-mmusic-msid-00
2754 // "msid:" identifier [ " " appdata ]
2755 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002756 rtc::split(value, kSdpDelimiterSpace, &fields);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002757 if (fields.size() < 1 || fields.size() > 2) {
2758 return ParseFailed(line,
2759 "Expected format \"msid:<identifier>[ <appdata>]\".",
2760 error);
2761 }
2762 ssrc_info->msid_identifier = fields[0];
2763 if (fields.size() == 2) {
2764 ssrc_info->msid_appdata = fields[1];
2765 }
2766 } else if (attribute == kSsrcAttributeMslabel) {
2767 // draft-alvestrand-rtcweb-mid-01
2768 // mslabel:<value>
2769 ssrc_info->mslabel = value;
2770 } else if (attribute == kSSrcAttributeLabel) {
2771 // The label isn't defined.
2772 // label:<value>
2773 ssrc_info->label = value;
2774 }
2775 return true;
2776}
2777
2778bool ParseSsrcGroupAttribute(const std::string& line,
2779 SsrcGroupVec* ssrc_groups,
2780 SdpParseError* error) {
2781 ASSERT(ssrc_groups != NULL);
2782 // RFC 5576
2783 // a=ssrc-group:<semantics> <ssrc-id> ...
2784 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002785 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002786 kSdpDelimiterSpace, &fields);
2787 const size_t expected_min_fields = 2;
2788 if (fields.size() < expected_min_fields) {
2789 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
2790 }
2791 std::string semantics;
2792 if (!GetValue(fields[0], kAttributeSsrcGroup, &semantics, error)) {
2793 return false;
2794 }
Peter Boström0c4e06b2015-10-07 12:23:21 +02002795 std::vector<uint32_t> ssrcs;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002796 for (size_t i = 1; i < fields.size(); ++i) {
Peter Boström0c4e06b2015-10-07 12:23:21 +02002797 uint32_t ssrc = 0;
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002798 if (!GetValueFromString(line, fields[i], &ssrc, error)) {
2799 return false;
2800 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002801 ssrcs.push_back(ssrc);
2802 }
2803 ssrc_groups->push_back(SsrcGroup(semantics, ssrcs));
2804 return true;
2805}
2806
2807bool ParseCryptoAttribute(const std::string& line,
2808 MediaContentDescription* media_desc,
2809 SdpParseError* error) {
2810 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002811 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002812 kSdpDelimiterSpace, &fields);
2813 // RFC 4568
2814 // a=crypto:<tag> <crypto-suite> <key-params> [<session-params>]
2815 const size_t expected_min_fields = 3;
2816 if (fields.size() < expected_min_fields) {
2817 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
2818 }
2819 std::string tag_value;
2820 if (!GetValue(fields[0], kAttributeCrypto, &tag_value, error)) {
2821 return false;
2822 }
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002823 int tag = 0;
2824 if (!GetValueFromString(line, tag_value, &tag, error)) {
2825 return false;
2826 }
jbauch083b73f2015-07-16 02:46:32 -07002827 const std::string& crypto_suite = fields[1];
2828 const std::string& key_params = fields[2];
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002829 std::string session_params;
2830 if (fields.size() > 3) {
2831 session_params = fields[3];
2832 }
2833 media_desc->AddCrypto(CryptoParams(tag, crypto_suite, key_params,
2834 session_params));
2835 return true;
2836}
2837
2838// Updates or creates a new codec entry in the audio description with according
2839// to |name|, |clockrate|, |bitrate|, |channels| and |preference|.
2840void UpdateCodec(int payload_type, const std::string& name, int clockrate,
2841 int bitrate, int channels, int preference,
2842 AudioContentDescription* audio_desc) {
2843 // Codec may already be populated with (only) optional parameters
2844 // (from an fmtp).
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002845 cricket::AudioCodec codec =
2846 GetCodecWithPayloadType(audio_desc->codecs(), payload_type);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002847 codec.name = name;
2848 codec.clockrate = clockrate;
2849 codec.bitrate = bitrate;
2850 codec.channels = channels;
2851 codec.preference = preference;
2852 AddOrReplaceCodec<AudioContentDescription, cricket::AudioCodec>(audio_desc,
2853 codec);
2854}
2855
2856// Updates or creates a new codec entry in the video description according to
2857// |name|, |width|, |height|, |framerate| and |preference|.
2858void UpdateCodec(int payload_type, const std::string& name, int width,
2859 int height, int framerate, int preference,
2860 VideoContentDescription* video_desc) {
2861 // Codec may already be populated with (only) optional parameters
2862 // (from an fmtp).
changbin.shao@webrtc.org2d25b442015-03-16 04:14:34 +00002863 cricket::VideoCodec codec =
2864 GetCodecWithPayloadType(video_desc->codecs(), payload_type);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002865 codec.name = name;
2866 codec.width = width;
2867 codec.height = height;
2868 codec.framerate = framerate;
2869 codec.preference = preference;
2870 AddOrReplaceCodec<VideoContentDescription, cricket::VideoCodec>(video_desc,
2871 codec);
2872}
2873
2874bool ParseRtpmapAttribute(const std::string& line,
2875 const MediaType media_type,
2876 const std::vector<int>& codec_preference,
2877 MediaContentDescription* media_desc,
2878 SdpParseError* error) {
2879 std::vector<std::string> fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002880 rtc::split(line.substr(kLinePrefixLength),
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002881 kSdpDelimiterSpace, &fields);
2882 // RFC 4566
2883 // a=rtpmap:<payload type> <encoding name>/<clock rate>[/<encodingparameters>]
2884 const size_t expected_min_fields = 2;
2885 if (fields.size() < expected_min_fields) {
2886 return ParseFailedExpectMinFieldNum(line, expected_min_fields, error);
2887 }
2888 std::string payload_type_value;
2889 if (!GetValue(fields[0], kAttributeRtpmap, &payload_type_value, error)) {
2890 return false;
2891 }
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002892 int payload_type = 0;
pkasting@chromium.orge9facf82015-02-17 20:36:28 +00002893 if (!GetPayloadTypeFromString(line, payload_type_value, &payload_type,
2894 error)) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002895 return false;
2896 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002897
2898 // Set the preference order depending on the order of the pl type in the
2899 // <fmt> of the m-line.
2900 const int preference = codec_preference.end() -
2901 std::find(codec_preference.begin(), codec_preference.end(),
2902 payload_type);
2903 if (preference == 0) {
2904 LOG(LS_WARNING) << "Ignore rtpmap line that did not appear in the "
2905 << "<fmt> of the m-line: " << line;
2906 return true;
2907 }
jbauch083b73f2015-07-16 02:46:32 -07002908 const std::string& encoder = fields[1];
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002909 std::vector<std::string> codec_params;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00002910 rtc::split(encoder, '/', &codec_params);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002911 // <encoding name>/<clock rate>[/<encodingparameters>]
2912 // 2 mandatory fields
2913 if (codec_params.size() < 2 || codec_params.size() > 3) {
2914 return ParseFailed(line,
2915 "Expected format \"<encoding name>/<clock rate>"
2916 "[/<encodingparameters>]\".",
2917 error);
2918 }
jbauch083b73f2015-07-16 02:46:32 -07002919 const std::string& encoding_name = codec_params[0];
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002920 int clock_rate = 0;
2921 if (!GetValueFromString(line, codec_params[1], &clock_rate, error)) {
2922 return false;
2923 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002924 if (media_type == cricket::MEDIA_TYPE_VIDEO) {
2925 VideoContentDescription* video_desc =
2926 static_cast<VideoContentDescription*>(media_desc);
2927 // TODO: We will send resolution in SDP. For now use
2928 // JsepSessionDescription::kMaxVideoCodecWidth and kMaxVideoCodecHeight.
2929 UpdateCodec(payload_type, encoding_name,
2930 JsepSessionDescription::kMaxVideoCodecWidth,
2931 JsepSessionDescription::kMaxVideoCodecHeight,
2932 JsepSessionDescription::kDefaultVideoCodecFramerate,
2933 preference, video_desc);
2934 } else if (media_type == cricket::MEDIA_TYPE_AUDIO) {
2935 // RFC 4566
2936 // For audio streams, <encoding parameters> indicates the number
2937 // of audio channels. This parameter is OPTIONAL and may be
2938 // omitted if the number of channels is one, provided that no
2939 // additional parameters are needed.
2940 int channels = 1;
2941 if (codec_params.size() == 3) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00002942 if (!GetValueFromString(line, codec_params[2], &channels, error)) {
2943 return false;
2944 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002945 }
2946 int bitrate = 0;
2947 // The default behavior for ISAC (bitrate == 0) in webrtcvoiceengine.cc
2948 // (specifically FindWebRtcCodec) is bandwidth-adaptive variable bitrate.
2949 // The bandwidth adaptation doesn't always work well, so this code
2950 // sets a fixed target bitrate instead.
2951 if (_stricmp(encoding_name.c_str(), kIsacCodecName) == 0) {
2952 if (clock_rate <= 16000) {
2953 bitrate = kIsacWbDefaultRate;
2954 } else {
2955 bitrate = kIsacSwbDefaultRate;
2956 }
2957 }
2958 AudioContentDescription* audio_desc =
2959 static_cast<AudioContentDescription*>(media_desc);
2960 UpdateCodec(payload_type, encoding_name, clock_rate, bitrate, channels,
2961 preference, audio_desc);
2962 } else if (media_type == cricket::MEDIA_TYPE_DATA) {
2963 DataContentDescription* data_desc =
2964 static_cast<DataContentDescription*>(media_desc);
2965 data_desc->AddCodec(cricket::DataCodec(payload_type, encoding_name,
2966 preference));
2967 }
2968 return true;
2969}
2970
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002971bool ParseFmtpParam(const std::string& line, std::string* parameter,
2972 std::string* value, SdpParseError* error) {
Donald Curtis0e07f922015-05-15 09:21:23 -07002973 if (!rtc::tokenize_first(line, kSdpDelimiterEqual, parameter, value)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002974 ParseFailed(line, "Unable to parse fmtp parameter. \'=\' missing.", error);
2975 return false;
2976 }
2977 // a=fmtp:<payload_type> <param1>=<value1>; <param2>=<value2>; ...
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002978 return true;
2979}
2980
2981bool ParseFmtpAttributes(const std::string& line, const MediaType media_type,
2982 MediaContentDescription* media_desc,
2983 SdpParseError* error) {
2984 if (media_type != cricket::MEDIA_TYPE_AUDIO &&
2985 media_type != cricket::MEDIA_TYPE_VIDEO) {
2986 return true;
2987 }
Donald Curtis0e07f922015-05-15 09:21:23 -07002988
2989 std::string line_payload;
2990 std::string line_params;
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002991
2992 // RFC 5576
2993 // a=fmtp:<format> <format specific parameters>
2994 // At least two fields, whereas the second one is any of the optional
2995 // parameters.
Donald Curtis144d0182015-05-15 13:14:24 -07002996 if (!rtc::tokenize_first(line.substr(kLinePrefixLength), kSdpDelimiterSpace,
2997 &line_payload, &line_params)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00002998 ParseFailedExpectMinFieldNum(line, 2, error);
2999 return false;
3000 }
3001
Donald Curtis0e07f922015-05-15 09:21:23 -07003002 // Parse out the payload information.
pkasting@chromium.orgd3245462015-02-23 21:28:22 +00003003 std::string payload_type_str;
Donald Curtis0e07f922015-05-15 09:21:23 -07003004 if (!GetValue(line_payload, kAttributeFmtp, &payload_type_str, error)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003005 return false;
3006 }
3007
Donald Curtis0e07f922015-05-15 09:21:23 -07003008 int payload_type = 0;
Donald Curtis144d0182015-05-15 13:14:24 -07003009 if (!GetPayloadTypeFromString(line_payload, payload_type_str, &payload_type,
3010 error)) {
Donald Curtis0e07f922015-05-15 09:21:23 -07003011 return false;
3012 }
3013
3014 // Parse out format specific parameters.
3015 std::vector<std::string> fields;
3016 rtc::split(line_params, kSdpDelimiterSemicolon, &fields);
3017
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003018 cricket::CodecParameterMap codec_params;
Donald Curtis144d0182015-05-15 13:14:24 -07003019 for (auto& iter : fields) {
Donald Curtis0e07f922015-05-15 09:21:23 -07003020 if (iter.find(kSdpDelimiterEqual) == std::string::npos) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003021 // Only fmtps with equals are currently supported. Other fmtp types
3022 // should be ignored. Unknown fmtps do not constitute an error.
3023 continue;
3024 }
Donald Curtis0e07f922015-05-15 09:21:23 -07003025
3026 std::string name;
3027 std::string value;
3028 if (!ParseFmtpParam(rtc::string_trim(iter), &name, &value, error)) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003029 return false;
3030 }
3031 codec_params[name] = value;
3032 }
3033
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003034 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
3035 UpdateCodec<AudioContentDescription, cricket::AudioCodec>(
pkasting@chromium.orgd3245462015-02-23 21:28:22 +00003036 media_desc, payload_type, codec_params);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003037 } else if (media_type == cricket::MEDIA_TYPE_VIDEO) {
3038 UpdateCodec<VideoContentDescription, cricket::VideoCodec>(
pkasting@chromium.orgd3245462015-02-23 21:28:22 +00003039 media_desc, payload_type, codec_params);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003040 }
3041 return true;
3042}
3043
3044bool ParseRtcpFbAttribute(const std::string& line, const MediaType media_type,
3045 MediaContentDescription* media_desc,
3046 SdpParseError* error) {
3047 if (media_type != cricket::MEDIA_TYPE_AUDIO &&
3048 media_type != cricket::MEDIA_TYPE_VIDEO) {
3049 return true;
3050 }
3051 std::vector<std::string> rtcp_fb_fields;
buildbot@webrtc.orgd4e598d2014-07-29 17:36:52 +00003052 rtc::split(line.c_str(), kSdpDelimiterSpace, &rtcp_fb_fields);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003053 if (rtcp_fb_fields.size() < 2) {
3054 return ParseFailedGetValue(line, kAttributeRtcpFb, error);
3055 }
3056 std::string payload_type_string;
3057 if (!GetValue(rtcp_fb_fields[0], kAttributeRtcpFb, &payload_type_string,
3058 error)) {
3059 return false;
3060 }
wu@webrtc.org5e760e72014-04-02 23:19:09 +00003061 int payload_type = kWildcardPayloadType;
3062 if (payload_type_string != "*") {
pkasting@chromium.orge9facf82015-02-17 20:36:28 +00003063 if (!GetPayloadTypeFromString(line, payload_type_string, &payload_type,
3064 error)) {
wu@webrtc.org5e760e72014-04-02 23:19:09 +00003065 return false;
3066 }
3067 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003068 std::string id = rtcp_fb_fields[1];
3069 std::string param = "";
3070 for (std::vector<std::string>::iterator iter = rtcp_fb_fields.begin() + 2;
3071 iter != rtcp_fb_fields.end(); ++iter) {
3072 param.append(*iter);
3073 }
3074 const cricket::FeedbackParam feedback_param(id, param);
3075
3076 if (media_type == cricket::MEDIA_TYPE_AUDIO) {
pkasting@chromium.orgd3245462015-02-23 21:28:22 +00003077 UpdateCodec<AudioContentDescription, cricket::AudioCodec>(
3078 media_desc, payload_type, feedback_param);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003079 } else if (media_type == cricket::MEDIA_TYPE_VIDEO) {
pkasting@chromium.orgd3245462015-02-23 21:28:22 +00003080 UpdateCodec<VideoContentDescription, cricket::VideoCodec>(
3081 media_desc, payload_type, feedback_param);
henrike@webrtc.org28e20752013-07-10 00:45:36 +00003082 }
3083 return true;
3084}
3085
3086} // namespace webrtc