1 /*
2 * Copyright (c) 2012 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 "video/render/incoming_video_stream.h"
12
13 #include <memory>
14 #include <utility>
15
16 #include "absl/types/optional.h"
17 #include "api/units/time_delta.h"
18 #include "rtc_base/checks.h"
19 #include "rtc_base/trace_event.h"
20 #include "video/render/video_render_frames.h"
21
22 namespace webrtc {
23
IncomingVideoStream(TaskQueueFactory * task_queue_factory,int32_t delay_ms,rtc::VideoSinkInterface<VideoFrame> * callback)24 IncomingVideoStream::IncomingVideoStream(
25 TaskQueueFactory* task_queue_factory,
26 int32_t delay_ms,
27 rtc::VideoSinkInterface<VideoFrame>* callback)
28 : render_buffers_(delay_ms),
29 callback_(callback),
30 incoming_render_queue_(task_queue_factory->CreateTaskQueue(
31 "IncomingVideoStream",
32 TaskQueueFactory::Priority::HIGH)) {}
33
~IncomingVideoStream()34 IncomingVideoStream::~IncomingVideoStream() {
35 RTC_DCHECK(main_thread_checker_.IsCurrent());
36 }
37
OnFrame(const VideoFrame & video_frame)38 void IncomingVideoStream::OnFrame(const VideoFrame& video_frame) {
39 TRACE_EVENT0("webrtc", "IncomingVideoStream::OnFrame");
40 RTC_CHECK_RUNS_SERIALIZED(&decoder_race_checker_);
41 RTC_DCHECK(!incoming_render_queue_.IsCurrent());
42 // TODO(srte): Using video_frame = std::move(video_frame) would move the frame
43 // into the lambda instead of copying it, but it doesn't work unless we change
44 // OnFrame to take its frame argument by value instead of const reference.
45 incoming_render_queue_.PostTask([this, video_frame = video_frame]() mutable {
46 RTC_DCHECK_RUN_ON(&incoming_render_queue_);
47 if (render_buffers_.AddFrame(std::move(video_frame)) == 1)
48 Dequeue();
49 });
50 }
51
Dequeue()52 void IncomingVideoStream::Dequeue() {
53 TRACE_EVENT0("webrtc", "IncomingVideoStream::Dequeue");
54 RTC_DCHECK_RUN_ON(&incoming_render_queue_);
55 absl::optional<VideoFrame> frame_to_render = render_buffers_.FrameToRender();
56 if (frame_to_render)
57 callback_->OnFrame(*frame_to_render);
58
59 if (render_buffers_.HasPendingFrames()) {
60 uint32_t wait_time = render_buffers_.TimeToNextFrameRelease();
61 incoming_render_queue_.PostDelayedHighPrecisionTask(
62 [this]() { Dequeue(); }, TimeDelta::Millis(wait_time));
63 }
64 }
65
66 } // namespace webrtc
67