OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 22 matching lines...) Expand all Loading... |
33 RtpUtility::PayloadTypeMap::iterator it = payload_type_map_.begin(); | 33 RtpUtility::PayloadTypeMap::iterator it = payload_type_map_.begin(); |
34 delete it->second; | 34 delete it->second; |
35 payload_type_map_.erase(it); | 35 payload_type_map_.erase(it); |
36 } | 36 } |
37 } | 37 } |
38 | 38 |
39 int32_t RTPPayloadRegistry::RegisterReceivePayload( | 39 int32_t RTPPayloadRegistry::RegisterReceivePayload( |
40 const char payload_name[RTP_PAYLOAD_NAME_SIZE], | 40 const char payload_name[RTP_PAYLOAD_NAME_SIZE], |
41 const int8_t payload_type, | 41 const int8_t payload_type, |
42 const uint32_t frequency, | 42 const uint32_t frequency, |
43 const uint8_t channels, | 43 const size_t channels, |
44 const uint32_t rate, | 44 const uint32_t rate, |
45 bool* created_new_payload) { | 45 bool* created_new_payload) { |
46 assert(payload_type >= 0); | 46 assert(payload_type >= 0); |
47 assert(payload_name); | 47 assert(payload_name); |
48 *created_new_payload = false; | 48 *created_new_payload = false; |
49 | 49 |
50 // Sanity check. | 50 // Sanity check. |
51 switch (payload_type) { | 51 switch (payload_type) { |
52 // Reserved payload types to avoid RTCP conflicts when marker bit is set. | 52 // Reserved payload types to avoid RTCP conflicts when marker bit is set. |
53 case 64: // 192 Full INTRA-frame request. | 53 case 64: // 192 Full INTRA-frame request. |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
132 return 0; | 132 return 0; |
133 } | 133 } |
134 | 134 |
135 // There can't be several codecs with the same rate, frequency and channels | 135 // There can't be several codecs with the same rate, frequency and channels |
136 // for audio codecs, but there can for video. | 136 // for audio codecs, but there can for video. |
137 // Always called from within a critical section. | 137 // Always called from within a critical section. |
138 void RTPPayloadRegistry::DeregisterAudioCodecOrRedTypeRegardlessOfPayloadType( | 138 void RTPPayloadRegistry::DeregisterAudioCodecOrRedTypeRegardlessOfPayloadType( |
139 const char payload_name[RTP_PAYLOAD_NAME_SIZE], | 139 const char payload_name[RTP_PAYLOAD_NAME_SIZE], |
140 const size_t payload_name_length, | 140 const size_t payload_name_length, |
141 const uint32_t frequency, | 141 const uint32_t frequency, |
142 const uint8_t channels, | 142 const size_t channels, |
143 const uint32_t rate) { | 143 const uint32_t rate) { |
144 RtpUtility::PayloadTypeMap::iterator iterator = payload_type_map_.begin(); | 144 RtpUtility::PayloadTypeMap::iterator iterator = payload_type_map_.begin(); |
145 for (; iterator != payload_type_map_.end(); ++iterator) { | 145 for (; iterator != payload_type_map_.end(); ++iterator) { |
146 RtpUtility::Payload* payload = iterator->second; | 146 RtpUtility::Payload* payload = iterator->second; |
147 size_t name_length = strlen(payload->name); | 147 size_t name_length = strlen(payload->name); |
148 | 148 |
149 if (payload_name_length == name_length && | 149 if (payload_name_length == name_length && |
150 RtpUtility::StringCompare( | 150 RtpUtility::StringCompare( |
151 payload->name, payload_name, payload_name_length)) { | 151 payload->name, payload_name, payload_name_length)) { |
152 // We found the payload name in the list. | 152 // We found the payload name in the list. |
(...skipping 11 matching lines...) Expand all Loading... |
164 payload_type_map_.erase(iterator); | 164 payload_type_map_.erase(iterator); |
165 break; | 165 break; |
166 } | 166 } |
167 } | 167 } |
168 } | 168 } |
169 } | 169 } |
170 | 170 |
171 int32_t RTPPayloadRegistry::ReceivePayloadType( | 171 int32_t RTPPayloadRegistry::ReceivePayloadType( |
172 const char payload_name[RTP_PAYLOAD_NAME_SIZE], | 172 const char payload_name[RTP_PAYLOAD_NAME_SIZE], |
173 const uint32_t frequency, | 173 const uint32_t frequency, |
174 const uint8_t channels, | 174 const size_t channels, |
175 const uint32_t rate, | 175 const uint32_t rate, |
176 int8_t* payload_type) const { | 176 int8_t* payload_type) const { |
177 assert(payload_type); | 177 assert(payload_type); |
178 size_t payload_name_length = strlen(payload_name); | 178 size_t payload_name_length = strlen(payload_name); |
179 | 179 |
180 CriticalSectionScoped cs(crit_sect_.get()); | 180 CriticalSectionScoped cs(crit_sect_.get()); |
181 | 181 |
182 RtpUtility::PayloadTypeMap::const_iterator it = payload_type_map_.begin(); | 182 RtpUtility::PayloadTypeMap::const_iterator it = payload_type_map_.begin(); |
183 | 183 |
184 for (; it != payload_type_map_.end(); ++it) { | 184 for (; it != payload_type_map_.end(); ++it) { |
(...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
381 last_received_media_payload_type_ = media_payload_type; | 381 last_received_media_payload_type_ = media_payload_type; |
382 return false; | 382 return false; |
383 } | 383 } |
384 | 384 |
385 class RTPPayloadAudioStrategy : public RTPPayloadStrategy { | 385 class RTPPayloadAudioStrategy : public RTPPayloadStrategy { |
386 public: | 386 public: |
387 bool CodecsMustBeUnique() const override { return true; } | 387 bool CodecsMustBeUnique() const override { return true; } |
388 | 388 |
389 bool PayloadIsCompatible(const RtpUtility::Payload& payload, | 389 bool PayloadIsCompatible(const RtpUtility::Payload& payload, |
390 const uint32_t frequency, | 390 const uint32_t frequency, |
391 const uint8_t channels, | 391 const size_t channels, |
392 const uint32_t rate) const override { | 392 const uint32_t rate) const override { |
393 return | 393 return |
394 payload.audio && | 394 payload.audio && |
395 payload.typeSpecific.Audio.frequency == frequency && | 395 payload.typeSpecific.Audio.frequency == frequency && |
396 payload.typeSpecific.Audio.channels == channels && | 396 payload.typeSpecific.Audio.channels == channels && |
397 (payload.typeSpecific.Audio.rate == rate || | 397 (payload.typeSpecific.Audio.rate == rate || |
398 payload.typeSpecific.Audio.rate == 0 || rate == 0); | 398 payload.typeSpecific.Audio.rate == 0 || rate == 0); |
399 } | 399 } |
400 | 400 |
401 void UpdatePayloadRate(RtpUtility::Payload* payload, | 401 void UpdatePayloadRate(RtpUtility::Payload* payload, |
402 const uint32_t rate) const override { | 402 const uint32_t rate) const override { |
403 payload->typeSpecific.Audio.rate = rate; | 403 payload->typeSpecific.Audio.rate = rate; |
404 } | 404 } |
405 | 405 |
406 RtpUtility::Payload* CreatePayloadType( | 406 RtpUtility::Payload* CreatePayloadType( |
407 const char payloadName[RTP_PAYLOAD_NAME_SIZE], | 407 const char payloadName[RTP_PAYLOAD_NAME_SIZE], |
408 const int8_t payloadType, | 408 const int8_t payloadType, |
409 const uint32_t frequency, | 409 const uint32_t frequency, |
410 const uint8_t channels, | 410 const size_t channels, |
411 const uint32_t rate) const override { | 411 const uint32_t rate) const override { |
412 RtpUtility::Payload* payload = new RtpUtility::Payload; | 412 RtpUtility::Payload* payload = new RtpUtility::Payload; |
413 payload->name[RTP_PAYLOAD_NAME_SIZE - 1] = 0; | 413 payload->name[RTP_PAYLOAD_NAME_SIZE - 1] = 0; |
414 strncpy(payload->name, payloadName, RTP_PAYLOAD_NAME_SIZE - 1); | 414 strncpy(payload->name, payloadName, RTP_PAYLOAD_NAME_SIZE - 1); |
415 assert(frequency >= 1000); | 415 assert(frequency >= 1000); |
416 payload->typeSpecific.Audio.frequency = frequency; | 416 payload->typeSpecific.Audio.frequency = frequency; |
417 payload->typeSpecific.Audio.channels = channels; | 417 payload->typeSpecific.Audio.channels = channels; |
418 payload->typeSpecific.Audio.rate = rate; | 418 payload->typeSpecific.Audio.rate = rate; |
419 payload->audio = true; | 419 payload->audio = true; |
420 return payload; | 420 return payload; |
421 } | 421 } |
422 | 422 |
423 int GetPayloadTypeFrequency(const RtpUtility::Payload& payload) const { | 423 int GetPayloadTypeFrequency(const RtpUtility::Payload& payload) const { |
424 return payload.typeSpecific.Audio.frequency; | 424 return payload.typeSpecific.Audio.frequency; |
425 } | 425 } |
426 }; | 426 }; |
427 | 427 |
428 class RTPPayloadVideoStrategy : public RTPPayloadStrategy { | 428 class RTPPayloadVideoStrategy : public RTPPayloadStrategy { |
429 public: | 429 public: |
430 bool CodecsMustBeUnique() const override { return false; } | 430 bool CodecsMustBeUnique() const override { return false; } |
431 | 431 |
432 bool PayloadIsCompatible(const RtpUtility::Payload& payload, | 432 bool PayloadIsCompatible(const RtpUtility::Payload& payload, |
433 const uint32_t frequency, | 433 const uint32_t frequency, |
434 const uint8_t channels, | 434 const size_t channels, |
435 const uint32_t rate) const override { | 435 const uint32_t rate) const override { |
436 return !payload.audio; | 436 return !payload.audio; |
437 } | 437 } |
438 | 438 |
439 void UpdatePayloadRate(RtpUtility::Payload* payload, | 439 void UpdatePayloadRate(RtpUtility::Payload* payload, |
440 const uint32_t rate) const override { | 440 const uint32_t rate) const override { |
441 payload->typeSpecific.Video.maxRate = rate; | 441 payload->typeSpecific.Video.maxRate = rate; |
442 } | 442 } |
443 | 443 |
444 RtpUtility::Payload* CreatePayloadType( | 444 RtpUtility::Payload* CreatePayloadType( |
445 const char payloadName[RTP_PAYLOAD_NAME_SIZE], | 445 const char payloadName[RTP_PAYLOAD_NAME_SIZE], |
446 const int8_t payloadType, | 446 const int8_t payloadType, |
447 const uint32_t frequency, | 447 const uint32_t frequency, |
448 const uint8_t channels, | 448 const size_t channels, |
449 const uint32_t rate) const override { | 449 const uint32_t rate) const override { |
450 RtpVideoCodecTypes videoType = kRtpVideoGeneric; | 450 RtpVideoCodecTypes videoType = kRtpVideoGeneric; |
451 | 451 |
452 if (RtpUtility::StringCompare(payloadName, "VP8", 3)) { | 452 if (RtpUtility::StringCompare(payloadName, "VP8", 3)) { |
453 videoType = kRtpVideoVp8; | 453 videoType = kRtpVideoVp8; |
454 } else if (RtpUtility::StringCompare(payloadName, "VP9", 3)) { | 454 } else if (RtpUtility::StringCompare(payloadName, "VP9", 3)) { |
455 videoType = kRtpVideoVp9; | 455 videoType = kRtpVideoVp9; |
456 } else if (RtpUtility::StringCompare(payloadName, "H264", 4)) { | 456 } else if (RtpUtility::StringCompare(payloadName, "H264", 4)) { |
457 videoType = kRtpVideoH264; | 457 videoType = kRtpVideoH264; |
458 } else if (RtpUtility::StringCompare(payloadName, "I420", 4)) { | 458 } else if (RtpUtility::StringCompare(payloadName, "I420", 4)) { |
(...skipping 22 matching lines...) Expand all Loading... |
481 RTPPayloadStrategy* RTPPayloadStrategy::CreateStrategy( | 481 RTPPayloadStrategy* RTPPayloadStrategy::CreateStrategy( |
482 const bool handling_audio) { | 482 const bool handling_audio) { |
483 if (handling_audio) { | 483 if (handling_audio) { |
484 return new RTPPayloadAudioStrategy(); | 484 return new RTPPayloadAudioStrategy(); |
485 } else { | 485 } else { |
486 return new RTPPayloadVideoStrategy(); | 486 return new RTPPayloadVideoStrategy(); |
487 } | 487 } |
488 } | 488 } |
489 | 489 |
490 } // namespace webrtc | 490 } // namespace webrtc |
OLD | NEW |