| Index: webrtc/modules/rtp_rtcp/source/rtcp_packet/target_bitrate.cc
|
| diff --git a/webrtc/modules/rtp_rtcp/source/rtcp_packet/target_bitrate.cc b/webrtc/modules/rtp_rtcp/source/rtcp_packet/target_bitrate.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..e3a813a85430ecf0841051e1f13287ae85afe28c
|
| --- /dev/null
|
| +++ b/webrtc/modules/rtp_rtcp/source/rtcp_packet/target_bitrate.cc
|
| @@ -0,0 +1,134 @@
|
| +/*
|
| + * Copyright (c) 2016 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/modules/rtp_rtcp/source/rtcp_packet/target_bitrate.h"
|
| +
|
| +#include "webrtc/base/checks.h"
|
| +#include "webrtc/base/logging.h"
|
| +#include "webrtc/modules/rtp_rtcp/source/byte_io.h"
|
| +
|
| +namespace webrtc {
|
| +namespace rtcp {
|
| +constexpr size_t kTargetBitrateHeaderSizeBytes = 4;
|
| +constexpr uint8_t TargetBitrate::kBlockType;
|
| +const size_t TargetBitrate::kBitrateItemSizeBytes = 4;
|
| +
|
| +TargetBitrate::BitrateItem::BitrateItem()
|
| + : spatial_layer(0), temporal_layer(0), target_bitrate_kbps(0) {}
|
| +
|
| +TargetBitrate::BitrateItem::BitrateItem(uint8_t spatial_layer,
|
| + uint8_t temporal_layer,
|
| + uint32_t target_bitrate_kbps)
|
| + : spatial_layer(spatial_layer),
|
| + temporal_layer(temporal_layer),
|
| + target_bitrate_kbps(target_bitrate_kbps) {}
|
| +
|
| +// RFC 4585: Feedback format.
|
| +//
|
| +// Common packet format:
|
| +//
|
| +// 0 1 2 3
|
| +// 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
|
| +// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
| +// | BT=42 | reserved | block length |
|
| +// +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
|
| +//
|
| +// Target bitrate item (repeat as many times as necessary).
|
| +//
|
| +// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
| +// | S | T | Target Bitrate |
|
| +// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
| +// : ... :
|
| +//
|
| +// Spatial Layer (S): 4 bits
|
| +// Indicates which temporal layer this bitrate concerns.
|
| +//
|
| +// Temporal Layer (T): 4 bits
|
| +// Indicates which temporal layer this bitrate concerns.
|
| +//
|
| +// Target Bitrate: 24 bits
|
| +// The encoder target bitrate for this layer, in kbps.
|
| +//
|
| +// As an example of how S and T are intended to be used, VP8 simulcast will
|
| +// use a separate TargetBitrate message per stream, since they are transmitted
|
| +// on separate SSRCs, with temporal layers grouped by stream.
|
| +// If VP9 SVC is used, there will be only one SSRC, so each spatial and
|
| +// temporal layer combo used shall be specified in the TargetBitrate packet.
|
| +
|
| +TargetBitrate::TargetBitrate() {}
|
| +TargetBitrate::~TargetBitrate() {}
|
| +
|
| +void TargetBitrate::Create(uint8_t* buffer) const {
|
| + buffer[0] = kBlockType;
|
| + buffer[1] = 0; // Reserved.
|
| + const size_t block_length_words = (BlockLength() / 4) - 1;
|
| + ByteWriter<uint16_t>::WriteBigEndian(&buffer[2], block_length_words);
|
| +
|
| + size_t index = kTargetBitrateHeaderSizeBytes;
|
| + for (const BitrateItem& item : bitrates_) {
|
| + buffer[index] = (item.spatial_layer << 4) | item.temporal_layer;
|
| + ByteWriter<uint32_t, 3>::WriteBigEndian(&buffer[index + 1],
|
| + item.target_bitrate_kbps);
|
| + index += kBitrateItemSizeBytes;
|
| + }
|
| +}
|
| +
|
| +bool TargetBitrate::Parse(const uint8_t* block, uint16_t block_length) {
|
| + if (block_length < 1) {
|
| + LOG(LS_WARNING)
|
| + << "Cannot parse TargetBitrate RTCP packet: Too little payload data ("
|
| + << kTargetBitrateHeaderSizeBytes << " bytes needed, got "
|
| + << block_length * 4 << ").";
|
| + return false;
|
| + }
|
| +
|
| + // Validate block header (should already have been parsed and checked).
|
| + RTC_DCHECK_EQ(block[0], kBlockType);
|
| + RTC_DCHECK_EQ(block_length, ByteReader<uint16_t>::ReadBigEndian(&block[2]));
|
| +
|
| + // Header specifies block length - 1, but since we ignore the header, which
|
| + // occupies exactly on block, we can just treat this as payload length.
|
| + const size_t payload_bytes = block_length * 4;
|
| + const size_t num_items = payload_bytes / kBitrateItemSizeBytes;
|
| + size_t index = kTargetBitrateHeaderSizeBytes;
|
| + bitrates_.clear();
|
| + for (size_t i = 0; i < num_items; ++i) {
|
| + uint8_t layers = block[index];
|
| + uint32_t bitrate_kbps =
|
| + ByteReader<uint32_t, 3>::ReadBigEndian(&block[index + 1]);
|
| + index += kBitrateItemSizeBytes;
|
| + AddTargetBitrate((layers >> 4) & 0x0F, layers & 0x0F, bitrate_kbps);
|
| + }
|
| +
|
| + return true;
|
| +}
|
| +
|
| +void TargetBitrate::AddTargetBitrate(uint8_t spatial_layer,
|
| + uint8_t temporal_layer,
|
| + uint32_t target_bitrate_kbps) {
|
| + RTC_DCHECK_LE(spatial_layer, 0x0F);
|
| + RTC_DCHECK_LE(temporal_layer, 0x0F);
|
| + RTC_DCHECK_LE(target_bitrate_kbps, 0x00FFFFFFU);
|
| + bitrates_.push_back(
|
| + BitrateItem(spatial_layer, temporal_layer, target_bitrate_kbps));
|
| +}
|
| +
|
| +const std::vector<TargetBitrate::BitrateItem>&
|
| +TargetBitrate::GetTargetBitrates() const {
|
| + return bitrates_;
|
| +}
|
| +
|
| +size_t TargetBitrate::BlockLength() const {
|
| + return kTargetBitrateHeaderSizeBytes +
|
| + bitrates_.size() * kBitrateItemSizeBytes;
|
| +}
|
| +
|
| +} // namespace rtcp
|
| +} // namespace webrtc
|
|
|