| /* |
| * Copyright 2011 The WebRTC project authors. All Rights Reserved. |
| * |
| * Use of this source code is governed by a BSD-style license |
| * that can be found in the LICENSE file in the root of the source |
| * tree. An additional intellectual property rights grant can be found |
| * in the file PATENTS. All contributing project authors may |
| * be found in the AUTHORS file in the root of the source tree. |
| */ |
| |
| #include "webrtc/pc/webrtcsdp.h" |
| |
| #include <ctype.h> |
| #include <limits.h> |
| #include <stdio.h> |
| |
| #include <algorithm> |
| #include <memory> |
| #include <string> |
| #include <unordered_map> |
| #include <vector> |
| |
| #include "webrtc/api/jsepicecandidate.h" |
| #include "webrtc/api/jsepsessiondescription.h" |
| // for RtpExtension |
| #include "webrtc/api/rtpparameters.h" |
| #include "webrtc/media/base/codec.h" |
| #include "webrtc/media/base/cryptoparams.h" |
| #include "webrtc/media/base/mediaconstants.h" |
| #include "webrtc/media/base/rtputils.h" |
| #include "webrtc/media/sctp/sctptransportinternal.h" |
| #include "webrtc/p2p/base/candidate.h" |
| #include "webrtc/p2p/base/p2pconstants.h" |
| #include "webrtc/p2p/base/port.h" |
| #include "webrtc/pc/mediasession.h" |
| #include "webrtc/rtc_base/arraysize.h" |
| #include "webrtc/rtc_base/checks.h" |
| #include "webrtc/rtc_base/logging.h" |
| #include "webrtc/rtc_base/messagedigest.h" |
| #include "webrtc/rtc_base/stringutils.h" |
| |
| using cricket::AudioContentDescription; |
| using cricket::Candidate; |
| using cricket::Candidates; |
| using cricket::ContentDescription; |
| using cricket::ContentInfo; |
| using cricket::CryptoParams; |
| using cricket::DataContentDescription; |
| using cricket::ICE_CANDIDATE_COMPONENT_RTP; |
| using cricket::ICE_CANDIDATE_COMPONENT_RTCP; |
| using cricket::kCodecParamMaxBitrate; |
| using cricket::kCodecParamMaxPTime; |
| using cricket::kCodecParamMaxQuantization; |
| using cricket::kCodecParamMinBitrate; |
| using cricket::kCodecParamMinPTime; |
| using cricket::kCodecParamPTime; |
| using cricket::kCodecParamSPropStereo; |
| using cricket::kCodecParamStartBitrate; |
| using cricket::kCodecParamStereo; |
| using cricket::kCodecParamUseInbandFec; |
| using cricket::kCodecParamUseDtx; |
| using cricket::kCodecParamSctpProtocol; |
| using cricket::kCodecParamSctpStreams; |
| using cricket::kCodecParamMaxAverageBitrate; |
| using cricket::kCodecParamMaxPlaybackRate; |
| using cricket::kCodecParamAssociatedPayloadType; |
| using cricket::MediaContentDescription; |
| using cricket::MediaType; |
| using cricket::RtpHeaderExtensions; |
| using cricket::SsrcGroup; |
| using cricket::StreamParams; |
| using cricket::StreamParamsVec; |
| using cricket::TransportDescription; |
| using cricket::TransportInfo; |
| using cricket::VideoContentDescription; |
| using rtc::SocketAddress; |
| |
| namespace cricket { |
| class SessionDescription; |
| } |
| |
| // TODO(deadbeef): Switch to using anonymous namespace rather than declaring |
| // everything "static". |
| namespace webrtc { |
| |
| // Line type |
| // RFC 4566 |
| // An SDP session description consists of a number of lines of text of |
| // the form: |
| // <type>=<value> |
| // where <type> MUST be exactly one case-significant character. |
| static const int kLinePrefixLength = 2; // Length of <type>= |
| static const char kLineTypeVersion = 'v'; |
| static const char kLineTypeOrigin = 'o'; |
| static const char kLineTypeSessionName = 's'; |
| static const char kLineTypeSessionInfo = 'i'; |
| static const char kLineTypeSessionUri = 'u'; |
| static const char kLineTypeSessionEmail = 'e'; |
| static const char kLineTypeSessionPhone = 'p'; |
| static const char kLineTypeSessionBandwidth = 'b'; |
| static const char kLineTypeTiming = 't'; |
| static const char kLineTypeRepeatTimes = 'r'; |
| static const char kLineTypeTimeZone = 'z'; |
| static const char kLineTypeEncryptionKey = 'k'; |
| static const char kLineTypeMedia = 'm'; |
| static const char kLineTypeConnection = 'c'; |
| static const char kLineTypeAttributes = 'a'; |
| |
| // Attributes |
| static const char kAttributeGroup[] = "group"; |
| static const char kAttributeMid[] = "mid"; |
| static const char kAttributeMsid[] = "msid"; |
| static const char kAttributeBundleOnly[] = "bundle-only"; |
| static const char kAttributeRtcpMux[] = "rtcp-mux"; |
| static const char kAttributeRtcpReducedSize[] = "rtcp-rsize"; |
| static const char kAttributeSsrc[] = "ssrc"; |
| static const char kSsrcAttributeCname[] = "cname"; |
| static const char kAttributeExtmap[] = "extmap"; |
| // draft-alvestrand-mmusic-msid-01 |
| // a=msid-semantic: WMS |
| static const char kAttributeMsidSemantics[] = "msid-semantic"; |
| static const char kMediaStreamSemantic[] = "WMS"; |
| static const char kSsrcAttributeMsid[] = "msid"; |
| static const char kDefaultMsid[] = "default"; |
| static const char kSsrcAttributeMslabel[] = "mslabel"; |
| static const char kSSrcAttributeLabel[] = "label"; |
| static const char kAttributeSsrcGroup[] = "ssrc-group"; |
| static const char kAttributeCrypto[] = "crypto"; |
| static const char kAttributeCandidate[] = "candidate"; |
| static const char kAttributeCandidateTyp[] = "typ"; |
| static const char kAttributeCandidateRaddr[] = "raddr"; |
| static const char kAttributeCandidateRport[] = "rport"; |
| static const char kAttributeCandidateUfrag[] = "ufrag"; |
| static const char kAttributeCandidatePwd[] = "pwd"; |
| static const char kAttributeCandidateGeneration[] = "generation"; |
| static const char kAttributeCandidateNetworkId[] = "network-id"; |
| static const char kAttributeCandidateNetworkCost[] = "network-cost"; |
| static const char kAttributeFingerprint[] = "fingerprint"; |
| static const char kAttributeSetup[] = "setup"; |
| static const char kAttributeFmtp[] = "fmtp"; |
| static const char kAttributeRtpmap[] = "rtpmap"; |
| static const char kAttributeSctpmap[] = "sctpmap"; |
| static const char kAttributeRtcp[] = "rtcp"; |
| static const char kAttributeIceUfrag[] = "ice-ufrag"; |
| static const char kAttributeIcePwd[] = "ice-pwd"; |
| static const char kAttributeIceLite[] = "ice-lite"; |
| static const char kAttributeIceOption[] = "ice-options"; |
| static const char kAttributeSendOnly[] = "sendonly"; |
| static const char kAttributeRecvOnly[] = "recvonly"; |
| static const char kAttributeRtcpFb[] = "rtcp-fb"; |
| static const char kAttributeSendRecv[] = "sendrecv"; |
| static const char kAttributeInactive[] = "inactive"; |
| // draft-ietf-mmusic-sctp-sdp-07 |
| // a=sctp-port |
| static const char kAttributeSctpPort[] = "sctp-port"; |
| |
| // Experimental flags |
| static const char kAttributeXGoogleFlag[] = "x-google-flag"; |
| static const char kValueConference[] = "conference"; |
| |
| // Candidate |
| static const char kCandidateHost[] = "host"; |
| static const char kCandidateSrflx[] = "srflx"; |
| static const char kCandidatePrflx[] = "prflx"; |
| static const char kCandidateRelay[] = "relay"; |
| static const char kTcpCandidateType[] = "tcptype"; |
| |
| static const char kSdpDelimiterEqual = '='; |
| static const char kSdpDelimiterSpace = ' '; |
| static const char kSdpDelimiterColon = ':'; |
| static const char kSdpDelimiterSemicolon = ';'; |
| static const char kSdpDelimiterSlash = '/'; |
| static const char kNewLine = '\n'; |
| static const char kReturn = '\r'; |
| static const char kLineBreak[] = "\r\n"; |
| |
| // TODO: Generate the Session and Time description |
| // instead of hardcoding. |
| static const char kSessionVersion[] = "v=0"; |
| // RFC 4566 |
| static const char kSessionOriginUsername[] = "-"; |
| static const char kSessionOriginSessionId[] = "0"; |
| static const char kSessionOriginSessionVersion[] = "0"; |
| static const char kSessionOriginNettype[] = "IN"; |
| static const char kSessionOriginAddrtype[] = "IP4"; |
| static const char kSessionOriginAddress[] = "127.0.0.1"; |
| static const char kSessionName[] = "s=-"; |
| static const char kTimeDescription[] = "t=0 0"; |
| static const char kAttrGroup[] = "a=group:BUNDLE"; |
| static const char kConnectionNettype[] = "IN"; |
| static const char kConnectionIpv4Addrtype[] = "IP4"; |
| static const char kConnectionIpv6Addrtype[] = "IP6"; |
| static const char kMediaTypeVideo[] = "video"; |
| static const char kMediaTypeAudio[] = "audio"; |
| static const char kMediaTypeData[] = "application"; |
| static const char kMediaPortRejected[] = "0"; |
| // draft-ietf-mmusic-trickle-ice-01 |
| // When no candidates have been gathered, set the connection |
| // address to IP6 ::. |
| // TODO(perkj): FF can not parse IP6 ::. See http://crbug/430333 |
| // Use IPV4 per default. |
| static const char kDummyAddress[] = "0.0.0.0"; |
| static const char kDummyPort[] = "9"; |
| // RFC 3556 |
| static const char kApplicationSpecificMaximum[] = "AS"; |
| |
| static const char kDefaultSctpmapProtocol[] = "webrtc-datachannel"; |
| |
| // RTP payload type is in the 0-127 range. Use -1 to indicate "all" payload |
| // types. |
| const int kWildcardPayloadType = -1; |
| |
| struct SsrcInfo { |
| uint32_t ssrc_id; |
| std::string cname; |
| std::string stream_id; |
| std::string track_id; |
| |
| // For backward compatibility. |
| // TODO(ronghuawu): Remove below 2 fields once all the clients support msid. |
| std::string label; |
| std::string mslabel; |
| }; |
| typedef std::vector<SsrcInfo> SsrcInfoVec; |
| typedef std::vector<SsrcGroup> SsrcGroupVec; |
| |
| template <class T> |
| static void AddFmtpLine(const T& codec, std::string* message); |
| static void BuildMediaDescription(const ContentInfo* content_info, |
| const TransportInfo* transport_info, |
| const MediaType media_type, |
| const std::vector<Candidate>& candidates, |
| bool unified_plan_sdp, |
| std::string* message); |
| static void BuildSctpContentAttributes(std::string* message, |
| int sctp_port, |
| bool use_sctpmap); |
| static void BuildRtpContentAttributes(const MediaContentDescription* media_desc, |
| const MediaType media_type, |
| bool unified_plan_sdp, |
| std::string* message); |
| static void BuildRtpMap(const MediaContentDescription* media_desc, |
| const MediaType media_type, |
| std::string* message); |
| static void BuildCandidate(const std::vector<Candidate>& candidates, |
| bool include_ufrag, |
| std::string* message); |
| static void BuildIceOptions(const std::vector<std::string>& transport_options, |
| std::string* message); |
| static bool IsRtp(const std::string& protocol); |
| static bool IsDtlsSctp(const std::string& protocol); |
| static bool ParseSessionDescription(const std::string& message, |
| size_t* pos, |
| std::string* session_id, |
| std::string* session_version, |
| TransportDescription* session_td, |
| RtpHeaderExtensions* session_extmaps, |
| rtc::SocketAddress* connection_addr, |
| cricket::SessionDescription* desc, |
| SdpParseError* error); |
| static bool ParseGroupAttribute(const std::string& line, |
| cricket::SessionDescription* desc, |
| SdpParseError* error); |
| static bool ParseMediaDescription( |
| const std::string& message, |
| const TransportDescription& session_td, |
| const RtpHeaderExtensions& session_extmaps, |
| size_t* pos, |
| const rtc::SocketAddress& session_connection_addr, |
| cricket::SessionDescription* desc, |
| std::vector<JsepIceCandidate*>* candidates, |
| SdpParseError* error); |
| static bool ParseContent(const std::string& message, |
| const MediaType media_type, |
| int mline_index, |
| const std::string& protocol, |
| const std::vector<int>& payload_types, |
| size_t* pos, |
| std::string* content_name, |
| bool* bundle_only, |
| MediaContentDescription* media_desc, |
| TransportDescription* transport, |
| std::vector<JsepIceCandidate*>* candidates, |
| SdpParseError* error); |
| static bool ParseSsrcAttribute(const std::string& line, |
| SsrcInfoVec* ssrc_infos, |
| SdpParseError* error); |
| static bool ParseSsrcGroupAttribute(const std::string& line, |
| SsrcGroupVec* ssrc_groups, |
| SdpParseError* error); |
| static bool ParseCryptoAttribute(const std::string& line, |
| MediaContentDescription* media_desc, |
| SdpParseError* error); |
| static bool ParseRtpmapAttribute(const std::string& line, |
| const MediaType media_type, |
| const std::vector<int>& payload_types, |
| MediaContentDescription* media_desc, |
| SdpParseError* error); |
| static bool ParseFmtpAttributes(const std::string& line, |
| const MediaType media_type, |
| MediaContentDescription* media_desc, |
| SdpParseError* error); |
| static bool ParseFmtpParam(const std::string& line, std::string* parameter, |
| std::string* value, SdpParseError* error); |
| static bool ParseCandidate(const std::string& message, Candidate* candidate, |
| SdpParseError* error, bool is_raw); |
| static bool ParseRtcpFbAttribute(const std::string& line, |
| const MediaType media_type, |
| MediaContentDescription* media_desc, |
| SdpParseError* error); |
| static bool ParseIceOptions(const std::string& line, |
| std::vector<std::string>* transport_options, |
| SdpParseError* error); |
| static bool ParseExtmap(const std::string& line, |
| RtpExtension* extmap, |
| SdpParseError* error); |
| static bool ParseFingerprintAttribute(const std::string& line, |
| rtc::SSLFingerprint** fingerprint, |
| SdpParseError* error); |
| static bool ParseDtlsSetup(const std::string& line, |
| cricket::ConnectionRole* role, |
| SdpParseError* error); |
| static bool ParseMsidAttribute(const std::string& line, |
| std::string* stream_id, |
| std::string* track_id, |
| SdpParseError* error); |
| |
| // Helper functions |
| |
| // Below ParseFailed*** functions output the line that caused the parsing |
| // failure and the detailed reason (|description|) of the failure to |error|. |
| // The functions always return false so that they can be used directly in the |
| // following way when error happens: |
| // "return ParseFailed***(...);" |
| |
| // The line starting at |line_start| of |message| is the failing line. |
| // The reason for the failure should be provided in the |description|. |
| // An example of a description could be "unknown character". |
| static bool ParseFailed(const std::string& message, |
| size_t line_start, |
| const std::string& description, |
| SdpParseError* error) { |
| // Get the first line of |message| from |line_start|. |
| std::string first_line; |
| size_t line_end = message.find(kNewLine, line_start); |
| if (line_end != std::string::npos) { |
| if (line_end > 0 && (message.at(line_end - 1) == kReturn)) { |
| --line_end; |
| } |
| first_line = message.substr(line_start, (line_end - line_start)); |
| } else { |
| first_line = message.substr(line_start); |
| } |
| |
| if (error) { |
| error->line = first_line; |
| error->description = description; |
| } |
| LOG(LS_ERROR) << "Failed to parse: \"" << first_line |
| << "\". Reason: " << description; |
| return false; |
| } |
| |
| // |line| is the failing line. The reason for the failure should be |
| // provided in the |description|. |
| static bool ParseFailed(const std::string& line, |
| const std::string& description, |
| SdpParseError* error) { |
| return ParseFailed(line, 0, description, error); |
| } |
| |
| // Parses failure where the failing SDP line isn't know or there are multiple |
| // failing lines. |
| static bool ParseFailed(const std::string& description, |
| SdpParseError* error) { |
| return ParseFailed("", description, error); |
| } |
| |
| // |line| is the failing line. The failure is due to the fact that |line| |
| // doesn't have |expected_fields| fields. |
| static bool ParseFailedExpectFieldNum(const std::string& line, |
| int expected_fields, |
| SdpParseError* error) { |
| std::ostringstream description; |
| description << "Expects " << expected_fields << " fields."; |
| return ParseFailed(line, description.str(), error); |
| } |
| |
| // |line| is the failing line. The failure is due to the fact that |line| has |
| // less than |expected_min_fields| fields. |
| static bool ParseFailedExpectMinFieldNum(const std::string& line, |
| int expected_min_fields, |
| SdpParseError* error) { |
| std::ostringstream description; |
| description << "Expects at least " << expected_min_fields << " fields."; |
| return ParseFailed(line, description.str(), error); |
| } |
| |
| // |line| is the failing line. The failure is due to the fact that it failed to |
| // get the value of |attribute|. |
| static bool ParseFailedGetValue(const std::string& line, |
| const std::string& attribute, |
| SdpParseError* error) { |
| std::ostringstream description; |
| description << "Failed to get the value of attribute: " << attribute; |
| return ParseFailed(line, description.str(), error); |
| } |
| |
| // The line starting at |line_start| of |message| is the failing line. The |
| // failure is due to the line type (e.g. the "m" part of the "m-line") |
| // not matching what is expected. The expected line type should be |
| // provided as |line_type|. |
| static bool ParseFailedExpectLine(const std::string& message, |
| size_t line_start, |
| const char line_type, |
| const std::string& line_value, |
| SdpParseError* error) { |
| std::ostringstream description; |
| description << "Expect line: " << line_type << "=" << line_value; |
| return ParseFailed(message, line_start, description.str(), error); |
| } |
| |
| static bool AddLine(const std::string& line, std::string* message) { |
| if (!message) |
| return false; |
| |
| message->append(line); |
| message->append(kLineBreak); |
| return true; |
| } |
| |
| static bool GetLine(const std::string& message, |
| size_t* pos, |
| std::string* line) { |
| size_t line_begin = *pos; |
| size_t line_end = message.find(kNewLine, line_begin); |
| if (line_end == std::string::npos) { |
| return false; |
| } |
| // Update the new start position |
| *pos = line_end + 1; |
| if (line_end > 0 && (message.at(line_end - 1) == kReturn)) { |
| --line_end; |
| } |
| *line = message.substr(line_begin, (line_end - line_begin)); |
| const char* cline = line->c_str(); |
| // RFC 4566 |
| // An SDP session description consists of a number of lines of text of |
| // the form: |
| // <type>=<value> |
| // where <type> MUST be exactly one case-significant character and |
| // <value> is structured text whose format depends on <type>. |
| // Whitespace MUST NOT be used on either side of the "=" sign. |
| if (line->length() < 3 || |
| !islower(cline[0]) || |
| cline[1] != kSdpDelimiterEqual || |
| cline[2] == kSdpDelimiterSpace) { |
| *pos = line_begin; |
| return false; |
| } |
| return true; |
| } |
| |
| // Init |os| to "|type|=|value|". |
| static void InitLine(const char type, |
| const std::string& value, |
| std::ostringstream* os) { |
| os->str(""); |
| *os << type << kSdpDelimiterEqual << value; |
| } |
| |
| // Init |os| to "a=|attribute|". |
| static void InitAttrLine(const std::string& attribute, std::ostringstream* os) { |
| InitLine(kLineTypeAttributes, attribute, os); |
| } |
| |
| // Writes a SDP attribute line based on |attribute| and |value| to |message|. |
| static void AddAttributeLine(const std::string& attribute, int value, |
| std::string* message) { |
| std::ostringstream os; |
| InitAttrLine(attribute, &os); |
| os << kSdpDelimiterColon << value; |
| AddLine(os.str(), message); |
| } |
| |
| static bool IsLineType(const std::string& message, |
| const char type, |
| size_t line_start) { |
| if (message.size() < line_start + kLinePrefixLength) { |
| return false; |
| } |
| const char* cmessage = message.c_str(); |
| return (cmessage[line_start] == type && |
| cmessage[line_start + 1] == kSdpDelimiterEqual); |
| } |
| |
| static bool IsLineType(const std::string& line, |
| const char type) { |
| return IsLineType(line, type, 0); |
| } |
| |
| static bool GetLineWithType(const std::string& message, size_t* pos, |
| std::string* line, const char type) { |
| if (!IsLineType(message, type, *pos)) { |
| return false; |
| } |
| |
| if (!GetLine(message, pos, line)) |
| return false; |
| |
| return true; |
| } |
| |
| static bool HasAttribute(const std::string& line, |
| const std::string& attribute) { |
| return (line.compare(kLinePrefixLength, attribute.size(), attribute) == 0); |
| } |
| |
| static bool AddSsrcLine(uint32_t ssrc_id, |
| const std::string& attribute, |
| const std::string& value, |
| std::string* message) { |
| // RFC 5576 |
| // a=ssrc:<ssrc-id> <attribute>:<value> |
| std::ostringstream os; |
| InitAttrLine(kAttributeSsrc, &os); |
| os << kSdpDelimiterColon << ssrc_id << kSdpDelimiterSpace |
| << attribute << kSdpDelimiterColon << value; |
| return AddLine(os.str(), message); |
| } |
| |
| // Get value only from <attribute>:<value>. |
| static bool GetValue(const std::string& message, const std::string& attribute, |
| std::string* value, SdpParseError* error) { |
| std::string leftpart; |
| if (!rtc::tokenize_first(message, kSdpDelimiterColon, &leftpart, value)) { |
| return ParseFailedGetValue(message, attribute, error); |
| } |
| // The left part should end with the expected attribute. |
| if (leftpart.length() < attribute.length() || |
| leftpart.compare(leftpart.length() - attribute.length(), |
| attribute.length(), attribute) != 0) { |
| return ParseFailedGetValue(message, attribute, error); |
| } |
| return true; |
| } |
| |
| static bool CaseInsensitiveFind(std::string str1, std::string str2) { |
| std::transform(str1.begin(), str1.end(), str1.begin(), |
| ::tolower); |
| std::transform(str2.begin(), str2.end(), str2.begin(), |
| ::tolower); |
| return str1.find(str2) != std::string::npos; |
| } |
| |
| template <class T> |
| static bool GetValueFromString(const std::string& line, |
| const std::string& s, |
| T* t, |
| SdpParseError* error) { |
| if (!rtc::FromString(s, t)) { |
| std::ostringstream description; |
| description << "Invalid value: " << s << "."; |
| return ParseFailed(line, description.str(), error); |
| } |
| return true; |
| } |
| |
| static bool GetPayloadTypeFromString(const std::string& line, |
| const std::string& s, |
| int* payload_type, |
| SdpParseError* error) { |
| return GetValueFromString(line, s, payload_type, error) && |
| cricket::IsValidRtpPayloadType(*payload_type); |
| } |
| |
| // |msid_stream_id| and |msid_track_id| represent the stream/track ID from the |
| // "a=msid" attribute, if it exists. They are empty if the attribute does not |
| // exist. |
| void CreateTracksFromSsrcInfos(const SsrcInfoVec& ssrc_infos, |
| const std::string& msid_stream_id, |
| const std::string& msid_track_id, |
| StreamParamsVec* tracks) { |
| RTC_DCHECK(tracks != NULL); |
| RTC_DCHECK(msid_stream_id.empty() == msid_track_id.empty()); |
| for (SsrcInfoVec::const_iterator ssrc_info = ssrc_infos.begin(); |
| ssrc_info != ssrc_infos.end(); ++ssrc_info) { |
| if (ssrc_info->cname.empty()) { |
| continue; |
| } |
| |
| std::string stream_id; |
| std::string track_id; |
| if (ssrc_info->stream_id.empty() && !ssrc_info->mslabel.empty()) { |
| // If there's no msid and there's mslabel, we consider this is a sdp from |
| // a older version of client that doesn't support msid. |
| // In that case, we use the mslabel and label to construct the track. |
| stream_id = ssrc_info->mslabel; |
| track_id = ssrc_info->label; |
| } else if (ssrc_info->stream_id.empty() && !msid_stream_id.empty()) { |
| // If there's no msid in the SSRC attributes, but there's a global one |
| // (from a=msid), use that. This is the case with unified plan SDP. |
| stream_id = msid_stream_id; |
| track_id = msid_track_id; |
| } else { |
| stream_id = ssrc_info->stream_id; |
| track_id = ssrc_info->track_id; |
| } |
| // If a stream/track ID wasn't populated from the SSRC attributes OR the |
| // msid attribute, use default/random values. |
| if (stream_id.empty()) { |
| stream_id = kDefaultMsid; |
| } |
| if (track_id.empty()) { |
| // TODO(ronghuawu): What should we do if the track id doesn't appear? |
| // Create random string (which will be used as track label later)? |
| track_id = rtc::CreateRandomString(8); |
| } |
| |
| StreamParamsVec::iterator track = tracks->begin(); |
| for (; track != tracks->end(); ++track) { |
| if (track->id == track_id) { |
| break; |
| } |
| } |
| if (track == tracks->end()) { |
| // If we don't find an existing track, create a new one. |
| tracks->push_back(StreamParams()); |
| track = tracks->end() - 1; |
| } |
| track->add_ssrc(ssrc_info->ssrc_id); |
| track->cname = ssrc_info->cname; |
| track->sync_label = stream_id; |
| track->id = track_id; |
| } |
| } |
| |
| void GetMediaStreamLabels(const ContentInfo* content, |
| std::set<std::string>* labels) { |
| const MediaContentDescription* media_desc = |
| static_cast<const MediaContentDescription*>( |
| content->description); |
| const cricket::StreamParamsVec& streams = media_desc->streams(); |
| for (cricket::StreamParamsVec::const_iterator it = streams.begin(); |
| it != streams.end(); ++it) { |
| labels->insert(it->sync_label); |
| } |
| } |
| |
| // RFC 5245 |
| // It is RECOMMENDED that default candidates be chosen based on the |
| // likelihood of those candidates to work with the peer that is being |
| // contacted. It is RECOMMENDED that relayed > reflexive > host. |
| static const int kPreferenceUnknown = 0; |
| static const int kPreferenceHost = 1; |
| static const int kPreferenceReflexive = 2; |
| static const int kPreferenceRelayed = 3; |
| |
| static int GetCandidatePreferenceFromType(const std::string& type) { |
| int preference = kPreferenceUnknown; |
| if (type == cricket::LOCAL_PORT_TYPE) { |
| preference = kPreferenceHost; |
| } else if (type == cricket::STUN_PORT_TYPE) { |
| preference = kPreferenceReflexive; |
| } else if (type == cricket::RELAY_PORT_TYPE) { |
| preference = kPreferenceRelayed; |
| } else { |
| RTC_NOTREACHED(); |
| } |
| return preference; |
| } |
| |
| // Get ip and port of the default destination from the |candidates| with the |
| // given value of |component_id|. The default candidate should be the one most |
| // likely to work, typically IPv4 relay. |
| // RFC 5245 |
| // The value of |component_id| currently supported are 1 (RTP) and 2 (RTCP). |
| // TODO: Decide the default destination in webrtcsession and |
| // pass it down via SessionDescription. |
| static void GetDefaultDestination( |
| const std::vector<Candidate>& candidates, |
| int component_id, std::string* port, |
| std::string* ip, std::string* addr_type) { |
| *addr_type = kConnectionIpv4Addrtype; |
| *port = kDummyPort; |
| *ip = kDummyAddress; |
| int current_preference = kPreferenceUnknown; |
| int current_family = AF_UNSPEC; |
| for (std::vector<Candidate>::const_iterator it = candidates.begin(); |
| it != candidates.end(); ++it) { |
| if (it->component() != component_id) { |
| continue; |
| } |
| // Default destination should be UDP only. |
| if (it->protocol() != cricket::UDP_PROTOCOL_NAME) { |
| continue; |
| } |
| const int preference = GetCandidatePreferenceFromType(it->type()); |
| const int family = it->address().ipaddr().family(); |
| // See if this candidate is more preferable then the current one if it's the |
| // same family. Or if the current family is IPv4 already so we could safely |
| // ignore all IPv6 ones. WebRTC bug 4269. |
| // http://code.google.com/p/webrtc/issues/detail?id=4269 |
| if ((preference <= current_preference && current_family == family) || |
| (current_family == AF_INET && family == AF_INET6)) { |
| continue; |
| } |
| if (family == AF_INET) { |
| addr_type->assign(kConnectionIpv4Addrtype); |
| } else if (family == AF_INET6) { |
| addr_type->assign(kConnectionIpv6Addrtype); |
| } |
| current_preference = preference; |
| current_family = family; |
| *port = it->address().PortAsString(); |
| *ip = it->address().ipaddr().ToString(); |
| } |
| } |
| |
| // Gets "a=rtcp" line if found default RTCP candidate from |candidates|. |
| static std::string GetRtcpLine(const std::vector<Candidate>& candidates) { |
| std::string rtcp_line, rtcp_port, rtcp_ip, addr_type; |
| GetDefaultDestination(candidates, ICE_CANDIDATE_COMPONENT_RTCP, |
| &rtcp_port, &rtcp_ip, &addr_type); |
| // Found default RTCP candidate. |
| // RFC 5245 |
| // If the agent is utilizing RTCP, it MUST encode the RTCP candidate |
| // using the a=rtcp attribute as defined in RFC 3605. |
| |
| // RFC 3605 |
| // rtcp-attribute = "a=rtcp:" port [nettype space addrtype space |
| // connection-address] CRLF |
| std::ostringstream os; |
| InitAttrLine(kAttributeRtcp, &os); |
| os << kSdpDelimiterColon |
| << rtcp_port << " " |
| << kConnectionNettype << " " |
| << addr_type << " " |
| << rtcp_ip; |
| rtcp_line = os.str(); |
| return rtcp_line; |
| } |
| |
| // Get candidates according to the mline index from SessionDescriptionInterface. |
| static void GetCandidatesByMindex(const SessionDescriptionInterface& desci, |
| int mline_index, |
| std::vector<Candidate>* candidates) { |
| if (!candidates) { |
| return; |
| } |
| const IceCandidateCollection* cc = desci.candidates(mline_index); |
| for (size_t i = 0; i < cc->count(); ++i) { |
| const IceCandidateInterface* candidate = cc->at(i); |
| candidates->push_back(candidate->candidate()); |
| } |
| } |
| |
| static bool IsValidPort(int port) { |
| return port >= 0 && port <= 65535; |
| } |
| |
| std::string SdpSerialize(const JsepSessionDescription& jdesc, |
| bool unified_plan_sdp) { |
| const cricket::SessionDescription* desc = jdesc.description(); |
| if (!desc) { |
| return ""; |
| } |
| |
| std::string message; |
| |
| // Session Description. |
| AddLine(kSessionVersion, &message); |
| // Session Origin |
| // RFC 4566 |
| // o=<username> <sess-id> <sess-version> <nettype> <addrtype> |
| // <unicast-address> |
| std::ostringstream os; |
| InitLine(kLineTypeOrigin, kSessionOriginUsername, &os); |
| const std::string& session_id = jdesc.session_id().empty() ? |
| kSessionOriginSessionId : jdesc.session_id(); |
| const std::string& session_version = jdesc.session_version().empty() ? |
| kSessionOriginSessionVersion : jdesc.session_version(); |
| os << " " << session_id << " " << session_version << " " |
| << kSessionOriginNettype << " " << kSessionOriginAddrtype << " " |
| << kSessionOriginAddress; |
| AddLine(os.str(), &message); |
| AddLine(kSessionName, &message); |
| |
| // Time Description. |
| AddLine(kTimeDescription, &message); |
| |
| // Group |
| if (desc->HasGroup(cricket::GROUP_TYPE_BUNDLE)) { |
| std::string group_line = kAttrGroup; |
| const cricket::ContentGroup* group = |
| desc->GetGroupByName(cricket::GROUP_TYPE_BUNDLE); |
| RTC_DCHECK(group != NULL); |
| const cricket::ContentNames& content_names = group->content_names(); |
| for (cricket::ContentNames::const_iterator it = content_names.begin(); |
| it != content_names.end(); ++it) { |
| group_line.append(" "); |
| group_line.append(*it); |
| } |
| AddLine(group_line, &message); |
| } |
| |
| // MediaStream semantics |
| InitAttrLine(kAttributeMsidSemantics, &os); |
| os << kSdpDelimiterColon << " " << kMediaStreamSemantic; |
| |
| std::set<std::string> media_stream_labels; |
| const ContentInfo* audio_content = GetFirstAudioContent(desc); |
| if (audio_content) |
| GetMediaStreamLabels(audio_content, &media_stream_labels); |
| |
| const ContentInfo* video_content = GetFirstVideoContent(desc); |
| if (video_content) |
| GetMediaStreamLabels(video_content, &media_stream_labels); |
| |
| for (std::set<std::string>::const_iterator it = |
| media_stream_labels.begin(); it != media_stream_labels.end(); ++it) { |
| os << " " << *it; |
| } |
| AddLine(os.str(), &message); |
| |
| // Preserve the order of the media contents. |
| int mline_index = -1; |
| for (cricket::ContentInfos::const_iterator it = desc->contents().begin(); |
| it != desc->contents().end(); ++it) { |
| const MediaContentDescription* mdesc = |
| static_cast<const MediaContentDescription*>(it->description); |
| std::vector<Candidate> candidates; |
| GetCandidatesByMindex(jdesc, ++mline_index, &candidates); |
| BuildMediaDescription(&*it, desc->GetTransportInfoByName(it->name), |
| mdesc->type(), candidates, unified_plan_sdp, |
| &message); |
| } |
| return message; |
| } |
| |
| // Serializes the passed in IceCandidateInterface to a SDP string. |
| // candidate - The candidate to be serialized. |
| std::string SdpSerializeCandidate(const IceCandidateInterface& candidate) { |
| return SdpSerializeCandidate(candidate.candidate()); |
| } |
| |
| // Serializes a cricket Candidate. |
| std::string SdpSerializeCandidate(const cricket::Candidate& candidate) { |
| std::string message; |
| std::vector<cricket::Candidate> candidates(1, candidate); |
| BuildCandidate(candidates, true, &message); |
| // From WebRTC draft section 4.8.1.1 candidate-attribute will be |
| // just candidate:<candidate> not a=candidate:<blah>CRLF |
| RTC_DCHECK(message.find("a=") == 0); |
| message.erase(0, 2); |
| RTC_DCHECK(message.find(kLineBreak) == message.size() - 2); |
| message.resize(message.size() - 2); |
| return message; |
| } |
| |
| bool SdpDeserialize(const std::string& message, |
| JsepSessionDescription* jdesc, |
| SdpParseError* error) { |
| std::string session_id; |
| std::string session_version; |
| TransportDescription session_td("", ""); |
| RtpHeaderExtensions session_extmaps; |
| rtc::SocketAddress session_connection_addr; |
| cricket::SessionDescription* desc = new cricket::SessionDescription(); |
| std::vector<JsepIceCandidate*> candidates; |
| size_t current_pos = 0; |
| |
| // Session Description |
| if (!ParseSessionDescription(message, ¤t_pos, &session_id, |
| &session_version, &session_td, &session_extmaps, |
| &session_connection_addr, desc, error)) { |
| delete desc; |
| return false; |
| } |
| |
| // Media Description |
| if (!ParseMediaDescription(message, session_td, session_extmaps, ¤t_pos, |
| session_connection_addr, desc, &candidates, |
| error)) { |
| delete desc; |
| for (std::vector<JsepIceCandidate*>::const_iterator |
| it = candidates.begin(); it != candidates.end(); ++it) { |
| delete *it; |
| } |
| return false; |
| } |
| |
| jdesc->Initialize(desc, session_id, session_version); |
| |
| for (std::vector<JsepIceCandidate*>::const_iterator |
| it = candidates.begin(); it != candidates.end(); ++it) { |
| jdesc->AddCandidate(*it); |
| delete *it; |
| } |
| return true; |
| } |
| |
| bool SdpDeserializeCandidate(const std::string& message, |
| JsepIceCandidate* jcandidate, |
| SdpParseError* error) { |
| RTC_DCHECK(jcandidate != NULL); |
| Candidate candidate; |
| if (!ParseCandidate(message, &candidate, error, true)) { |
| return false; |
| } |
| jcandidate->SetCandidate(candidate); |
| return true; |
| } |
| |
| bool SdpDeserializeCandidate(const std::string& transport_name, |
| const std::string& message, |
| cricket::Candidate* candidate, |
| SdpParseError* error) { |
| RTC_DCHECK(candidate != nullptr); |
| if (!ParseCandidate(message, candidate, error, true)) { |
| return false; |
| } |
| candidate->set_transport_name(transport_name); |
| return true; |
| } |
| |
| bool ParseCandidate(const std::string& message, Candidate* candidate, |
| SdpParseError* error, bool is_raw) { |
| RTC_DCHECK(candidate != NULL); |
| |
| // Get the first line from |message|. |
| std::string first_line = message; |
| size_t pos = 0; |
| GetLine(message, &pos, &first_line); |
| |
| // Makes sure |message| contains only one line. |
| if (message.size() > first_line.size()) { |
| std::string left, right; |
| if (rtc::tokenize_first(message, kNewLine, &left, &right) && |
| !right.empty()) { |
| return ParseFailed(message, 0, "Expect one line only", error); |
| } |
| } |
| |
| // From WebRTC draft section 4.8.1.1 candidate-attribute should be |
| // candidate:<candidate> when trickled, but we still support |
| // a=candidate:<blah>CRLF for backward compatibility and for parsing a line |
| // from the SDP. |
| if (IsLineType(first_line, kLineTypeAttributes)) { |
| first_line = first_line.substr(kLinePrefixLength); |
| } |
| |
| std::string attribute_candidate; |
| std::string candidate_value; |
| |
| // |first_line| must be in the form of "candidate:<value>". |
| if (!rtc::tokenize_first(first_line, kSdpDelimiterColon, &attribute_candidate, |
| &candidate_value) || |
| attribute_candidate != kAttributeCandidate) { |
| if (is_raw) { |
| std::ostringstream description; |
| description << "Expect line: " << kAttributeCandidate |
| << ":" << "<candidate-str>"; |
| return ParseFailed(first_line, 0, description.str(), error); |
| } else { |
| return ParseFailedExpectLine(first_line, 0, kLineTypeAttributes, |
| kAttributeCandidate, error); |
| } |
| } |
| |
| std::vector<std::string> fields; |
| rtc::split(candidate_value, kSdpDelimiterSpace, &fields); |
| |
| // RFC 5245 |
| // a=candidate:<foundation> <component-id> <transport> <priority> |
| // <connection-address> <port> typ <candidate-types> |
| // [raddr <connection-address>] [rport <port>] |
| // *(SP extension-att-name SP extension-att-value) |
| const size_t expected_min_fields = 8; |
| if (fields.size() < expected_min_fields || |
| (fields[6] != kAttributeCandidateTyp)) { |
| return ParseFailedExpectMinFieldNum(first_line, expected_min_fields, error); |
| } |
| const std::string& foundation = fields[0]; |
| |
| int component_id = 0; |
| if (!GetValueFromString(first_line, fields[1], &component_id, error)) { |
| return false; |
| } |
| const std::string& transport = fields[2]; |
| uint32_t priority = 0; |
| if (!GetValueFromString(first_line, fields[3], &priority, error)) { |
| return false; |
| } |
| const std::string& connection_address = fields[4]; |
| int port = 0; |
| if (!GetValueFromString(first_line, fields[5], &port, error)) { |
| return false; |
| } |
| if (!IsValidPort(port)) { |
| return ParseFailed(first_line, "Invalid port number.", error); |
| } |
| SocketAddress address(connection_address, port); |
| |
| cricket::ProtocolType protocol; |
| if (!StringToProto(transport.c_str(), &protocol)) { |
| return ParseFailed(first_line, "Unsupported transport type.", error); |
| } |
| switch (protocol) { |
| case cricket::PROTO_UDP: |
| case cricket::PROTO_TCP: |
| case cricket::PROTO_SSLTCP: |
| // Supported protocol. |
| break; |
| default: |
| return ParseFailed(first_line, "Unsupported transport type.", error); |
| } |
| |
| std::string candidate_type; |
| const std::string& type = fields[7]; |
| if (type == kCandidateHost) { |
| candidate_type = cricket::LOCAL_PORT_TYPE; |
| } else if (type == kCandidateSrflx) { |
| candidate_type = cricket::STUN_PORT_TYPE; |
| } else if (type == kCandidateRelay) { |
| candidate_type = cricket::RELAY_PORT_TYPE; |
| } else if (type == kCandidatePrflx) { |
| candidate_type = cricket::PRFLX_PORT_TYPE; |
| } else { |
| return ParseFailed(first_line, "Unsupported candidate type.", error); |
| } |
| |
| size_t current_position = expected_min_fields; |
| SocketAddress related_address; |
| // The 2 optional fields for related address |
| // [raddr <connection-address>] [rport <port>] |
| if (fields.size() >= (current_position + 2) && |
| fields[current_position] == kAttributeCandidateRaddr) { |
| related_address.SetIP(fields[++current_position]); |
| ++current_position; |
| } |
| if (fields.size() >= (current_position + 2) && |
| fields[current_position] == kAttributeCandidateRport) { |
| int port = 0; |
| if (!GetValueFromString( |
| first_line, fields[++current_position], &port, error)) { |
| return false; |
| } |
| if (!IsValidPort(port)) { |
| return ParseFailed(first_line, "Invalid port number.", error); |
| } |
| related_address.SetPort(port); |
| ++current_position; |
| } |
| |
| // If this is a TCP candidate, it has additional extension as defined in |
| // RFC 6544. |
| std::string tcptype; |
| if (fields.size() >= (current_position + 2) && |
| fields[current_position] == kTcpCandidateType) { |
| tcptype = fields[++current_position]; |
| ++current_position; |
| |
| if (tcptype != cricket::TCPTYPE_ACTIVE_STR && |
| tcptype != cricket::TCPTYPE_PASSIVE_STR && |
| tcptype != cricket::TCPTYPE_SIMOPEN_STR) { |
| return ParseFailed(first_line, "Invalid TCP candidate type.", error); |
| } |
| |
| if (protocol != cricket::PROTO_TCP) { |
| return ParseFailed(first_line, "Invalid non-TCP candidate", error); |
| } |
| } |
| |
| // Extension |
| // Though non-standard, we support the ICE ufrag and pwd being signaled on |
| // the candidate to avoid issues with confusing which generation a candidate |
| // belongs to when trickling multiple generations at the same time. |
| std::string username; |
| std::string password; |
| uint32_t generation = 0; |
| uint16_t network_id = 0; |
| uint16_t network_cost = 0; |
| for (size_t i = current_position; i + 1 < fields.size(); ++i) { |
| // RFC 5245 |
| // *(SP extension-att-name SP extension-att-value) |
| if (fields[i] == kAttributeCandidateGeneration) { |
| if (!GetValueFromString(first_line, fields[++i], &generation, error)) { |
| return false; |
| } |
| } else if (fields[i] == kAttributeCandidateUfrag) { |
| username = fields[++i]; |
| } else if (fields[i] == kAttributeCandidatePwd) { |
| password = fields[++i]; |
| } else if (fields[i] == kAttributeCandidateNetworkId) { |
| if (!GetValueFromString(first_line, fields[++i], &network_id, error)) { |
| return false; |
| } |
| } else if (fields[i] == kAttributeCandidateNetworkCost) { |
| if (!GetValueFromString(first_line, fields[++i], &network_cost, error)) { |
| return false; |
| } |
| network_cost = std::min(network_cost, rtc::kNetworkCostMax); |
| } else { |
| // Skip the unknown extension. |
| ++i; |
| } |
| } |
| |
| *candidate = Candidate(component_id, cricket::ProtoToString(protocol), |
| address, priority, username, password, candidate_type, |
| generation, foundation, network_id, network_cost); |
| candidate->set_related_address(related_address); |
| candidate->set_tcptype(tcptype); |
| return true; |
| } |
| |
| bool ParseIceOptions(const std::string& line, |
| std::vector<std::string>* transport_options, |
| SdpParseError* error) { |
| std::string ice_options; |
| if (!GetValue(line, kAttributeIceOption, &ice_options, error)) { |
| return false; |
| } |
| std::vector<std::string> fields; |
| rtc::split(ice_options, kSdpDelimiterSpace, &fields); |
| for (size_t i = 0; i < fields.size(); ++i) { |
| transport_options->push_back(fields[i]); |
| } |
| return true; |
| } |
| |
| bool ParseSctpPort(const std::string& line, |
| int* sctp_port, |
| SdpParseError* error) { |
| // draft-ietf-mmusic-sctp-sdp-07 |
| // a=sctp-port |
| std::vector<std::string> fields; |
| const size_t expected_min_fields = 2; |
| rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterColon, &fields); |
| if (fields.size() < expected_min_fields) { |
| fields.resize(0); |
| rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterSpace, &fields); |
| } |
| if (fields.size() < expected_min_fields) { |
| return ParseFailedExpectMinFieldNum(line, expected_min_fields, error); |
| } |
| if (!rtc::FromString(fields[1], sctp_port)) { |
| return ParseFailed(line, "Invalid sctp port value.", error); |
| } |
| return true; |
| } |
| |
| bool ParseExtmap(const std::string& line, |
| RtpExtension* extmap, |
| SdpParseError* error) { |
| // RFC 5285 |
| // a=extmap:<value>["/"<direction>] <URI> <extensionattributes> |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), |
| kSdpDelimiterSpace, &fields); |
| const size_t expected_min_fields = 2; |
| if (fields.size() < expected_min_fields) { |
| return ParseFailedExpectMinFieldNum(line, expected_min_fields, error); |
| } |
| std::string uri = fields[1]; |
| |
| std::string value_direction; |
| if (!GetValue(fields[0], kAttributeExtmap, &value_direction, error)) { |
| return false; |
| } |
| std::vector<std::string> sub_fields; |
| rtc::split(value_direction, kSdpDelimiterSlash, &sub_fields); |
| int value = 0; |
| if (!GetValueFromString(line, sub_fields[0], &value, error)) { |
| return false; |
| } |
| |
| bool encrypted = false; |
| if (uri == RtpExtension::kEncryptHeaderExtensionsUri) { |
| // RFC 6904 |
| // a=extmap:<value["/"<direction>] urn:ietf:params:rtp-hdrext:encrypt <URI> <extensionattributes> |
| const size_t expected_min_fields_encrypted = expected_min_fields + 1; |
| if (fields.size() < expected_min_fields_encrypted) { |
| return ParseFailedExpectMinFieldNum(line, expected_min_fields_encrypted, |
| error); |
| } |
| |
| encrypted = true; |
| uri = fields[2]; |
| if (uri == RtpExtension::kEncryptHeaderExtensionsUri) { |
| return ParseFailed(line, "Recursive encrypted header.", error); |
| } |
| } |
| |
| *extmap = RtpExtension(uri, value, encrypted); |
| return true; |
| } |
| |
| void BuildMediaDescription(const ContentInfo* content_info, |
| const TransportInfo* transport_info, |
| const MediaType media_type, |
| const std::vector<Candidate>& candidates, |
| bool unified_plan_sdp, |
| std::string* message) { |
| RTC_DCHECK(message != NULL); |
| if (content_info == NULL || message == NULL) { |
| return; |
| } |
| // TODO: Rethink if we should use sprintfn instead of stringstream. |
| // According to the style guide, streams should only be used for logging. |
| // http://google-styleguide.googlecode.com/svn/ |
| // trunk/cppguide.xml?showone=Streams#Streams |
| std::ostringstream os; |
| const MediaContentDescription* media_desc = |
| static_cast<const MediaContentDescription*>( |
| content_info->description); |
| RTC_DCHECK(media_desc != NULL); |
| |
| int sctp_port = cricket::kSctpDefaultPort; |
| |
| // RFC 4566 |
| // m=<media> <port> <proto> <fmt> |
| // fmt is a list of payload type numbers that MAY be used in the session. |
| const char* type = NULL; |
| if (media_type == cricket::MEDIA_TYPE_AUDIO) |
| type = kMediaTypeAudio; |
| else if (media_type == cricket::MEDIA_TYPE_VIDEO) |
| type = kMediaTypeVideo; |
| else if (media_type == cricket::MEDIA_TYPE_DATA) |
| type = kMediaTypeData; |
| else |
| RTC_NOTREACHED(); |
| |
| std::string fmt; |
| if (media_type == cricket::MEDIA_TYPE_VIDEO) { |
| const VideoContentDescription* video_desc = |
| static_cast<const VideoContentDescription*>(media_desc); |
| for (std::vector<cricket::VideoCodec>::const_iterator it = |
| video_desc->codecs().begin(); |
| it != video_desc->codecs().end(); ++it) { |
| fmt.append(" "); |
| fmt.append(rtc::ToString<int>(it->id)); |
| } |
| } else if (media_type == cricket::MEDIA_TYPE_AUDIO) { |
| const AudioContentDescription* audio_desc = |
| static_cast<const AudioContentDescription*>(media_desc); |
| for (std::vector<cricket::AudioCodec>::const_iterator it = |
| audio_desc->codecs().begin(); |
| it != audio_desc->codecs().end(); ++it) { |
| fmt.append(" "); |
| fmt.append(rtc::ToString<int>(it->id)); |
| } |
| } else if (media_type == cricket::MEDIA_TYPE_DATA) { |
| const DataContentDescription* data_desc = |
| static_cast<const DataContentDescription*>(media_desc); |
| if (IsDtlsSctp(media_desc->protocol())) { |
| fmt.append(" "); |
| |
| if (data_desc->use_sctpmap()) { |
| for (std::vector<cricket::DataCodec>::const_iterator it = |
| data_desc->codecs().begin(); |
| it != data_desc->codecs().end(); ++it) { |
| if (cricket::CodecNamesEq(it->name, |
| cricket::kGoogleSctpDataCodecName) && |
| it->GetParam(cricket::kCodecParamPort, &sctp_port)) { |
| break; |
| } |
| } |
| |
| fmt.append(rtc::ToString<int>(sctp_port)); |
| } else { |
| fmt.append(kDefaultSctpmapProtocol); |
| } |
| } else { |
| for (std::vector<cricket::DataCodec>::const_iterator it = |
| data_desc->codecs().begin(); |
| it != data_desc->codecs().end(); ++it) { |
| fmt.append(" "); |
| fmt.append(rtc::ToString<int>(it->id)); |
| } |
| } |
| } |
| // The fmt must never be empty. If no codecs are found, set the fmt attribute |
| // to 0. |
| if (fmt.empty()) { |
| fmt = " 0"; |
| } |
| |
| // The port number in the m line will be updated later when associated with |
| // the candidates. |
| // |
| // A port value of 0 indicates that the m= section is rejected. |
| // RFC 3264 |
| // To reject an offered stream, the port number in the corresponding stream in |
| // the answer MUST be set to zero. |
| // |
| // However, the BUNDLE draft adds a new meaning to port zero, when used along |
| // with a=bundle-only. |
| std::string port = kDummyPort; |
| if (content_info->rejected || content_info->bundle_only) { |
| port = kMediaPortRejected; |
| } else if (!media_desc->connection_address().IsNil()) { |
| port = rtc::ToString(media_desc->connection_address().port()); |
| } |
| |
| rtc::SSLFingerprint* fp = (transport_info) ? |
| transport_info->description.identity_fingerprint.get() : NULL; |
| |
| // Add the m and c lines. |
| InitLine(kLineTypeMedia, type, &os); |
| os << " " << port << " " << media_desc->protocol() << fmt; |
| AddLine(os.str(), message); |
| |
| InitLine(kLineTypeConnection, kConnectionNettype, &os); |
| if (media_desc->connection_address().IsNil()) { |
| os << " " << kConnectionIpv4Addrtype << " " << kDummyAddress; |
| } else if (media_desc->connection_address().family() == AF_INET) { |
| os << " " << kConnectionIpv4Addrtype << " " |
| << media_desc->connection_address().ipaddr().ToString(); |
| } else { |
| os << " " << kConnectionIpv6Addrtype << " " |
| << media_desc->connection_address().ipaddr().ToString(); |
| } |
| AddLine(os.str(), message); |
| |
| // RFC 4566 |
| // b=AS:<bandwidth> |
| if (media_desc->bandwidth() >= 1000) { |
| InitLine(kLineTypeSessionBandwidth, kApplicationSpecificMaximum, &os); |
| os << kSdpDelimiterColon << (media_desc->bandwidth() / 1000); |
| AddLine(os.str(), message); |
| } |
| |
| // Add the a=bundle-only line. |
| if (content_info->bundle_only) { |
| InitAttrLine(kAttributeBundleOnly, &os); |
| AddLine(os.str(), message); |
| } |
| |
| // Add the a=rtcp line. |
| if (IsRtp(media_desc->protocol())) { |
| std::string rtcp_line = GetRtcpLine(candidates); |
| if (!rtcp_line.empty()) { |
| AddLine(rtcp_line, message); |
| } |
| } |
| |
| // Build the a=candidate lines. We don't include ufrag and pwd in the |
| // candidates in the SDP to avoid redundancy. |
| BuildCandidate(candidates, false, message); |
| |
| // Use the transport_info to build the media level ice-ufrag and ice-pwd. |
| if (transport_info) { |
| // RFC 5245 |
| // ice-pwd-att = "ice-pwd" ":" password |
| // ice-ufrag-att = "ice-ufrag" ":" ufrag |
| // ice-ufrag |
| if (!transport_info->description.ice_ufrag.empty()) { |
| InitAttrLine(kAttributeIceUfrag, &os); |
| os << kSdpDelimiterColon << transport_info->description.ice_ufrag; |
| AddLine(os.str(), message); |
| } |
| // ice-pwd |
| if (!transport_info->description.ice_pwd.empty()) { |
| InitAttrLine(kAttributeIcePwd, &os); |
| os << kSdpDelimiterColon << transport_info->description.ice_pwd; |
| AddLine(os.str(), message); |
| } |
| |
| // draft-petithuguenin-mmusic-ice-attributes-level-03 |
| BuildIceOptions(transport_info->description.transport_options, message); |
| |
| // RFC 4572 |
| // fingerprint-attribute = |
| // "fingerprint" ":" hash-func SP fingerprint |
| if (fp) { |
| // Insert the fingerprint attribute. |
| InitAttrLine(kAttributeFingerprint, &os); |
| os << kSdpDelimiterColon |
| << fp->algorithm << kSdpDelimiterSpace |
| << fp->GetRfc4572Fingerprint(); |
| AddLine(os.str(), message); |
| |
| // Inserting setup attribute. |
| if (transport_info->description.connection_role != |
| cricket::CONNECTIONROLE_NONE) { |
| // Making sure we are not using "passive" mode. |
| cricket::ConnectionRole role = |
| transport_info->description.connection_role; |
| std::string dtls_role_str; |
| const bool success = |
| cricket::ConnectionRoleToString(role, &dtls_role_str); |
| RTC_DCHECK(success); |
| InitAttrLine(kAttributeSetup, &os); |
| os << kSdpDelimiterColon << dtls_role_str; |
| AddLine(os.str(), message); |
| } |
| } |
| } |
| |
| // RFC 3388 |
| // mid-attribute = "a=mid:" identification-tag |
| // identification-tag = token |
| // Use the content name as the mid identification-tag. |
| InitAttrLine(kAttributeMid, &os); |
| os << kSdpDelimiterColon << content_info->name; |
| AddLine(os.str(), message); |
| |
| if (IsDtlsSctp(media_desc->protocol())) { |
| const DataContentDescription* data_desc = |
| static_cast<const DataContentDescription*>(media_desc); |
| bool use_sctpmap = data_desc->use_sctpmap(); |
| BuildSctpContentAttributes(message, sctp_port, use_sctpmap); |
| } else if (IsRtp(media_desc->protocol())) { |
| BuildRtpContentAttributes(media_desc, media_type, unified_plan_sdp, |
| message); |
| } |
| } |
| |
| void BuildSctpContentAttributes(std::string* message, |
| int sctp_port, |
| bool use_sctpmap) { |
| std::ostringstream os; |
| if (use_sctpmap) { |
| // draft-ietf-mmusic-sctp-sdp-04 |
| // a=sctpmap:sctpmap-number protocol [streams] |
| InitAttrLine(kAttributeSctpmap, &os); |
| os << kSdpDelimiterColon << sctp_port << kSdpDelimiterSpace |
| << kDefaultSctpmapProtocol << kSdpDelimiterSpace |
| << cricket::kMaxSctpStreams; |
| } else { |
| // draft-ietf-mmusic-sctp-sdp-23 |
| // a=sctp-port:<port> |
| InitAttrLine(kAttributeSctpPort, &os); |
| os << kSdpDelimiterColon << sctp_port; |
| // TODO(zstein): emit max-message-size here |
| } |
| AddLine(os.str(), message); |
| } |
| |
| // If unified_plan_sdp is true, will use "a=msid". |
| void BuildRtpContentAttributes(const MediaContentDescription* media_desc, |
| const MediaType media_type, |
| bool unified_plan_sdp, |
| std::string* message) { |
| std::ostringstream os; |
| // RFC 5285 |
| // a=extmap:<value>["/"<direction>] <URI> <extensionattributes> |
| // The definitions MUST be either all session level or all media level. This |
| // implementation uses all media level. |
| for (size_t i = 0; i < media_desc->rtp_header_extensions().size(); ++i) { |
| const RtpExtension& extension = media_desc->rtp_header_extensions()[i]; |
| InitAttrLine(kAttributeExtmap, &os); |
| os << kSdpDelimiterColon << extension.id; |
| if (extension.encrypt) { |
| os << kSdpDelimiterSpace << RtpExtension::kEncryptHeaderExtensionsUri; |
| } |
| os << kSdpDelimiterSpace << extension.uri; |
| AddLine(os.str(), message); |
| } |
| |
| // RFC 3264 |
| // a=sendrecv || a=sendonly || a=sendrecv || a=inactive |
| switch (media_desc->direction()) { |
| case cricket::MD_INACTIVE: |
| InitAttrLine(kAttributeInactive, &os); |
| break; |
| case cricket::MD_SENDONLY: |
| InitAttrLine(kAttributeSendOnly, &os); |
| break; |
| case cricket::MD_RECVONLY: |
| InitAttrLine(kAttributeRecvOnly, &os); |
| break; |
| case cricket::MD_SENDRECV: |
| default: |
| InitAttrLine(kAttributeSendRecv, &os); |
| break; |
| } |
| AddLine(os.str(), message); |
| |
| // draft-ietf-mmusic-msid-11 |
| // a=msid:<stream id> <track id> |
| if (unified_plan_sdp && !media_desc->streams().empty()) { |
| if (media_desc->streams().size() > 1u) { |
| LOG(LS_WARNING) << "Trying to serialize unified plan SDP with more than " |
| << "one track in a media section. Omitting 'a=msid'."; |
| } else { |
| auto track = media_desc->streams().begin(); |
| const std::string& stream_id = track->sync_label; |
| InitAttrLine(kAttributeMsid, &os); |
| os << kSdpDelimiterColon << stream_id << kSdpDelimiterSpace << track->id; |
| AddLine(os.str(), message); |
| } |
| } |
| |
| // RFC 5761 |
| // a=rtcp-mux |
| if (media_desc->rtcp_mux()) { |
| InitAttrLine(kAttributeRtcpMux, &os); |
| AddLine(os.str(), message); |
| } |
| |
| // RFC 5506 |
| // a=rtcp-rsize |
| if (media_desc->rtcp_reduced_size()) { |
| InitAttrLine(kAttributeRtcpReducedSize, &os); |
| AddLine(os.str(), message); |
| } |
| |
| // RFC 4568 |
| // a=crypto:<tag> <crypto-suite> <key-params> [<session-params>] |
| for (std::vector<CryptoParams>::const_iterator it = |
| media_desc->cryptos().begin(); |
| it != media_desc->cryptos().end(); ++it) { |
| InitAttrLine(kAttributeCrypto, &os); |
| os << kSdpDelimiterColon << it->tag << " " << it->cipher_suite << " " |
| << it->key_params; |
| if (!it->session_params.empty()) { |
| os << " " << it->session_params; |
| } |
| AddLine(os.str(), message); |
| } |
| |
| // RFC 4566 |
| // a=rtpmap:<payload type> <encoding name>/<clock rate> |
| // [/<encodingparameters>] |
| BuildRtpMap(media_desc, media_type, message); |
| |
| for (StreamParamsVec::const_iterator track = media_desc->streams().begin(); |
| track != media_desc->streams().end(); ++track) { |
| // Require that the track belongs to a media stream, |
| // ie the sync_label is set. This extra check is necessary since the |
| // MediaContentDescription always contains a streamparam with an ssrc even |
| // if no track or media stream have been created. |
| if (track->sync_label.empty()) continue; |
| |
| // Build the ssrc-group lines. |
| for (size_t i = 0; i < track->ssrc_groups.size(); ++i) { |
| // RFC 5576 |
| // a=ssrc-group:<semantics> <ssrc-id> ... |
| if (track->ssrc_groups[i].ssrcs.empty()) { |
| continue; |
| } |
| InitAttrLine(kAttributeSsrcGroup, &os); |
| os << kSdpDelimiterColon << track->ssrc_groups[i].semantics; |
| std::vector<uint32_t>::const_iterator ssrc = |
| track->ssrc_groups[i].ssrcs.begin(); |
| for (; ssrc != track->ssrc_groups[i].ssrcs.end(); ++ssrc) { |
| os << kSdpDelimiterSpace << rtc::ToString<uint32_t>(*ssrc); |
| } |
| AddLine(os.str(), message); |
| } |
| // Build the ssrc lines for each ssrc. |
| for (size_t i = 0; i < track->ssrcs.size(); ++i) { |
| uint32_t ssrc = track->ssrcs[i]; |
| // RFC 5576 |
| // a=ssrc:<ssrc-id> cname:<value> |
| AddSsrcLine(ssrc, kSsrcAttributeCname, |
| track->cname, message); |
| |
| // draft-alvestrand-mmusic-msid-00 |
| // a=ssrc:<ssrc-id> msid:identifier [appdata] |
| // The appdata consists of the "id" attribute of a MediaStreamTrack, |
| // which corresponds to the "id" attribute of StreamParams. |
| const std::string& stream_id = track->sync_label; |
| InitAttrLine(kAttributeSsrc, &os); |
| os << kSdpDelimiterColon << ssrc << kSdpDelimiterSpace |
| << kSsrcAttributeMsid << kSdpDelimiterColon << stream_id |
| << kSdpDelimiterSpace << track->id; |
| AddLine(os.str(), message); |
| |
| // TODO(ronghuawu): Remove below code which is for backward |
| // compatibility. |
| // draft-alvestrand-rtcweb-mid-01 |
| // a=ssrc:<ssrc-id> mslabel:<value> |
| // The label isn't yet defined. |
| // a=ssrc:<ssrc-id> label:<value> |
| AddSsrcLine(ssrc, kSsrcAttributeMslabel, track->sync_label, message); |
| AddSsrcLine(ssrc, kSSrcAttributeLabel, track->id, message); |
| } |
| } |
| } |
| |
| void WriteFmtpHeader(int payload_type, std::ostringstream* os) { |
| // fmtp header: a=fmtp:|payload_type| <parameters> |
| // Add a=fmtp |
| InitAttrLine(kAttributeFmtp, os); |
| // Add :|payload_type| |
| *os << kSdpDelimiterColon << payload_type; |
| } |
| |
| void WriteRtcpFbHeader(int payload_type, std::ostringstream* os) { |
| // rtcp-fb header: a=rtcp-fb:|payload_type| |
| // <parameters>/<ccm <ccm_parameters>> |
| // Add a=rtcp-fb |
| InitAttrLine(kAttributeRtcpFb, os); |
| // Add : |
| *os << kSdpDelimiterColon; |
| if (payload_type == kWildcardPayloadType) { |
| *os << "*"; |
| } else { |
| *os << payload_type; |
| } |
| } |
| |
| void WriteFmtpParameter(const std::string& parameter_name, |
| const std::string& parameter_value, |
| std::ostringstream* os) { |
| // fmtp parameters: |parameter_name|=|parameter_value| |
| *os << parameter_name << kSdpDelimiterEqual << parameter_value; |
| } |
| |
| void WriteFmtpParameters(const cricket::CodecParameterMap& parameters, |
| std::ostringstream* os) { |
| for (cricket::CodecParameterMap::const_iterator fmtp = parameters.begin(); |
| fmtp != parameters.end(); ++fmtp) { |
| // Parameters are a semicolon-separated list, no spaces. |
| // The list is separated from the header by a space. |
| if (fmtp == parameters.begin()) { |
| *os << kSdpDelimiterSpace; |
| } else { |
| *os << kSdpDelimiterSemicolon; |
| } |
| WriteFmtpParameter(fmtp->first, fmtp->second, os); |
| } |
| } |
| |
| bool IsFmtpParam(const std::string& name) { |
| // RFC 4855, section 3 specifies the mapping of media format parameters to SDP |
| // parameters. Only ptime, maxptime, channels and rate are placed outside of |
| // the fmtp line. In WebRTC, channels and rate are already handled separately |
| // and thus not included in the CodecParameterMap. |
| return name != kCodecParamPTime && name != kCodecParamMaxPTime; |
| } |
| |
| // Retreives fmtp parameters from |params|, which may contain other parameters |
| // as well, and puts them in |fmtp_parameters|. |
| void GetFmtpParams(const cricket::CodecParameterMap& params, |
| cricket::CodecParameterMap* fmtp_parameters) { |
| for (cricket::CodecParameterMap::const_iterator iter = params.begin(); |
| iter != params.end(); ++iter) { |
| if (IsFmtpParam(iter->first)) { |
| (*fmtp_parameters)[iter->first] = iter->second; |
| } |
| } |
| } |
| |
| template <class T> |
| void AddFmtpLine(const T& codec, std::string* message) { |
| cricket::CodecParameterMap fmtp_parameters; |
| GetFmtpParams(codec.params, &fmtp_parameters); |
| if (fmtp_parameters.empty()) { |
| // No need to add an fmtp if it will have no (optional) parameters. |
| return; |
| } |
| std::ostringstream os; |
| WriteFmtpHeader(codec.id, &os); |
| WriteFmtpParameters(fmtp_parameters, &os); |
| AddLine(os.str(), message); |
| return; |
| } |
| |
| template <class T> |
| void AddRtcpFbLines(const T& codec, std::string* message) { |
| for (std::vector<cricket::FeedbackParam>::const_iterator iter = |
| codec.feedback_params.params().begin(); |
| iter != codec.feedback_params.params().end(); ++iter) { |
| std::ostringstream os; |
| WriteRtcpFbHeader(codec.id, &os); |
| os << " " << iter->id(); |
| if (!iter->param().empty()) { |
| os << " " << iter->param(); |
| } |
| AddLine(os.str(), message); |
| } |
| } |
| |
| bool AddSctpDataCodec(DataContentDescription* media_desc, |
| int sctp_port) { |
| for (const auto& codec : media_desc->codecs()) { |
| if (cricket::CodecNamesEq(codec.name, cricket::kGoogleSctpDataCodecName)) { |
| return ParseFailed("", |
| "Can't have multiple sctp port attributes.", |
| NULL); |
| } |
| } |
| // Add the SCTP Port number as a pseudo-codec "port" parameter |
| cricket::DataCodec codec_port(cricket::kGoogleSctpDataCodecPlType, |
| cricket::kGoogleSctpDataCodecName); |
| codec_port.SetParam(cricket::kCodecParamPort, sctp_port); |
| LOG(INFO) << "AddSctpDataCodec: Got SCTP Port Number " |
| << sctp_port; |
| media_desc->AddCodec(codec_port); |
| return true; |
| } |
| |
| bool GetMinValue(const std::vector<int>& values, int* value) { |
| if (values.empty()) { |
| return false; |
| } |
| std::vector<int>::const_iterator found = |
| std::min_element(values.begin(), values.end()); |
| *value = *found; |
| return true; |
| } |
| |
| bool GetParameter(const std::string& name, |
| const cricket::CodecParameterMap& params, int* value) { |
| std::map<std::string, std::string>::const_iterator found = |
| params.find(name); |
| if (found == params.end()) { |
| return false; |
| } |
| if (!rtc::FromString(found->second, value)) { |
| return false; |
| } |
| return true; |
| } |
| |
| void BuildRtpMap(const MediaContentDescription* media_desc, |
| const MediaType media_type, |
| std::string* message) { |
| RTC_DCHECK(message != NULL); |
| RTC_DCHECK(media_desc != NULL); |
| std::ostringstream os; |
| if (media_type == cricket::MEDIA_TYPE_VIDEO) { |
| const VideoContentDescription* video_desc = |
| static_cast<const VideoContentDescription*>(media_desc); |
| for (std::vector<cricket::VideoCodec>::const_iterator it = |
| video_desc->codecs().begin(); |
| it != video_desc->codecs().end(); ++it) { |
| // RFC 4566 |
| // a=rtpmap:<payload type> <encoding name>/<clock rate> |
| // [/<encodingparameters>] |
| if (it->id != kWildcardPayloadType) { |
| InitAttrLine(kAttributeRtpmap, &os); |
| os << kSdpDelimiterColon << it->id << " " << it->name << "/" |
| << cricket::kVideoCodecClockrate; |
| AddLine(os.str(), message); |
| } |
| AddRtcpFbLines(*it, message); |
| AddFmtpLine(*it, message); |
| } |
| } else if (media_type == cricket::MEDIA_TYPE_AUDIO) { |
| const AudioContentDescription* audio_desc = |
| static_cast<const AudioContentDescription*>(media_desc); |
| std::vector<int> ptimes; |
| std::vector<int> maxptimes; |
| int max_minptime = 0; |
| for (std::vector<cricket::AudioCodec>::const_iterator it = |
| audio_desc->codecs().begin(); |
| it != audio_desc->codecs().end(); ++it) { |
| RTC_DCHECK(!it->name.empty()); |
| // RFC 4566 |
| // a=rtpmap:<payload type> <encoding name>/<clock rate> |
| // [/<encodingparameters>] |
| InitAttrLine(kAttributeRtpmap, &os); |
| os << kSdpDelimiterColon << it->id << " "; |
| os << it->name << "/" << it->clockrate; |
| if (it->channels != 1) { |
| os << "/" << it->channels; |
| } |
| AddLine(os.str(), message); |
| AddRtcpFbLines(*it, message); |
| AddFmtpLine(*it, message); |
| int minptime = 0; |
| if (GetParameter(kCodecParamMinPTime, it->params, &minptime)) { |
| max_minptime = std::max(minptime, max_minptime); |
| } |
| int ptime; |
| if (GetParameter(kCodecParamPTime, it->params, &ptime)) { |
| ptimes.push_back(ptime); |
| } |
| int maxptime; |
| if (GetParameter(kCodecParamMaxPTime, it->params, &maxptime)) { |
| maxptimes.push_back(maxptime); |
| } |
| } |
| // Populate the maxptime attribute with the smallest maxptime of all codecs |
| // under the same m-line. |
| int min_maxptime = INT_MAX; |
| if (GetMinValue(maxptimes, &min_maxptime)) { |
| AddAttributeLine(kCodecParamMaxPTime, min_maxptime, message); |
| } |
| RTC_DCHECK(min_maxptime > max_minptime); |
| // Populate the ptime attribute with the smallest ptime or the largest |
| // minptime, whichever is the largest, for all codecs under the same m-line. |
| int ptime = INT_MAX; |
| if (GetMinValue(ptimes, &ptime)) { |
| ptime = std::min(ptime, min_maxptime); |
| ptime = std::max(ptime, max_minptime); |
| AddAttributeLine(kCodecParamPTime, ptime, message); |
| } |
| } else if (media_type == cricket::MEDIA_TYPE_DATA) { |
| const DataContentDescription* data_desc = |
| static_cast<const DataContentDescription*>(media_desc); |
| for (std::vector<cricket::DataCodec>::const_iterator it = |
| data_desc->codecs().begin(); |
| it != data_desc->codecs().end(); ++it) { |
| // RFC 4566 |
| // a=rtpmap:<payload type> <encoding name>/<clock rate> |
| // [/<encodingparameters>] |
| InitAttrLine(kAttributeRtpmap, &os); |
| os << kSdpDelimiterColon << it->id << " " |
| << it->name << "/" << it->clockrate; |
| AddLine(os.str(), message); |
| } |
| } |
| } |
| |
| void BuildCandidate(const std::vector<Candidate>& candidates, |
| bool include_ufrag, |
| std::string* message) { |
| std::ostringstream os; |
| |
| for (std::vector<Candidate>::const_iterator it = candidates.begin(); |
| it != candidates.end(); ++it) { |
| // RFC 5245 |
| // a=candidate:<foundation> <component-id> <transport> <priority> |
| // <connection-address> <port> typ <candidate-types> |
| // [raddr <connection-address>] [rport <port>] |
| // *(SP extension-att-name SP extension-att-value) |
| std::string type; |
| // Map the cricket candidate type to "host" / "srflx" / "prflx" / "relay" |
| if (it->type() == cricket::LOCAL_PORT_TYPE) { |
| type = kCandidateHost; |
| } else if (it->type() == cricket::STUN_PORT_TYPE) { |
| type = kCandidateSrflx; |
| } else if (it->type() == cricket::RELAY_PORT_TYPE) { |
| type = kCandidateRelay; |
| } else if (it->type() == cricket::PRFLX_PORT_TYPE) { |
| type = kCandidatePrflx; |
| // Peer reflexive candidate may be signaled for being removed. |
| } else { |
| RTC_NOTREACHED(); |
| // Never write out candidates if we don't know the type. |
| continue; |
| } |
| |
| InitAttrLine(kAttributeCandidate, &os); |
| os << kSdpDelimiterColon |
| << it->foundation() << " " |
| << it->component() << " " |
| << it->protocol() << " " |
| << it->priority() << " " |
| << it->address().ipaddr().ToString() << " " |
| << it->address().PortAsString() << " " |
| << kAttributeCandidateTyp << " " |
| << type << " "; |
| |
| // Related address |
| if (!it->related_address().IsNil()) { |
| os << kAttributeCandidateRaddr << " " |
| << it->related_address().ipaddr().ToString() << " " |
| << kAttributeCandidateRport << " " |
| << it->related_address().PortAsString() << " "; |
| } |
| |
| if (it->protocol() == cricket::TCP_PROTOCOL_NAME) { |
| os << kTcpCandidateType << " " << it->tcptype() << " "; |
| } |
| |
| // Extensions |
| os << kAttributeCandidateGeneration << " " << it->generation(); |
| if (include_ufrag && !it->username().empty()) { |
| os << " " << kAttributeCandidateUfrag << " " << it->username(); |
| } |
| if (it->network_id() > 0) { |
| os << " " << kAttributeCandidateNetworkId << " " << it->network_id(); |
| } |
| if (it->network_cost() > 0) { |
| os << " " << kAttributeCandidateNetworkCost << " " << it->network_cost(); |
| } |
| |
| AddLine(os.str(), message); |
| } |
| } |
| |
| void BuildIceOptions(const std::vector<std::string>& transport_options, |
| std::string* message) { |
| if (!transport_options.empty()) { |
| std::ostringstream os; |
| InitAttrLine(kAttributeIceOption, &os); |
| os << kSdpDelimiterColon << transport_options[0]; |
| for (size_t i = 1; i < transport_options.size(); ++i) { |
| os << kSdpDelimiterSpace << transport_options[i]; |
| } |
| AddLine(os.str(), message); |
| } |
| } |
| |
| bool IsRtp(const std::string& protocol) { |
| return protocol.empty() || |
| (protocol.find(cricket::kMediaProtocolRtpPrefix) != std::string::npos); |
| } |
| |
| bool IsDtlsSctp(const std::string& protocol) { |
| // This intentionally excludes "SCTP" and "SCTP/DTLS". |
| return protocol.find(cricket::kMediaProtocolDtlsSctp) != std::string::npos; |
| } |
| |
| bool ParseConnectionData(const std::string& line, |
| rtc::SocketAddress* addr, |
| SdpParseError* error) { |
| // Parse the line from left to right. |
| std::string token; |
| std::string rightpart; |
| // RFC 4566 |
| // c=<nettype> <addrtype> <connection-address> |
| // Skip the "c=" |
| if (!rtc::tokenize_first(line, kSdpDelimiterEqual, &token, &rightpart)) { |
| return ParseFailed(line, "Failed to parse the network type.", error); |
| } |
| |
| // Extract and verify the <nettype> |
| if (!rtc::tokenize_first(rightpart, kSdpDelimiterSpace, &token, &rightpart) || |
| token != kConnectionNettype) { |
| return ParseFailed(line, |
| "Failed to parse the connection data. The network type " |
| "is not currently supported.", |
| error); |
| } |
| |
| // Extract the "<addrtype>" and "<connection-address>". |
| if (!rtc::tokenize_first(rightpart, kSdpDelimiterSpace, &token, &rightpart)) { |
| return ParseFailed(line, "Failed to parse the address type.", error); |
| } |
| |
| // The rightpart part should be the IP address without the slash which is used |
| // for multicast. |
| if (rightpart.find('/') != std::string::npos) { |
| return ParseFailed(line, |
| "Failed to parse the connection data. Multicast is not " |
| "currently supported.", |
| error); |
| } |
| addr->SetIP(rightpart); |
| |
| // Verify that the addrtype matches the type of the parsed address. |
| if ((addr->family() == AF_INET && token != "IP4") || |
| (addr->family() == AF_INET6 && token != "IP6")) { |
| addr->Clear(); |
| return ParseFailed( |
| line, |
| "Failed to parse the connection data. The address type is mismatching.", |
| error); |
| } |
| return true; |
| } |
| |
| bool ParseSessionDescription(const std::string& message, |
| size_t* pos, |
| std::string* session_id, |
| std::string* session_version, |
| TransportDescription* session_td, |
| RtpHeaderExtensions* session_extmaps, |
| rtc::SocketAddress* connection_addr, |
| cricket::SessionDescription* desc, |
| SdpParseError* error) { |
| std::string line; |
| |
| desc->set_msid_supported(false); |
| |
| // RFC 4566 |
| // v= (protocol version) |
| if (!GetLineWithType(message, pos, &line, kLineTypeVersion)) { |
| return ParseFailedExpectLine(message, *pos, kLineTypeVersion, |
| std::string(), error); |
| } |
| // RFC 4566 |
| // o=<username> <sess-id> <sess-version> <nettype> <addrtype> |
| // <unicast-address> |
| if (!GetLineWithType(message, pos, &line, kLineTypeOrigin)) { |
| return ParseFailedExpectLine(message, *pos, kLineTypeOrigin, |
| std::string(), error); |
| } |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), |
| kSdpDelimiterSpace, &fields); |
| const size_t expected_fields = 6; |
| if (fields.size() != expected_fields) { |
| return ParseFailedExpectFieldNum(line, expected_fields, error); |
| } |
| *session_id = fields[1]; |
| *session_version = fields[2]; |
| |
| // RFC 4566 |
| // s= (session name) |
| if (!GetLineWithType(message, pos, &line, kLineTypeSessionName)) { |
| return ParseFailedExpectLine(message, *pos, kLineTypeSessionName, |
| std::string(), error); |
| } |
| |
| // Optional lines |
| // Those are the optional lines, so shouldn't return false if not present. |
| // RFC 4566 |
| // i=* (session information) |
| GetLineWithType(message, pos, &line, kLineTypeSessionInfo); |
| |
| // RFC 4566 |
| // u=* (URI of description) |
| GetLineWithType(message, pos, &line, kLineTypeSessionUri); |
| |
| // RFC 4566 |
| // e=* (email address) |
| GetLineWithType(message, pos, &line, kLineTypeSessionEmail); |
| |
| // RFC 4566 |
| // p=* (phone number) |
| GetLineWithType(message, pos, &line, kLineTypeSessionPhone); |
| |
| // RFC 4566 |
| // c=* (connection information -- not required if included in |
| // all media) |
| if (GetLineWithType(message, pos, &line, kLineTypeConnection)) { |
| if (!ParseConnectionData(line, connection_addr, error)) { |
| return false; |
| } |
| } |
| |
| // RFC 4566 |
| // b=* (zero or more bandwidth information lines) |
| while (GetLineWithType(message, pos, &line, kLineTypeSessionBandwidth)) { |
| // By pass zero or more b lines. |
| } |
| |
| // RFC 4566 |
| // One or more time descriptions ("t=" and "r=" lines; see below) |
| // t= (time the session is active) |
| // r=* (zero or more repeat times) |
| // Ensure there's at least one time description |
| if (!GetLineWithType(message, pos, &line, kLineTypeTiming)) { |
| return ParseFailedExpectLine(message, *pos, kLineTypeTiming, std::string(), |
| error); |
| } |
| |
| while (GetLineWithType(message, pos, &line, kLineTypeRepeatTimes)) { |
| // By pass zero or more r lines. |
| } |
| |
| // Go through the rest of the time descriptions |
| while (GetLineWithType(message, pos, &line, kLineTypeTiming)) { |
| while (GetLineWithType(message, pos, &line, kLineTypeRepeatTimes)) { |
| // By pass zero or more r lines. |
| } |
| } |
| |
| // RFC 4566 |
| // z=* (time zone adjustments) |
| GetLineWithType(message, pos, &line, kLineTypeTimeZone); |
| |
| // RFC 4566 |
| // k=* (encryption key) |
| GetLineWithType(message, pos, &line, kLineTypeEncryptionKey); |
| |
| // RFC 4566 |
| // a=* (zero or more session attribute lines) |
| while (GetLineWithType(message, pos, &line, kLineTypeAttributes)) { |
| if (HasAttribute(line, kAttributeGroup)) { |
| if (!ParseGroupAttribute(line, desc, error)) { |
| return false; |
| } |
| } else if (HasAttribute(line, kAttributeIceUfrag)) { |
| if (!GetValue(line, kAttributeIceUfrag, |
| &(session_td->ice_ufrag), error)) { |
| return false; |
| } |
| } else if (HasAttribute(line, kAttributeIcePwd)) { |
| if (!GetValue(line, kAttributeIcePwd, &(session_td->ice_pwd), error)) { |
| return false; |
| } |
| } else if (HasAttribute(line, kAttributeIceLite)) { |
| session_td->ice_mode = cricket::ICEMODE_LITE; |
| } else if (HasAttribute(line, kAttributeIceOption)) { |
| if (!ParseIceOptions(line, &(session_td->transport_options), error)) { |
| return false; |
| } |
| } else if (HasAttribute(line, kAttributeFingerprint)) { |
| if (session_td->identity_fingerprint.get()) { |
| return ParseFailed( |
| line, |
| "Can't have multiple fingerprint attributes at the same level.", |
| error); |
| } |
| rtc::SSLFingerprint* fingerprint = NULL; |
| if (!ParseFingerprintAttribute(line, &fingerprint, error)) { |
| return false; |
| } |
| session_td->identity_fingerprint.reset(fingerprint); |
| } else if (HasAttribute(line, kAttributeSetup)) { |
| if (!ParseDtlsSetup(line, &(session_td->connection_role), error)) { |
| return false; |
| } |
| } else if (HasAttribute(line, kAttributeMsidSemantics)) { |
| std::string semantics; |
| if (!GetValue(line, kAttributeMsidSemantics, &semantics, error)) { |
| return false; |
| } |
| desc->set_msid_supported( |
| CaseInsensitiveFind(semantics, kMediaStreamSemantic)); |
| } else if (HasAttribute(line, kAttributeExtmap)) { |
| RtpExtension extmap; |
| if (!ParseExtmap(line, &extmap, error)) { |
| return false; |
| } |
| session_extmaps->push_back(extmap); |
| } |
| } |
| |
| return true; |
| } |
| |
| bool ParseGroupAttribute(const std::string& line, |
| cricket::SessionDescription* desc, |
| SdpParseError* error) { |
| RTC_DCHECK(desc != NULL); |
| |
| // RFC 5888 and draft-holmberg-mmusic-sdp-bundle-negotiation-00 |
| // a=group:BUNDLE video voice |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), |
| kSdpDelimiterSpace, &fields); |
| std::string semantics; |
| if (!GetValue(fields[0], kAttributeGroup, &semantics, error)) { |
| return false; |
| } |
| cricket::ContentGroup group(semantics); |
| for (size_t i = 1; i < fields.size(); ++i) { |
| group.AddContentName(fields[i]); |
| } |
| desc->AddGroup(group); |
| return true; |
| } |
| |
| static bool ParseFingerprintAttribute(const std::string& line, |
| rtc::SSLFingerprint** fingerprint, |
| SdpParseError* error) { |
| if (!IsLineType(line, kLineTypeAttributes) || |
| !HasAttribute(line, kAttributeFingerprint)) { |
| return ParseFailedExpectLine(line, 0, kLineTypeAttributes, |
| kAttributeFingerprint, error); |
| } |
| |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), |
| kSdpDelimiterSpace, &fields); |
| const size_t expected_fields = 2; |
| if (fields.size() != expected_fields) { |
| return ParseFailedExpectFieldNum(line, expected_fields, error); |
| } |
| |
| // The first field here is "fingerprint:<hash>. |
| std::string algorithm; |
| if (!GetValue(fields[0], kAttributeFingerprint, &algorithm, error)) { |
| return false; |
| } |
| |
| // Downcase the algorithm. Note that we don't need to downcase the |
| // fingerprint because hex_decode can handle upper-case. |
| std::transform(algorithm.begin(), algorithm.end(), algorithm.begin(), |
| ::tolower); |
| |
| // The second field is the digest value. De-hexify it. |
| *fingerprint = rtc::SSLFingerprint::CreateFromRfc4572( |
| algorithm, fields[1]); |
| if (!*fingerprint) { |
| return ParseFailed(line, |
| "Failed to create fingerprint from the digest.", |
| error); |
| } |
| |
| return true; |
| } |
| |
| static bool ParseDtlsSetup(const std::string& line, |
| cricket::ConnectionRole* role, |
| SdpParseError* error) { |
| // setup-attr = "a=setup:" role |
| // role = "active" / "passive" / "actpass" / "holdconn" |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), kSdpDelimiterColon, &fields); |
| const size_t expected_fields = 2; |
| if (fields.size() != expected_fields) { |
| return ParseFailedExpectFieldNum(line, expected_fields, error); |
| } |
| std::string role_str = fields[1]; |
| if (!cricket::StringToConnectionRole(role_str, role)) { |
| return ParseFailed(line, "Invalid attribute value.", error); |
| } |
| return true; |
| } |
| |
| static bool ParseMsidAttribute(const std::string& line, |
| std::string* stream_id, |
| std::string* track_id, |
| SdpParseError* error) { |
| // draft-ietf-mmusic-msid-11 |
| // a=msid:<stream id> <track id> |
| // msid-value = msid-id [ SP msid-appdata ] |
| // msid-id = 1*64token-char ; see RFC 4566 |
| // msid-appdata = 1*64token-char ; see RFC 4566 |
| std::string field1; |
| if (!rtc::tokenize_first(line.substr(kLinePrefixLength), kSdpDelimiterSpace, |
| &field1, track_id)) { |
| const size_t expected_fields = 2; |
| return ParseFailedExpectFieldNum(line, expected_fields, error); |
| } |
| |
| if (track_id->empty()) { |
| return ParseFailed(line, "Missing track ID in msid attribute.", error); |
| } |
| |
| // msid:<msid-id> |
| if (!GetValue(field1, kAttributeMsid, stream_id, error)) { |
| return false; |
| } |
| if (stream_id->empty()) { |
| return ParseFailed(line, "Missing stream ID in msid attribute.", error); |
| } |
| return true; |
| } |
| |
| // RFC 3551 |
| // PT encoding media type clock rate channels |
| // name (Hz) |
| // 0 PCMU A 8,000 1 |
| // 1 reserved A |
| // 2 reserved A |
| // 3 GSM A 8,000 1 |
| // 4 G723 A 8,000 1 |
| // 5 DVI4 A 8,000 1 |
| // 6 DVI4 A 16,000 1 |
| // 7 LPC A 8,000 1 |
| // 8 PCMA A 8,000 1 |
| // 9 G722 A 8,000 1 |
| // 10 L16 A 44,100 2 |
| // 11 L16 A 44,100 1 |
| // 12 QCELP A 8,000 1 |
| // 13 CN A 8,000 1 |
| // 14 MPA A 90,000 (see text) |
| // 15 G728 A 8,000 1 |
| // 16 DVI4 A 11,025 1 |
| // 17 DVI4 A 22,050 1 |
| // 18 G729 A 8,000 1 |
| struct StaticPayloadAudioCodec { |
| const char* name; |
| int clockrate; |
| size_t channels; |
| }; |
| static const StaticPayloadAudioCodec kStaticPayloadAudioCodecs[] = { |
| { "PCMU", 8000, 1 }, |
| { "reserved", 0, 0 }, |
| { "reserved", 0, 0 }, |
| { "GSM", 8000, 1 }, |
| { "G723", 8000, 1 }, |
| { "DVI4", 8000, 1 }, |
| { "DVI4", 16000, 1 }, |
| { "LPC", 8000, 1 }, |
| { "PCMA", 8000, 1 }, |
| { "G722", 8000, 1 }, |
| { "L16", 44100, 2 }, |
| { "L16", 44100, 1 }, |
| { "QCELP", 8000, 1 }, |
| { "CN", 8000, 1 }, |
| { "MPA", 90000, 1 }, |
| { "G728", 8000, 1 }, |
| { "DVI4", 11025, 1 }, |
| { "DVI4", 22050, 1 }, |
| { "G729", 8000, 1 }, |
| }; |
| |
| void MaybeCreateStaticPayloadAudioCodecs( |
| const std::vector<int>& fmts, AudioContentDescription* media_desc) { |
| if (!media_desc) { |
| return; |
| } |
| RTC_DCHECK(media_desc->codecs().empty()); |
| for (int payload_type : fmts) { |
| if (!media_desc->HasCodec(payload_type) && |
| payload_type >= 0 && |
| static_cast<uint32_t>(payload_type) < |
| arraysize(kStaticPayloadAudioCodecs)) { |
| std::string encoding_name = kStaticPayloadAudioCodecs[payload_type].name; |
| int clock_rate = kStaticPayloadAudioCodecs[payload_type].clockrate; |
| size_t channels = kStaticPayloadAudioCodecs[payload_type].channels; |
| media_desc->AddCodec(cricket::AudioCodec(payload_type, encoding_name, |
| clock_rate, 0, channels)); |
| } |
| } |
| } |
| |
| template <class C> |
| static C* ParseContentDescription(const std::string& message, |
| const MediaType media_type, |
| int mline_index, |
| const std::string& protocol, |
| const std::vector<int>& payload_types, |
| size_t* pos, |
| std::string* content_name, |
| bool* bundle_only, |
| TransportDescription* transport, |
| std::vector<JsepIceCandidate*>* candidates, |
| webrtc::SdpParseError* error) { |
| C* media_desc = new C(); |
| switch (media_type) { |
| case cricket::MEDIA_TYPE_AUDIO: |
| *content_name = cricket::CN_AUDIO; |
| break; |
| case cricket::MEDIA_TYPE_VIDEO: |
| *content_name = cricket::CN_VIDEO; |
| break; |
| case cricket::MEDIA_TYPE_DATA: |
| *content_name = cricket::CN_DATA; |
| break; |
| default: |
| RTC_NOTREACHED(); |
| break; |
| } |
| if (!ParseContent(message, media_type, mline_index, protocol, payload_types, |
| pos, content_name, bundle_only, media_desc, transport, |
| candidates, error)) { |
| delete media_desc; |
| return nullptr; |
| } |
| // Sort the codecs according to the m-line fmt list. |
| std::unordered_map<int, int> payload_type_preferences; |
| // "size + 1" so that the lowest preference payload type has a preference of |
| // 1, which is greater than the default (0) for payload types not in the fmt |
| // list. |
| int preference = static_cast<int>(payload_types.size() + 1); |
| for (int pt : payload_types) { |
| payload_type_preferences[pt] = preference--; |
| } |
| std::vector<typename C::CodecType> codecs = media_desc->codecs(); |
| std::sort(codecs.begin(), codecs.end(), [&payload_type_preferences]( |
| const typename C::CodecType& a, |
| const typename C::CodecType& b) { |
| return payload_type_preferences[a.id] > payload_type_preferences[b.id]; |
| }); |
| media_desc->set_codecs(codecs); |
| return media_desc; |
| } |
| |
| bool ParseMediaDescription(const std::string& message, |
| const TransportDescription& session_td, |
| const RtpHeaderExtensions& session_extmaps, |
| size_t* pos, |
| const rtc::SocketAddress& session_connection_addr, |
| cricket::SessionDescription* desc, |
| std::vector<JsepIceCandidate*>* candidates, |
| SdpParseError* error) { |
| RTC_DCHECK(desc != NULL); |
| std::string line; |
| int mline_index = -1; |
| |
| // Zero or more media descriptions |
| // RFC 4566 |
| // m=<media> <port> <proto> <fmt> |
| while (GetLineWithType(message, pos, &line, kLineTypeMedia)) { |
| ++mline_index; |
| |
| std::vector<std::string> fields; |
| rtc::split(line.substr(kLinePrefixLength), |
| kSdpDelimiterSpace, &fields); |
| |
| const size_t expected_min_fields = 4; |
| if (fields.size() < expected_min_fields) { |
| return ParseFailedExpectMinFieldNum(line, expected_min_fields, error); |
| } |
| bool port_rejected = false; |
| // RFC 3264 |
| // To reject an offered stream, the port number in the corresponding stream |
| // in the answer MUST be set to zero. |
| if (fields[1] == kMediaPortRejected) { |
| port_rejected = true; |
| } |
| |
| int port = 0; |
| if (!rtc::FromString<int>(fields[1], &port) || !IsValidPort(port)) { |
| return ParseFailed(line, "The port number is invalid", error); |
| } |
| std::string protocol = fields[2]; |
| |
| // <fmt> |
| std::vector<int> payload_types; |
| if (IsRtp(protocol)) { |
| for (size_t j = 3 ; j < fields.size(); ++j) { |
| // TODO(wu): Remove when below bug is fixed. |
| // https://bugzilla.mozilla.org/show_bug.cgi?id=996329 |
| if (fields[j].empty() && j == fields.size() - 1) { |
| continue; |
| } |
| |
| int pl = 0; |
| if (!GetPayloadTypeFromString(line, fields[j], &pl, error)) { |
| return false; |
| } |
| payload_types.push_back(pl); |
| } |
| } |
| |
| // Make a temporary TransportDescription based on |session_td|. |
| // Some of this gets overwritten by ParseContent. |
| TransportDescription transport( |
| session_td.transport_options, session_td.ice_ufrag, session_td.ice_pwd, |
| session_td.ice_mode, session_td.connection_role, |
| session_td.identity_fingerprint.get()); |
| |
| std::unique_ptr<MediaContentDescription> content; |
| std::string content_name; |
| bool bundle_only = false; |
| if (HasAttribute(line, kMediaTypeVideo)) { |
| content.reset(ParseContentDescription<VideoContentDescription>( |
| message, cricket::MEDIA_TYPE_VIDEO, mline_index, protocol, |
| payload_types, pos, &content_name, &bundle_only, &transport, |
| candidates, error)); |
| } else if (HasAttribute(line, kMediaTypeAudio)) { |
| content.reset(ParseContentDescription<AudioContentDescription>( |
| message, cricket::MEDIA_TYPE_AUDIO, mline_index, protocol, |
| payload_types, pos, &content_name, &bundle_only, &transport, |
| candidates, error)); |
| } else if (HasAttribute(line, kMediaTypeData)) { |
| DataContentDescription* data_desc = |
| ParseContentDescription<DataContentDescription>( |
| message, cricket::MEDIA_TYPE_DATA, mline_index, protocol, |
| payload_types, pos, &content_name, &bundle_only, &transport, |
| candidates, error); |
| content.reset(data_desc); |
| |
| if (data_desc && IsDtlsSctp(protocol)) { |
| int p; |
| if (rtc::FromString(fields[3], &p)) { |
| if (!AddSctpDataCodec(data_desc, p)) { |
| return false; |
| } |
| } else if (fields[3] == kDefaultSctpmapProtocol) { |
| data_desc->set_use_sctpmap(false); |
| } |
| } |
| } else { |
| LOG(LS_WARNING) << "Unsupported media type: " << line; |
| continue; |
| } |
| if (!content.get()) { |
| // ParseContentDescription returns NULL if failed. |
| return false; |
| } |
| |
| bool content_rejected = false; |
| // A port of 0 is not interpreted as a rejected m= section when it's |
| // used along with a=bundle-only. |
| if (bundle_only) { |
| if (!port_rejected) { |
| // Usage of bundle-only with a nonzero port is unspecified. So just |
| // ignore bundle-only if we see this. |
| bundle_only = false; |
| LOG(LS_WARNING) |
| << "a=bundle-only attribute observed with a nonzero " |
| << "port; this usage is unspecified so the attribute is being " |
| << "ignored."; |
| } |
| } else { |
| // If not using bundle-only, interpret port 0 in the normal way; the m= |
| // section is being rejected. |
| content_rejected = port_rejected; |
| } |
| |
| if (IsRtp(protocol)) { |
| // Set the extmap. |
| if (!session_extmaps.empty() && |
| !content->rtp_header_extensions().empty()) { |
| return ParseFailed("", |
| "The a=extmap MUST be either all session level or " |
| "all media level.", |
| error); |
| } |
| for (size_t i = 0; i < session_extmaps.size(); ++i) { |
| content->AddRtpHeaderExtension(session_extmaps[i]); |
| } |
| } |
| content->set_protocol(protocol); |
| |
| // Use the session level connection address if the media level addresses are |
| // not specified. |
| rtc::SocketAddress address; |
| address = content->connection_address().IsNil() |
| ? session_connection_addr |
| : content->connection_address(); |
| address.SetPort(port); |
| content->set_connection_address(address); |
| |
| desc->AddContent(content_name, |
| IsDtlsSctp(protocol) ? cricket::NS_JINGLE_DRAFT_SCTP |
| : cricket::NS_JINGLE_RTP, |
| content_rejected, bundle_only, content.release()); |
| // Create TransportInfo with the media level "ice-pwd" and "ice-ufrag". |
| TransportInfo transport_info(content_name, transport); |
| |
| if (!desc->AddTransportInfo(transport_info)) { |
| std::ostringstream description; |
| description << "Failed to AddTransportInfo with content name: " |
| << content_name; |
| return ParseFailed("", description.str(), error); |
| } |
| } |
| |
| size_t end_of_message = message.size(); |
| if (mline_index == -1 && *pos != end_of_message) { |
| ParseFailed(message, *pos, "Expects m line.", error); |
| return false; |
| } |
| return true; |
| } |
| |
| bool VerifyCodec(const cricket::Codec& codec) { |
| // Codec has not been populated correctly unless the name has been set. This |
| // can happen if an SDP has an fmtp or rtcp-fb with a payload type but doesn't |
| // have a corresponding "rtpmap" line. |
| return !codec.name.empty(); |
| } |
| |
| bool VerifyAudioCodecs(const AudioContentDescription* audio_desc) { |
| const std::vector<cricket::AudioCodec>& codecs = audio_desc->codecs(); |
| for (std::vector<cricket::AudioCodec>::const_iterator iter = codecs.begin(); |
| iter != codecs.end(); ++iter) { |
| if (!VerifyCodec(*iter)) { |
| return false; |
| } |
| } |
| return true; |
| } |
| |
| bool VerifyVideoCodecs(const VideoContentDescription* video_desc) { |
| const std::vector<cricket::VideoCodec>& codecs = video_desc->codecs(); |
| for (std::vector<cricket::VideoCodec>::const_iterator iter = codecs.begin(); |
| iter != codecs.end(); ++iter) { |
| if (!VerifyCodec(*iter)) { |
| return false; |
| } |
| } |
| return true; |
| } |
| |
| void AddParameters(const cricket::CodecParameterMap& parameters, |
| cricket::Codec* codec) { |
| for (cricket::CodecParameterMap::const_iterator iter = |
| parameters.begin(); iter != parameters.end(); ++iter) { |
| codec->SetParam(iter->first, iter->second); |
| } |
| } |
| |
| void AddFeedbackParameter(const cricket::FeedbackParam& feedback_param, |
| cricket::Codec* codec) { |
| codec->AddFeedbackParam(feedback_param); |
| } |
| |
| void AddFeedbackParameters(const cricket::FeedbackParams& feedback_params, |
| cricket::Codec* codec) { |
| for (std::vector<cricket::FeedbackParam>::const_iterator iter = |
| feedback_params.params().begin(); |
| iter != feedback_params.params().end(); ++iter) { |
| codec->AddFeedbackParam(*iter); |
| } |
| } |
| |
| // Gets the current codec setting associated with |payload_type|. If there |
| // is no Codec associated with that payload type it returns an empty codec |
| // with that payload type. |
| template <class T> |
| T GetCodecWithPayloadType(const std::vector<T>& codecs, int payload_type) { |
| const T* codec = FindCodecById(codecs, payload_type); |
| if (codec) |
| return *codec; |
| // Return empty codec with |payload_type|. |
| T ret_val; |
| ret_val.id = payload_type; |
| return ret_val; |
| } |
| |
| // Updates or creates a new codec entry in the audio description. |
| template <class T, class U> |
| void AddOrReplaceCodec(MediaContentDescription* content_desc, const U& codec) { |
| T* desc = static_cast<T*>(content_desc); |
| std::vector<U> codecs = desc->codecs(); |
| bool found = false; |
| |
| typename std::vector<U>::iterator iter; |
| for (iter = codecs.begin(); iter != codecs.end(); ++iter) { |
| if (iter->id == codec.id) { |
| *iter = codec; |
| found = true; |
| break; |
| } |
| } |
| if (!found) { |
| desc->AddCodec(codec); |
| return; |
| } |
| desc->set_codecs(codecs); |
| } |
| |
| // Adds or updates existing codec corresponding to |payload_type| according |
| // to |parameters|. |
| template <class T, class U> |
| void UpdateCodec(MediaContentDescription* content_desc, int payload_type, |
| const cricket::CodecParameterMap& parameters) { |
| // Codec might already have been populated (from rtpmap). |
| U new_codec = GetCodecWithPayloadType(static_cast<T*>(content_desc)->codecs(), |
| payload_type); |
| AddParameters(parameters, &new_codec); |
| AddOrReplaceCodec<T, U>(content_desc, new_codec); |
| } |
| |
| // Adds or updates existing codec corresponding to |payload_type| according |
| // to |feedback_param|. |
| template <class T, class U> |
| void UpdateCodec(MediaContentDescription* content_desc, int payload_type, |
| const cricket::FeedbackParam& feedback_param) { |
| // Codec might already have been populated (from rtpmap). |
| U new_codec = GetCodecWithPayloadType(static_cast<T*>(content_desc)->codecs(), |
| payload_type); |
| AddFeedbackParameter(feedback_param, &new_codec); |
| AddOrReplaceCodec<T, U>(content_desc, new_codec); |
| } |
| |
| template <class T> |
| bool PopWildcardCodec(std::vector<T>* codecs, T* wildcard_codec) { |
| for (auto iter = codecs->begin(); iter != codecs->end(); ++iter) { |
| if (iter->id == kWildcardPayloadType) { |
| *wildcard_codec = *iter; |
| codecs->erase(iter); |
| return true; |
| } |
| } |
| return false; |
| } |
| |
| template<class T> |
| void UpdateFromWildcardCodecs(cricket::MediaContentDescriptionImpl<T>* desc) { |
| auto codecs = desc->codecs(); |
| T wildcard_codec; |
| if (!PopWildcardCodec(&codecs, &wildcard_codec)) { |
| return; |
| } |
| for (auto& codec : codecs) { |
| AddFeedbackParameters(wildcard_codec.feedback_params, &codec); |
| } |
| desc->set_codecs(codecs); |
| } |
| |
| void AddAudioAttribute(const std::string& name, const std::string& value, |
| AudioContentDescription* audio_desc) { |
| if (value.empty()) { |
| return; |
| } |
| std::vector<cricket::AudioCodec> codecs = audio_desc->codecs(); |
| for (std::vector<cricket::AudioCodec>::iterator iter = codecs.begin(); |
| iter != codecs.end(); ++iter) { |
| iter->params[name] = value; |
| } |
| audio_desc->set_codecs(codecs); |
| } |
| |
| bool ParseContent(const std::string& message, |
| const MediaType media_type, |
| int mline_index, |
| const std::string& protocol, |
| const std::vector<int>& payload_types, |
| size_t* pos, |
| std::string* content_name, |
| bool* bundle_only, |
| MediaContentDescription* media_desc, |
| TransportDescription* transport, |
| std::vector<JsepIceCandidate*>* candidates, |
| SdpParseError* error) { |
| RTC_DCHECK(media_desc != NULL); |
| RTC_DCHECK(content_name != NULL); |
| RTC_DCHECK(transport != NULL); |
| |
| if (media_type == cricket::MEDIA_TYPE_AUDIO) { |
| MaybeCreateStaticPayloadAudioCodecs( |
| payload_types, static_cast<AudioContentDescription*>(media_desc)); |
| } |
| |
| // The media level "ice-ufrag" and "ice-pwd". |
| // The candidates before update the media level "ice-pwd" and "ice-ufrag". |
| Candidates candidates_orig; |
| std::string line; |
| std::string mline_id; |
| // Tracks created out of the ssrc attributes. |
| StreamParamsVec tracks; |
| SsrcInfoVec ssrc_infos; |
| SsrcGroupVec ssrc_groups; |
| std::string maxptime_as_string; |
| std::string ptime_as_string; |
| std::string stream_id; |
| std::string track_id; |
| |
| |