kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
| 3 | * |
| 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 |
| 6 | * tree. An additional intellectual property rights grant can be found |
| 7 | * in the file PATENTS. All contributing project authors may |
| 8 | * be found in the AUTHORS file in the root of the source tree. |
| 9 | */ |
| 10 | |
| 11 | #include "webrtc/common_types.h" |
| 12 | |
| 13 | #include <string.h> |
danilchap | ef8d773 | 2017-04-19 09:59:48 | [diff] [blame^] | 14 | #include <limits> |
| 15 | #include <type_traits> |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 16 | |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 17 | #include "webrtc/base/checks.h" |
| 18 | #include "webrtc/base/stringutils.h" |
| 19 | |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 20 | namespace webrtc { |
| 21 | |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 22 | StreamDataCounters::StreamDataCounters() : first_packet_time_ms(-1) {} |
| 23 | |
danilchap | ef8d773 | 2017-04-19 09:59:48 | [diff] [blame^] | 24 | constexpr size_t StreamId::kMaxSize; |
| 25 | |
| 26 | void StreamId::Set(const char* data, size_t size) { |
| 27 | // If |data| contains \0, the stream id size might become less than |size|. |
| 28 | RTC_DCHECK_LE(size, kMaxSize); |
| 29 | memcpy(value_, data, size); |
| 30 | if (size < kMaxSize) |
| 31 | value_[size] = 0; |
| 32 | } |
| 33 | |
| 34 | // StreamId is used as member of RTPHeader that is sometimes copied with memcpy |
| 35 | // and thus assume trivial destructibility. |
| 36 | static_assert(std::is_trivially_destructible<StreamId>::value, ""); |
| 37 | |
sprang@webrtc.org | 3093390 | 2015-03-17 14:33:12 | [diff] [blame] | 38 | RTPHeaderExtension::RTPHeaderExtension() |
| 39 | : hasTransmissionTimeOffset(false), |
| 40 | transmissionTimeOffset(0), |
| 41 | hasAbsoluteSendTime(false), |
| 42 | absoluteSendTime(0), |
| 43 | hasTransportSequenceNumber(false), |
| 44 | transportSequenceNumber(0), |
| 45 | hasAudioLevel(false), |
Minyue | 4cee419 | 2015-08-10 13:08:36 | [diff] [blame] | 46 | voiceActivity(false), |
sprang@webrtc.org | 3093390 | 2015-03-17 14:33:12 | [diff] [blame] | 47 | audioLevel(0), |
| 48 | hasVideoRotation(false), |
ilnik | 00d802b | 2017-04-11 17:34:31 | [diff] [blame] | 49 | videoRotation(kVideoRotation_0), |
| 50 | hasVideoContentType(false), |
| 51 | videoContentType(VideoContentType::UNSPECIFIED) {} |
sprang@webrtc.org | 3093390 | 2015-03-17 14:33:12 | [diff] [blame] | 52 | |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 53 | RTPHeader::RTPHeader() |
| 54 | : markerBit(false), |
| 55 | payloadType(0), |
| 56 | sequenceNumber(0), |
| 57 | timestamp(0), |
| 58 | ssrc(0), |
| 59 | numCSRCs(0), |
tommi | a6219cc | 2016-06-15 17:30:14 | [diff] [blame] | 60 | arrOfCSRCs(), |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 61 | paddingLength(0), |
| 62 | headerLength(0), |
| 63 | payload_type_frequency(0), |
tommi | a6219cc | 2016-06-15 17:30:14 | [diff] [blame] | 64 | extension() {} |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 65 | |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 66 | VideoCodec::VideoCodec() |
| 67 | : codecType(kVideoCodecUnknown), |
| 68 | plName(), |
| 69 | plType(0), |
| 70 | width(0), |
| 71 | height(0), |
| 72 | startBitrate(0), |
| 73 | maxBitrate(0), |
| 74 | minBitrate(0), |
| 75 | targetBitrate(0), |
| 76 | maxFramerate(0), |
| 77 | qpMax(0), |
| 78 | numberOfSimulcastStreams(0), |
| 79 | simulcastStream(), |
| 80 | spatialLayers(), |
| 81 | mode(kRealtimeVideo), |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 82 | expect_encode_from_texture(false), |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 83 | codec_specific_() {} |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 84 | |
| 85 | VideoCodecVP8* VideoCodec::VP8() { |
| 86 | RTC_DCHECK_EQ(codecType, kVideoCodecVP8); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 87 | return &codec_specific_.VP8; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 88 | } |
| 89 | |
| 90 | const VideoCodecVP8& VideoCodec::VP8() const { |
| 91 | RTC_DCHECK_EQ(codecType, kVideoCodecVP8); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 92 | return codec_specific_.VP8; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 93 | } |
| 94 | |
| 95 | VideoCodecVP9* VideoCodec::VP9() { |
| 96 | RTC_DCHECK_EQ(codecType, kVideoCodecVP9); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 97 | return &codec_specific_.VP9; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 98 | } |
| 99 | |
| 100 | const VideoCodecVP9& VideoCodec::VP9() const { |
| 101 | RTC_DCHECK_EQ(codecType, kVideoCodecVP9); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 102 | return codec_specific_.VP9; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 103 | } |
| 104 | |
| 105 | VideoCodecH264* VideoCodec::H264() { |
| 106 | RTC_DCHECK_EQ(codecType, kVideoCodecH264); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 107 | return &codec_specific_.H264; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 108 | } |
| 109 | |
| 110 | const VideoCodecH264& VideoCodec::H264() const { |
| 111 | RTC_DCHECK_EQ(codecType, kVideoCodecH264); |
hta | 527d347 | 2016-11-17 07:23:04 | [diff] [blame] | 112 | return codec_specific_.H264; |
hta | 257dc39 | 2016-10-25 16:05:06 | [diff] [blame] | 113 | } |
| 114 | |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 115 | static const char* kPayloadNameVp8 = "VP8"; |
| 116 | static const char* kPayloadNameVp9 = "VP9"; |
| 117 | static const char* kPayloadNameH264 = "H264"; |
| 118 | static const char* kPayloadNameI420 = "I420"; |
| 119 | static const char* kPayloadNameRED = "RED"; |
| 120 | static const char* kPayloadNameULPFEC = "ULPFEC"; |
| 121 | static const char* kPayloadNameGeneric = "Generic"; |
| 122 | |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 123 | static bool CodecNamesEq(const char* name1, const char* name2) { |
| 124 | return _stricmp(name1, name2) == 0; |
| 125 | } |
| 126 | |
| 127 | rtc::Optional<const char*> CodecTypeToPayloadName(VideoCodecType type) { |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 128 | switch (type) { |
| 129 | case kVideoCodecVP8: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 130 | return rtc::Optional<const char*>(kPayloadNameVp8); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 131 | case kVideoCodecVP9: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 132 | return rtc::Optional<const char*>(kPayloadNameVp9); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 133 | case kVideoCodecH264: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 134 | return rtc::Optional<const char*>(kPayloadNameH264); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 135 | case kVideoCodecI420: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 136 | return rtc::Optional<const char*>(kPayloadNameI420); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 137 | case kVideoCodecRED: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 138 | return rtc::Optional<const char*>(kPayloadNameRED); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 139 | case kVideoCodecULPFEC: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 140 | return rtc::Optional<const char*>(kPayloadNameULPFEC); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 141 | case kVideoCodecGeneric: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 142 | return rtc::Optional<const char*>(kPayloadNameGeneric); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 143 | default: |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 144 | return rtc::Optional<const char*>(); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 145 | } |
| 146 | } |
| 147 | |
| 148 | rtc::Optional<VideoCodecType> PayloadNameToCodecType(const std::string& name) { |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 149 | if (CodecNamesEq(name.c_str(), kPayloadNameVp8)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 150 | return rtc::Optional<VideoCodecType>(kVideoCodecVP8); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 151 | if (CodecNamesEq(name.c_str(), kPayloadNameVp9)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 152 | return rtc::Optional<VideoCodecType>(kVideoCodecVP9); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 153 | if (CodecNamesEq(name.c_str(), kPayloadNameH264)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 154 | return rtc::Optional<VideoCodecType>(kVideoCodecH264); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 155 | if (CodecNamesEq(name.c_str(), kPayloadNameI420)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 156 | return rtc::Optional<VideoCodecType>(kVideoCodecI420); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 157 | if (CodecNamesEq(name.c_str(), kPayloadNameRED)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 158 | return rtc::Optional<VideoCodecType>(kVideoCodecRED); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 159 | if (CodecNamesEq(name.c_str(), kPayloadNameULPFEC)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 160 | return rtc::Optional<VideoCodecType>(kVideoCodecULPFEC); |
magjed | 10165ab | 2016-11-22 18:16:57 | [diff] [blame] | 161 | if (CodecNamesEq(name.c_str(), kPayloadNameGeneric)) |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 162 | return rtc::Optional<VideoCodecType>(kVideoCodecGeneric); |
| 163 | return rtc::Optional<VideoCodecType>(); |
| 164 | } |
| 165 | |
| 166 | const uint32_t BitrateAllocation::kMaxBitrateBps = |
| 167 | std::numeric_limits<uint32_t>::max(); |
| 168 | |
| 169 | BitrateAllocation::BitrateAllocation() : sum_(0), bitrates_{} {} |
| 170 | |
| 171 | bool BitrateAllocation::SetBitrate(size_t spatial_index, |
| 172 | size_t temporal_index, |
| 173 | uint32_t bitrate_bps) { |
sprang | 6d314c7 | 2016-12-06 14:08:53 | [diff] [blame] | 174 | RTC_CHECK_LT(spatial_index, kMaxSpatialLayers); |
| 175 | RTC_CHECK_LT(temporal_index, kMaxTemporalStreams); |
| 176 | RTC_CHECK_LE(bitrates_[spatial_index][temporal_index], sum_); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 177 | uint64_t new_bitrate_sum_bps = sum_; |
| 178 | new_bitrate_sum_bps -= bitrates_[spatial_index][temporal_index]; |
| 179 | new_bitrate_sum_bps += bitrate_bps; |
| 180 | if (new_bitrate_sum_bps > kMaxBitrateBps) |
| 181 | return false; |
| 182 | |
| 183 | bitrates_[spatial_index][temporal_index] = bitrate_bps; |
| 184 | sum_ = static_cast<uint32_t>(new_bitrate_sum_bps); |
| 185 | return true; |
| 186 | } |
| 187 | |
| 188 | uint32_t BitrateAllocation::GetBitrate(size_t spatial_index, |
| 189 | size_t temporal_index) const { |
sprang | 6d314c7 | 2016-12-06 14:08:53 | [diff] [blame] | 190 | RTC_CHECK_LT(spatial_index, kMaxSpatialLayers); |
| 191 | RTC_CHECK_LT(temporal_index, kMaxTemporalStreams); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 192 | return bitrates_[spatial_index][temporal_index]; |
| 193 | } |
| 194 | |
| 195 | // Get the sum of all the temporal layer for a specific spatial layer. |
| 196 | uint32_t BitrateAllocation::GetSpatialLayerSum(size_t spatial_index) const { |
sprang | 6d314c7 | 2016-12-06 14:08:53 | [diff] [blame] | 197 | RTC_CHECK_LT(spatial_index, kMaxSpatialLayers); |
Erik Språng | 08127a9 | 2016-11-16 15:41:30 | [diff] [blame] | 198 | uint32_t sum = 0; |
| 199 | for (int i = 0; i < kMaxTemporalStreams; ++i) |
| 200 | sum += bitrates_[spatial_index][i]; |
| 201 | return sum; |
| 202 | } |
| 203 | |
kwiberg@webrtc.org | ac2d27d | 2015-02-26 13:59:22 | [diff] [blame] | 204 | } // namespace webrtc |