1 /*
2 * Copyright (c) 2017 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 "media/engine/encoder_simulcast_proxy.h"
12
13 #include "api/video_codecs/video_encoder.h"
14 #include "media/engine/simulcast_encoder_adapter.h"
15 #include "modules/video_coding/include/video_error_codes.h"
16
17 namespace webrtc {
18
EncoderSimulcastProxy(VideoEncoderFactory * factory,const SdpVideoFormat & format)19 EncoderSimulcastProxy::EncoderSimulcastProxy(VideoEncoderFactory* factory,
20 const SdpVideoFormat& format)
21 : factory_(factory), video_format_(format), callback_(nullptr) {
22 encoder_ = factory_->CreateVideoEncoder(format);
23 }
24
EncoderSimulcastProxy(VideoEncoderFactory * factory)25 EncoderSimulcastProxy::EncoderSimulcastProxy(VideoEncoderFactory* factory)
26 : EncoderSimulcastProxy(factory, SdpVideoFormat("VP8")) {}
27
~EncoderSimulcastProxy()28 EncoderSimulcastProxy::~EncoderSimulcastProxy() {}
29
Release()30 int EncoderSimulcastProxy::Release() {
31 return encoder_->Release();
32 }
33
SetFecControllerOverride(FecControllerOverride * fec_controller_override)34 void EncoderSimulcastProxy::SetFecControllerOverride(
35 FecControllerOverride* fec_controller_override) {
36 encoder_->SetFecControllerOverride(fec_controller_override);
37 }
38
39 // TODO(eladalon): s/inst/codec_settings/g.
InitEncode(const VideoCodec * inst,const VideoEncoder::Settings & settings)40 int EncoderSimulcastProxy::InitEncode(const VideoCodec* inst,
41 const VideoEncoder::Settings& settings) {
42 int ret = encoder_->InitEncode(inst, settings);
43 if (ret == WEBRTC_VIDEO_CODEC_ERR_SIMULCAST_PARAMETERS_NOT_SUPPORTED) {
44 encoder_.reset(new SimulcastEncoderAdapter(factory_, video_format_));
45 if (callback_) {
46 encoder_->RegisterEncodeCompleteCallback(callback_);
47 }
48 ret = encoder_->InitEncode(inst, settings);
49 }
50 return ret;
51 }
52
Encode(const VideoFrame & input_image,const std::vector<VideoFrameType> * frame_types)53 int EncoderSimulcastProxy::Encode(
54 const VideoFrame& input_image,
55 const std::vector<VideoFrameType>* frame_types) {
56 return encoder_->Encode(input_image, frame_types);
57 }
58
RegisterEncodeCompleteCallback(EncodedImageCallback * callback)59 int EncoderSimulcastProxy::RegisterEncodeCompleteCallback(
60 EncodedImageCallback* callback) {
61 callback_ = callback;
62 return encoder_->RegisterEncodeCompleteCallback(callback);
63 }
64
SetRates(const RateControlParameters & parameters)65 void EncoderSimulcastProxy::SetRates(const RateControlParameters& parameters) {
66 encoder_->SetRates(parameters);
67 }
68
OnPacketLossRateUpdate(float packet_loss_rate)69 void EncoderSimulcastProxy::OnPacketLossRateUpdate(float packet_loss_rate) {
70 encoder_->OnPacketLossRateUpdate(packet_loss_rate);
71 }
72
OnRttUpdate(int64_t rtt_ms)73 void EncoderSimulcastProxy::OnRttUpdate(int64_t rtt_ms) {
74 encoder_->OnRttUpdate(rtt_ms);
75 }
76
OnLossNotification(const LossNotification & loss_notification)77 void EncoderSimulcastProxy::OnLossNotification(
78 const LossNotification& loss_notification) {
79 encoder_->OnLossNotification(loss_notification);
80 }
81
GetEncoderInfo() const82 VideoEncoder::EncoderInfo EncoderSimulcastProxy::GetEncoderInfo() const {
83 return encoder_->GetEncoderInfo();
84 }
85
86 } // namespace webrtc
87