blob: c8b12e747ff6c8c979a2d0599b3608e12f679e33 [file] [log] [blame]
/*
* 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 "common_video/include/incoming_video_stream.h"
#include <memory>
#include <utility>
#include "absl/types/optional.h"
#include "common_video/video_render_frames.h"
#include "rtc_base/checks.h"
#include "rtc_base/trace_event.h"
namespace webrtc {
namespace {
const char kIncomingQueueName[] = "IncomingVideoStream";
}
// Capture by moving (std::move) into a lambda isn't possible in C++11
// (supported in C++14). This class provides the functionality of what would be
// something like (inside OnFrame):
// VideoFrame frame(video_frame);
// incoming_render_queue_.PostTask([this, frame = std::move(frame)](){
// if (render_buffers_.AddFrame(std::move(frame)) == 1)
// Dequeue();
// });
class IncomingVideoStream::NewFrameTask : public rtc::QueuedTask {
public:
NewFrameTask(IncomingVideoStream* stream, VideoFrame frame)
: stream_(stream), frame_(std::move(frame)) {}
private:
bool Run() override {
RTC_DCHECK(stream_->incoming_render_queue_.IsCurrent());
if (stream_->render_buffers_.AddFrame(std::move(frame_)) == 1)
stream_->Dequeue();
return true;
}
IncomingVideoStream* stream_;
VideoFrame frame_;
};
IncomingVideoStream::IncomingVideoStream(
int32_t delay_ms,
rtc::VideoSinkInterface<VideoFrame>* callback)
: render_buffers_(delay_ms),
callback_(callback),
incoming_render_queue_(kIncomingQueueName,
rtc::TaskQueue::Priority::HIGH) {}
IncomingVideoStream::~IncomingVideoStream() {
RTC_DCHECK(main_thread_checker_.CalledOnValidThread());
}
void IncomingVideoStream::OnFrame(const VideoFrame& video_frame) {
TRACE_EVENT0("webrtc", "IncomingVideoStream::OnFrame");
RTC_CHECK_RUNS_SERIALIZED(&decoder_race_checker_);
RTC_DCHECK(!incoming_render_queue_.IsCurrent());
incoming_render_queue_.PostTask(
std::unique_ptr<rtc::QueuedTask>(new NewFrameTask(this, video_frame)));
}
void IncomingVideoStream::Dequeue() {
TRACE_EVENT0("webrtc", "IncomingVideoStream::Dequeue");
RTC_DCHECK(incoming_render_queue_.IsCurrent());
absl::optional<VideoFrame> frame_to_render = render_buffers_.FrameToRender();
if (frame_to_render)
callback_->OnFrame(*frame_to_render);
if (render_buffers_.HasPendingFrames()) {
uint32_t wait_time = render_buffers_.TimeToNextFrameRelease();
incoming_render_queue_.PostDelayedTask([this]() { Dequeue(); }, wait_time);
}
}
} // namespace webrtc