| Index: webrtc/video/vie_encoder.cc
|
| diff --git a/webrtc/video/vie_encoder.cc b/webrtc/video/vie_encoder.cc
|
| deleted file mode 100644
|
| index 803825c909e25f5af2dc96eff8d51882a2d0654c..0000000000000000000000000000000000000000
|
| --- a/webrtc/video/vie_encoder.cc
|
| +++ /dev/null
|
| @@ -1,628 +0,0 @@
|
| -/*
|
| - * Copyright (c) 2012 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/video/vie_encoder.h"
|
| -
|
| -#include <assert.h>
|
| -
|
| -#include <algorithm>
|
| -
|
| -#include "webrtc/base/checks.h"
|
| -#include "webrtc/base/logging.h"
|
| -#include "webrtc/base/trace_event.h"
|
| -#include "webrtc/call/bitrate_allocator.h"
|
| -#include "webrtc/common_video/include/video_image.h"
|
| -#include "webrtc/common_video/libyuv/include/webrtc_libyuv.h"
|
| -#include "webrtc/frame_callback.h"
|
| -#include "webrtc/modules/bitrate_controller/include/bitrate_controller.h"
|
| -#include "webrtc/modules/pacing/paced_sender.h"
|
| -#include "webrtc/modules/utility/include/process_thread.h"
|
| -#include "webrtc/modules/video_coding/include/video_codec_interface.h"
|
| -#include "webrtc/modules/video_coding/include/video_coding.h"
|
| -#include "webrtc/modules/video_coding/include/video_coding_defines.h"
|
| -#include "webrtc/modules/video_coding/encoded_frame.h"
|
| -#include "webrtc/system_wrappers/include/clock.h"
|
| -#include "webrtc/system_wrappers/include/critical_section_wrapper.h"
|
| -#include "webrtc/system_wrappers/include/metrics.h"
|
| -#include "webrtc/system_wrappers/include/tick_util.h"
|
| -#include "webrtc/video/payload_router.h"
|
| -#include "webrtc/video/send_statistics_proxy.h"
|
| -
|
| -namespace webrtc {
|
| -
|
| -// Margin on when we pause the encoder when the pacing buffer overflows relative
|
| -// to the configured buffer delay.
|
| -static const float kEncoderPausePacerMargin = 2.0f;
|
| -
|
| -// Don't stop the encoder unless the delay is above this configured value.
|
| -static const int kMinPacingDelayMs = 200;
|
| -
|
| -static const float kStopPaddingThresholdMs = 2000;
|
| -
|
| -static const int kMinKeyFrameRequestIntervalMs = 300;
|
| -
|
| -std::vector<uint32_t> AllocateStreamBitrates(
|
| - uint32_t total_bitrate,
|
| - const SimulcastStream* stream_configs,
|
| - size_t number_of_streams) {
|
| - if (number_of_streams == 0) {
|
| - std::vector<uint32_t> stream_bitrates(1, 0);
|
| - stream_bitrates[0] = total_bitrate;
|
| - return stream_bitrates;
|
| - }
|
| - std::vector<uint32_t> stream_bitrates(number_of_streams, 0);
|
| - uint32_t bitrate_remainder = total_bitrate;
|
| - for (size_t i = 0; i < stream_bitrates.size() && bitrate_remainder > 0; ++i) {
|
| - if (stream_configs[i].maxBitrate * 1000 > bitrate_remainder) {
|
| - stream_bitrates[i] = bitrate_remainder;
|
| - } else {
|
| - stream_bitrates[i] = stream_configs[i].maxBitrate * 1000;
|
| - }
|
| - bitrate_remainder -= stream_bitrates[i];
|
| - }
|
| - return stream_bitrates;
|
| -}
|
| -
|
| -class QMVideoSettingsCallback : public VCMQMSettingsCallback {
|
| - public:
|
| - explicit QMVideoSettingsCallback(VideoProcessing* vpm);
|
| -
|
| - ~QMVideoSettingsCallback();
|
| -
|
| - // Update VPM with QM (quality modes: frame size & frame rate) settings.
|
| - int32_t SetVideoQMSettings(const uint32_t frame_rate,
|
| - const uint32_t width,
|
| - const uint32_t height);
|
| -
|
| - // Update target frame rate.
|
| - void SetTargetFramerate(int frame_rate);
|
| -
|
| - private:
|
| - VideoProcessing* vp_;
|
| -};
|
| -
|
| -class ViEBitrateObserver : public BitrateObserver {
|
| - public:
|
| - explicit ViEBitrateObserver(ViEEncoder* owner)
|
| - : owner_(owner) {
|
| - }
|
| - virtual ~ViEBitrateObserver() {}
|
| - // Implements BitrateObserver.
|
| - virtual void OnNetworkChanged(uint32_t bitrate_bps,
|
| - uint8_t fraction_lost,
|
| - int64_t rtt) {
|
| - owner_->OnNetworkChanged(bitrate_bps, fraction_lost, rtt);
|
| - }
|
| - private:
|
| - ViEEncoder* owner_;
|
| -};
|
| -
|
| -ViEEncoder::ViEEncoder(uint32_t number_of_cores,
|
| - ProcessThread* module_process_thread,
|
| - SendStatisticsProxy* stats_proxy,
|
| - I420FrameCallback* pre_encode_callback,
|
| - PacedSender* pacer,
|
| - BitrateAllocator* bitrate_allocator)
|
| - : number_of_cores_(number_of_cores),
|
| - vp_(VideoProcessing::Create()),
|
| - qm_callback_(new QMVideoSettingsCallback(vp_.get())),
|
| - vcm_(VideoCodingModule::Create(Clock::GetRealTimeClock(),
|
| - this,
|
| - qm_callback_.get())),
|
| - send_payload_router_(NULL),
|
| - data_cs_(CriticalSectionWrapper::CreateCriticalSection()),
|
| - stats_proxy_(stats_proxy),
|
| - pre_encode_callback_(pre_encode_callback),
|
| - pacer_(pacer),
|
| - bitrate_allocator_(bitrate_allocator),
|
| - time_of_last_frame_activity_ms_(0),
|
| - encoder_config_(),
|
| - min_transmit_bitrate_kbps_(0),
|
| - last_observed_bitrate_bps_(0),
|
| - target_delay_ms_(0),
|
| - network_is_transmitting_(true),
|
| - encoder_paused_(false),
|
| - encoder_paused_and_dropped_frame_(false),
|
| - module_process_thread_(module_process_thread),
|
| - has_received_sli_(false),
|
| - picture_id_sli_(0),
|
| - has_received_rpsi_(false),
|
| - picture_id_rpsi_(0),
|
| - video_suspended_(false) {
|
| - bitrate_observer_.reset(new ViEBitrateObserver(this));
|
| -}
|
| -
|
| -bool ViEEncoder::Init() {
|
| - vp_->EnableTemporalDecimation(true);
|
| -
|
| - // Enable/disable content analysis: off by default for now.
|
| - vp_->EnableContentAnalysis(false);
|
| -
|
| - if (vcm_->RegisterTransportCallback(this) != 0) {
|
| - return false;
|
| - }
|
| - if (vcm_->RegisterSendStatisticsCallback(this) != 0) {
|
| - return false;
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -void ViEEncoder::StartThreadsAndSetSharedMembers(
|
| - rtc::scoped_refptr<PayloadRouter> send_payload_router,
|
| - VCMProtectionCallback* vcm_protection_callback) {
|
| - RTC_DCHECK(send_payload_router_ == NULL);
|
| -
|
| - send_payload_router_ = send_payload_router;
|
| - vcm_->RegisterProtectionCallback(vcm_protection_callback);
|
| - module_process_thread_->RegisterModule(vcm_.get());
|
| -}
|
| -
|
| -void ViEEncoder::StopThreadsAndRemoveSharedMembers() {
|
| - if (bitrate_allocator_)
|
| - bitrate_allocator_->RemoveBitrateObserver(bitrate_observer_.get());
|
| - module_process_thread_->DeRegisterModule(vcm_.get());
|
| -}
|
| -
|
| -ViEEncoder::~ViEEncoder() {
|
| -}
|
| -
|
| -void ViEEncoder::SetNetworkTransmissionState(bool is_transmitting) {
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - network_is_transmitting_ = is_transmitting;
|
| - }
|
| -}
|
| -
|
| -void ViEEncoder::Pause() {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - encoder_paused_ = true;
|
| -}
|
| -
|
| -void ViEEncoder::Restart() {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - encoder_paused_ = false;
|
| -}
|
| -
|
| -int32_t ViEEncoder::RegisterExternalEncoder(webrtc::VideoEncoder* encoder,
|
| - uint8_t pl_type,
|
| - bool internal_source) {
|
| - if (vcm_->RegisterExternalEncoder(encoder, pl_type, internal_source) !=
|
| - VCM_OK) {
|
| - return -1;
|
| - }
|
| - return 0;
|
| -}
|
| -
|
| -int32_t ViEEncoder::DeRegisterExternalEncoder(uint8_t pl_type) {
|
| - if (vcm_->RegisterExternalEncoder(NULL, pl_type) != VCM_OK) {
|
| - return -1;
|
| - }
|
| - return 0;
|
| -}
|
| -
|
| -int32_t ViEEncoder::SetEncoder(const webrtc::VideoCodec& video_codec) {
|
| - RTC_DCHECK(send_payload_router_ != NULL);
|
| - // Setting target width and height for VPM.
|
| - if (vp_->SetTargetResolution(video_codec.width, video_codec.height,
|
| - video_codec.maxFramerate) != VPM_OK) {
|
| - return -1;
|
| - }
|
| -
|
| - // Cache codec before calling AddBitrateObserver (which calls OnNetworkChanged
|
| - // that makes use of the number of simulcast streams configured).
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - encoder_config_ = video_codec;
|
| - }
|
| -
|
| - // Add a bitrate observer to the allocator and update the start, max and
|
| - // min bitrates of the bitrate controller as needed.
|
| - int allocated_bitrate_bps = bitrate_allocator_->AddBitrateObserver(
|
| - bitrate_observer_.get(), video_codec.minBitrate * 1000,
|
| - video_codec.maxBitrate * 1000);
|
| -
|
| - webrtc::VideoCodec modified_video_codec = video_codec;
|
| - modified_video_codec.startBitrate = allocated_bitrate_bps / 1000;
|
| -
|
| - size_t max_data_payload_length = send_payload_router_->MaxPayloadLength();
|
| - if (vcm_->RegisterSendCodec(&modified_video_codec, number_of_cores_,
|
| - static_cast<uint32_t>(max_data_payload_length)) !=
|
| - VCM_OK) {
|
| - return -1;
|
| - }
|
| - return 0;
|
| -}
|
| -
|
| -int ViEEncoder::GetPaddingNeededBps() const {
|
| - int64_t time_of_last_frame_activity_ms;
|
| - int min_transmit_bitrate_bps;
|
| - int bitrate_bps;
|
| - VideoCodec send_codec;
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - bool send_padding = encoder_config_.numberOfSimulcastStreams > 1 ||
|
| - video_suspended_ || min_transmit_bitrate_kbps_ > 0;
|
| - if (!send_padding)
|
| - return 0;
|
| - time_of_last_frame_activity_ms = time_of_last_frame_activity_ms_;
|
| - min_transmit_bitrate_bps = 1000 * min_transmit_bitrate_kbps_;
|
| - bitrate_bps = last_observed_bitrate_bps_;
|
| - send_codec = encoder_config_;
|
| - }
|
| -
|
| - bool video_is_suspended = vcm_->VideoSuspended();
|
| -
|
| - // Find the max amount of padding we can allow ourselves to send at this
|
| - // point, based on which streams are currently active and what our current
|
| - // available bandwidth is.
|
| - int pad_up_to_bitrate_bps = 0;
|
| - if (send_codec.numberOfSimulcastStreams == 0) {
|
| - pad_up_to_bitrate_bps = send_codec.minBitrate * 1000;
|
| - } else {
|
| - SimulcastStream* stream_configs = send_codec.simulcastStream;
|
| - pad_up_to_bitrate_bps =
|
| - stream_configs[send_codec.numberOfSimulcastStreams - 1].minBitrate *
|
| - 1000;
|
| - for (int i = 0; i < send_codec.numberOfSimulcastStreams - 1; ++i) {
|
| - pad_up_to_bitrate_bps += stream_configs[i].targetBitrate * 1000;
|
| - }
|
| - }
|
| -
|
| - // Disable padding if only sending one stream and video isn't suspended and
|
| - // min-transmit bitrate isn't used (applied later).
|
| - if (!video_is_suspended && send_codec.numberOfSimulcastStreams <= 1)
|
| - pad_up_to_bitrate_bps = 0;
|
| -
|
| - // The amount of padding should decay to zero if no frames are being
|
| - // captured/encoded unless a min-transmit bitrate is used.
|
| - int64_t now_ms = TickTime::MillisecondTimestamp();
|
| - if (now_ms - time_of_last_frame_activity_ms > kStopPaddingThresholdMs)
|
| - pad_up_to_bitrate_bps = 0;
|
| -
|
| - // Pad up to min bitrate.
|
| - if (pad_up_to_bitrate_bps < min_transmit_bitrate_bps)
|
| - pad_up_to_bitrate_bps = min_transmit_bitrate_bps;
|
| -
|
| - // Padding may never exceed bitrate estimate.
|
| - if (pad_up_to_bitrate_bps > bitrate_bps)
|
| - pad_up_to_bitrate_bps = bitrate_bps;
|
| -
|
| - return pad_up_to_bitrate_bps;
|
| -}
|
| -
|
| -bool ViEEncoder::EncoderPaused() const {
|
| - // Pause video if paused by caller or as long as the network is down or the
|
| - // pacer queue has grown too large in buffered mode.
|
| - if (encoder_paused_) {
|
| - return true;
|
| - }
|
| - if (target_delay_ms_ > 0) {
|
| - // Buffered mode.
|
| - // TODO(pwestin): Workaround until nack is configured as a time and not
|
| - // number of packets.
|
| - return pacer_->QueueInMs() >=
|
| - std::max(
|
| - static_cast<int>(target_delay_ms_ * kEncoderPausePacerMargin),
|
| - kMinPacingDelayMs);
|
| - }
|
| - if (pacer_->ExpectedQueueTimeMs() > PacedSender::kMaxQueueLengthMs) {
|
| - // Too much data in pacer queue, drop frame.
|
| - return true;
|
| - }
|
| - return !network_is_transmitting_;
|
| -}
|
| -
|
| -void ViEEncoder::TraceFrameDropStart() {
|
| - // Start trace event only on the first frame after encoder is paused.
|
| - if (!encoder_paused_and_dropped_frame_) {
|
| - TRACE_EVENT_ASYNC_BEGIN0("webrtc", "EncoderPaused", this);
|
| - }
|
| - encoder_paused_and_dropped_frame_ = true;
|
| - return;
|
| -}
|
| -
|
| -void ViEEncoder::TraceFrameDropEnd() {
|
| - // End trace event on first frame after encoder resumes, if frame was dropped.
|
| - if (encoder_paused_and_dropped_frame_) {
|
| - TRACE_EVENT_ASYNC_END0("webrtc", "EncoderPaused", this);
|
| - }
|
| - encoder_paused_and_dropped_frame_ = false;
|
| -}
|
| -
|
| -void ViEEncoder::DeliverFrame(VideoFrame video_frame) {
|
| - RTC_DCHECK(send_payload_router_ != NULL);
|
| - if (!send_payload_router_->active()) {
|
| - // We've paused or we have no channels attached, don't waste resources on
|
| - // encoding.
|
| - return;
|
| - }
|
| - VideoCodecType codec_type;
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - time_of_last_frame_activity_ms_ = TickTime::MillisecondTimestamp();
|
| - if (EncoderPaused()) {
|
| - TraceFrameDropStart();
|
| - return;
|
| - }
|
| - TraceFrameDropEnd();
|
| - codec_type = encoder_config_.codecType;
|
| - }
|
| -
|
| - TRACE_EVENT_ASYNC_STEP0("webrtc", "Video", video_frame.render_time_ms(),
|
| - "Encode");
|
| - const VideoFrame* frame_to_send = &video_frame;
|
| - // TODO(wuchengli): support texture frames.
|
| - if (video_frame.native_handle() == NULL) {
|
| - // Pass frame via preprocessor.
|
| - frame_to_send = vp_->PreprocessFrame(video_frame);
|
| - if (!frame_to_send) {
|
| - // Drop this frame, or there was an error processing it.
|
| - return;
|
| - }
|
| - }
|
| -
|
| - // If we haven't resampled the frame and we have a FrameCallback, we need to
|
| - // make a deep copy of |video_frame|.
|
| - VideoFrame copied_frame;
|
| - if (pre_encode_callback_) {
|
| - copied_frame.CopyFrame(*frame_to_send);
|
| - pre_encode_callback_->FrameCallback(&copied_frame);
|
| - frame_to_send = &copied_frame;
|
| - }
|
| -
|
| - if (codec_type == webrtc::kVideoCodecVP8) {
|
| - webrtc::CodecSpecificInfo codec_specific_info;
|
| - codec_specific_info.codecType = webrtc::kVideoCodecVP8;
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - codec_specific_info.codecSpecific.VP8.hasReceivedRPSI =
|
| - has_received_rpsi_;
|
| - codec_specific_info.codecSpecific.VP8.hasReceivedSLI =
|
| - has_received_sli_;
|
| - codec_specific_info.codecSpecific.VP8.pictureIdRPSI =
|
| - picture_id_rpsi_;
|
| - codec_specific_info.codecSpecific.VP8.pictureIdSLI =
|
| - picture_id_sli_;
|
| - has_received_sli_ = false;
|
| - has_received_rpsi_ = false;
|
| - }
|
| -
|
| - vcm_->AddVideoFrame(*frame_to_send, vp_->GetContentMetrics(),
|
| - &codec_specific_info);
|
| - return;
|
| - }
|
| - vcm_->AddVideoFrame(*frame_to_send);
|
| -}
|
| -
|
| -int ViEEncoder::SendKeyFrame() {
|
| - return vcm_->IntraFrameRequest(0);
|
| -}
|
| -
|
| -uint32_t ViEEncoder::LastObservedBitrateBps() const {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - return last_observed_bitrate_bps_;
|
| -}
|
| -
|
| -int ViEEncoder::CodecTargetBitrate(uint32_t* bitrate) const {
|
| - if (vcm_->Bitrate(bitrate) != 0)
|
| - return -1;
|
| - return 0;
|
| -}
|
| -
|
| -void ViEEncoder::SetProtectionMethod(bool nack, bool fec) {
|
| - // Set Video Protection for VCM.
|
| - VCMVideoProtection protection_mode;
|
| - if (fec) {
|
| - protection_mode =
|
| - nack ? webrtc::kProtectionNackFEC : kProtectionFEC;
|
| - } else {
|
| - protection_mode = nack ? kProtectionNack : kProtectionNone;
|
| - }
|
| - vcm_->SetVideoProtection(protection_mode, true);
|
| -}
|
| -
|
| -void ViEEncoder::SetSenderBufferingMode(int target_delay_ms) {
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - target_delay_ms_ = target_delay_ms;
|
| - }
|
| - if (target_delay_ms > 0) {
|
| - // Disable external frame-droppers.
|
| - vcm_->EnableFrameDropper(false);
|
| - vp_->EnableTemporalDecimation(false);
|
| - } else {
|
| - // Real-time mode - enable frame droppers.
|
| - vp_->EnableTemporalDecimation(true);
|
| - vcm_->EnableFrameDropper(true);
|
| - }
|
| -}
|
| -
|
| -void ViEEncoder::OnSetRates(uint32_t bitrate_bps, int framerate) {
|
| - if (stats_proxy_)
|
| - stats_proxy_->OnSetRates(bitrate_bps, framerate);
|
| -}
|
| -
|
| -int32_t ViEEncoder::SendData(
|
| - const uint8_t payload_type,
|
| - const EncodedImage& encoded_image,
|
| - const webrtc::RTPFragmentationHeader& fragmentation_header,
|
| - const RTPVideoHeader* rtp_video_hdr) {
|
| - RTC_DCHECK(send_payload_router_ != NULL);
|
| -
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - time_of_last_frame_activity_ms_ = TickTime::MillisecondTimestamp();
|
| - }
|
| -
|
| - if (stats_proxy_ != NULL)
|
| - stats_proxy_->OnSendEncodedImage(encoded_image, rtp_video_hdr);
|
| -
|
| - return send_payload_router_->RoutePayload(
|
| - encoded_image._frameType, payload_type, encoded_image._timeStamp,
|
| - encoded_image.capture_time_ms_, encoded_image._buffer,
|
| - encoded_image._length, &fragmentation_header, rtp_video_hdr)
|
| - ? 0
|
| - : -1;
|
| -}
|
| -
|
| -int32_t ViEEncoder::SendStatistics(const uint32_t bit_rate,
|
| - const uint32_t frame_rate) {
|
| - if (stats_proxy_)
|
| - stats_proxy_->OnOutgoingRate(frame_rate, bit_rate);
|
| - return 0;
|
| -}
|
| -
|
| -void ViEEncoder::OnReceivedSLI(uint32_t /*ssrc*/,
|
| - uint8_t picture_id) {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - picture_id_sli_ = picture_id;
|
| - has_received_sli_ = true;
|
| -}
|
| -
|
| -void ViEEncoder::OnReceivedRPSI(uint32_t /*ssrc*/,
|
| - uint64_t picture_id) {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - picture_id_rpsi_ = picture_id;
|
| - has_received_rpsi_ = true;
|
| -}
|
| -
|
| -void ViEEncoder::OnReceivedIntraFrameRequest(uint32_t ssrc) {
|
| - // Key frame request from remote side, signal to VCM.
|
| - TRACE_EVENT0("webrtc", "OnKeyFrameRequest");
|
| -
|
| - int idx = 0;
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - auto stream_it = ssrc_streams_.find(ssrc);
|
| - if (stream_it == ssrc_streams_.end()) {
|
| - LOG_F(LS_WARNING) << "ssrc not found: " << ssrc << ", map size "
|
| - << ssrc_streams_.size();
|
| - return;
|
| - }
|
| - std::map<unsigned int, int64_t>::iterator time_it =
|
| - time_last_intra_request_ms_.find(ssrc);
|
| - if (time_it == time_last_intra_request_ms_.end()) {
|
| - time_last_intra_request_ms_[ssrc] = 0;
|
| - }
|
| -
|
| - int64_t now = TickTime::MillisecondTimestamp();
|
| - if (time_last_intra_request_ms_[ssrc] + kMinKeyFrameRequestIntervalMs
|
| - > now) {
|
| - return;
|
| - }
|
| - time_last_intra_request_ms_[ssrc] = now;
|
| - idx = stream_it->second;
|
| - }
|
| - // Release the critsect before triggering key frame.
|
| - vcm_->IntraFrameRequest(idx);
|
| -}
|
| -
|
| -void ViEEncoder::OnLocalSsrcChanged(uint32_t old_ssrc, uint32_t new_ssrc) {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - std::map<unsigned int, int>::iterator it = ssrc_streams_.find(old_ssrc);
|
| - if (it == ssrc_streams_.end()) {
|
| - return;
|
| - }
|
| -
|
| - ssrc_streams_[new_ssrc] = it->second;
|
| - ssrc_streams_.erase(it);
|
| -
|
| - std::map<unsigned int, int64_t>::iterator time_it =
|
| - time_last_intra_request_ms_.find(old_ssrc);
|
| - int64_t last_intra_request_ms = 0;
|
| - if (time_it != time_last_intra_request_ms_.end()) {
|
| - last_intra_request_ms = time_it->second;
|
| - time_last_intra_request_ms_.erase(time_it);
|
| - }
|
| - time_last_intra_request_ms_[new_ssrc] = last_intra_request_ms;
|
| -}
|
| -
|
| -void ViEEncoder::SetSsrcs(const std::vector<uint32_t>& ssrcs) {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - ssrc_streams_.clear();
|
| - time_last_intra_request_ms_.clear();
|
| - int idx = 0;
|
| - for (uint32_t ssrc : ssrcs) {
|
| - ssrc_streams_[ssrc] = idx++;
|
| - }
|
| -}
|
| -
|
| -void ViEEncoder::SetMinTransmitBitrate(int min_transmit_bitrate_kbps) {
|
| - assert(min_transmit_bitrate_kbps >= 0);
|
| - CriticalSectionScoped crit(data_cs_.get());
|
| - min_transmit_bitrate_kbps_ = min_transmit_bitrate_kbps;
|
| -}
|
| -
|
| -// Called from ViEBitrateObserver.
|
| -void ViEEncoder::OnNetworkChanged(uint32_t bitrate_bps,
|
| - uint8_t fraction_lost,
|
| - int64_t round_trip_time_ms) {
|
| - LOG(LS_VERBOSE) << "OnNetworkChanged, bitrate" << bitrate_bps
|
| - << " packet loss " << static_cast<int>(fraction_lost)
|
| - << " rtt " << round_trip_time_ms;
|
| - RTC_DCHECK(send_payload_router_ != NULL);
|
| - vcm_->SetChannelParameters(bitrate_bps, fraction_lost, round_trip_time_ms);
|
| - bool video_is_suspended = vcm_->VideoSuspended();
|
| - bool video_suspension_changed;
|
| - VideoCodec send_codec;
|
| - uint32_t first_ssrc;
|
| - {
|
| - CriticalSectionScoped cs(data_cs_.get());
|
| - last_observed_bitrate_bps_ = bitrate_bps;
|
| - video_suspension_changed = video_suspended_ != video_is_suspended;
|
| - video_suspended_ = video_is_suspended;
|
| - send_codec = encoder_config_;
|
| - first_ssrc = ssrc_streams_.begin()->first;
|
| - }
|
| -
|
| - SimulcastStream* stream_configs = send_codec.simulcastStream;
|
| - // Allocate the bandwidth between the streams.
|
| - std::vector<uint32_t> stream_bitrates = AllocateStreamBitrates(
|
| - bitrate_bps, stream_configs, send_codec.numberOfSimulcastStreams);
|
| - send_payload_router_->SetTargetSendBitrates(stream_bitrates);
|
| -
|
| - if (!video_suspension_changed)
|
| - return;
|
| - // Video suspend-state changed, inform codec observer.
|
| - LOG(LS_INFO) << "Video suspend state changed " << video_is_suspended
|
| - << " for ssrc " << first_ssrc;
|
| - if (stats_proxy_)
|
| - stats_proxy_->OnSuspendChange(video_is_suspended);
|
| -}
|
| -
|
| -void ViEEncoder::SuspendBelowMinBitrate() {
|
| - vcm_->SuspendBelowMinBitrate();
|
| - bitrate_allocator_->EnforceMinBitrate(false);
|
| -}
|
| -
|
| -void ViEEncoder::RegisterPostEncodeImageCallback(
|
| - EncodedImageCallback* post_encode_callback) {
|
| - vcm_->RegisterPostEncodeImageCallback(post_encode_callback);
|
| -}
|
| -
|
| -QMVideoSettingsCallback::QMVideoSettingsCallback(VideoProcessing* vpm)
|
| - : vp_(vpm) {
|
| -}
|
| -
|
| -QMVideoSettingsCallback::~QMVideoSettingsCallback() {
|
| -}
|
| -
|
| -int32_t QMVideoSettingsCallback::SetVideoQMSettings(
|
| - const uint32_t frame_rate,
|
| - const uint32_t width,
|
| - const uint32_t height) {
|
| - return vp_->SetTargetResolution(width, height, frame_rate);
|
| -}
|
| -
|
| -void QMVideoSettingsCallback::SetTargetFramerate(int frame_rate) {
|
| - vp_->SetTargetFramerate(frame_rate);
|
| -}
|
| -
|
| -} // namespace webrtc
|
|
|