mirror of
https://github.com/mollyim/webrtc.git
synced 2025-05-13 05:40:42 +01:00
2874672671
Bug: webrtc:8064 Change-Id: I2a6ed11bf1415e4e0d199733f9d9a659afec0fe8 Reviewed-on: https://webrtc-review.googlesource.com/c/116689 Reviewed-by: Erik Språng <sprang@webrtc.org> Commit-Queue: Niels Moller <nisse@webrtc.org> Cr-Commit-Position: refs/heads/master@{#26194}
128 lines
4.3 KiB
C++
128 lines
4.3 KiB
C++
/*
|
|
* 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 "modules/video_coding/video_coding_impl.h"
|
|
|
|
#include <algorithm>
|
|
#include <memory>
|
|
|
|
#include "api/video/encoded_image.h"
|
|
#include "common_types.h" // NOLINT(build/include)
|
|
#include "modules/video_coding/include/video_codec_interface.h"
|
|
#include "modules/video_coding/timing.h"
|
|
#include "rtc_base/criticalsection.h"
|
|
#include "rtc_base/thread_checker.h"
|
|
#include "system_wrappers/include/clock.h"
|
|
|
|
namespace webrtc {
|
|
namespace vcm {
|
|
|
|
int64_t VCMProcessTimer::Period() const {
|
|
return _periodMs;
|
|
}
|
|
|
|
int64_t VCMProcessTimer::TimeUntilProcess() const {
|
|
const int64_t time_since_process = _clock->TimeInMilliseconds() - _latestMs;
|
|
const int64_t time_until_process = _periodMs - time_since_process;
|
|
return std::max<int64_t>(time_until_process, 0);
|
|
}
|
|
|
|
void VCMProcessTimer::Processed() {
|
|
_latestMs = _clock->TimeInMilliseconds();
|
|
}
|
|
} // namespace vcm
|
|
|
|
namespace {
|
|
|
|
class VideoCodingModuleImpl : public VideoCodingModule {
|
|
public:
|
|
VideoCodingModuleImpl(Clock* clock,
|
|
NackSender* nack_sender,
|
|
KeyFrameRequestSender* keyframe_request_sender)
|
|
: VideoCodingModule(),
|
|
timing_(new VCMTiming(clock)),
|
|
receiver_(clock, timing_.get(), nack_sender, keyframe_request_sender) {}
|
|
|
|
virtual ~VideoCodingModuleImpl() {}
|
|
|
|
int64_t TimeUntilNextProcess() override {
|
|
int64_t receiver_time = receiver_.TimeUntilNextProcess();
|
|
RTC_DCHECK_GE(receiver_time, 0);
|
|
return receiver_time;
|
|
}
|
|
|
|
void Process() override { receiver_.Process(); }
|
|
|
|
int32_t RegisterReceiveCodec(const VideoCodec* receiveCodec,
|
|
int32_t numberOfCores,
|
|
bool requireKeyFrame) override {
|
|
return receiver_.RegisterReceiveCodec(receiveCodec, numberOfCores,
|
|
requireKeyFrame);
|
|
}
|
|
|
|
void RegisterExternalDecoder(VideoDecoder* externalDecoder,
|
|
uint8_t payloadType) override {
|
|
receiver_.RegisterExternalDecoder(externalDecoder, payloadType);
|
|
}
|
|
|
|
int32_t RegisterReceiveCallback(
|
|
VCMReceiveCallback* receiveCallback) override {
|
|
RTC_DCHECK(construction_thread_.CalledOnValidThread());
|
|
return receiver_.RegisterReceiveCallback(receiveCallback);
|
|
}
|
|
|
|
int32_t RegisterFrameTypeCallback(
|
|
VCMFrameTypeCallback* frameTypeCallback) override {
|
|
return receiver_.RegisterFrameTypeCallback(frameTypeCallback);
|
|
}
|
|
|
|
int32_t RegisterPacketRequestCallback(
|
|
VCMPacketRequestCallback* callback) override {
|
|
RTC_DCHECK(construction_thread_.CalledOnValidThread());
|
|
return receiver_.RegisterPacketRequestCallback(callback);
|
|
}
|
|
|
|
int32_t Decode(uint16_t maxWaitTimeMs) override {
|
|
return receiver_.Decode(maxWaitTimeMs);
|
|
}
|
|
|
|
int32_t IncomingPacket(const uint8_t* incomingPayload,
|
|
size_t payloadLength,
|
|
const WebRtcRTPHeader& rtpInfo) override {
|
|
return receiver_.IncomingPacket(incomingPayload, payloadLength, rtpInfo);
|
|
}
|
|
|
|
int SetReceiverRobustnessMode(ReceiverRobustness robustnessMode,
|
|
VCMDecodeErrorMode errorMode) override {
|
|
return receiver_.SetReceiverRobustnessMode(robustnessMode, errorMode);
|
|
}
|
|
|
|
void SetNackSettings(size_t max_nack_list_size,
|
|
int max_packet_age_to_nack,
|
|
int max_incomplete_time_ms) override {
|
|
return receiver_.SetNackSettings(max_nack_list_size, max_packet_age_to_nack,
|
|
max_incomplete_time_ms);
|
|
}
|
|
|
|
private:
|
|
rtc::ThreadChecker construction_thread_;
|
|
const std::unique_ptr<VCMTiming> timing_;
|
|
vcm::VideoReceiver receiver_;
|
|
};
|
|
} // namespace
|
|
|
|
// DEPRECATED. Create method for current interface, will be removed when the
|
|
// new jitter buffer is in place.
|
|
VideoCodingModule* VideoCodingModule::Create(Clock* clock) {
|
|
RTC_DCHECK(clock);
|
|
return new VideoCodingModuleImpl(clock, nullptr, nullptr);
|
|
}
|
|
|
|
} // namespace webrtc
|