niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 1 | /* |
mflodman@webrtc.org | 0e703f4 | 2012-03-06 12:02:20 +0000 | [diff] [blame] | 2 | * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 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 | |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 11 | #include "common_video/include/incoming_video_stream.h" |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 12 | |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 13 | #include <memory> |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 14 | #include <utility> |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 15 | |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 16 | #include "absl/types/optional.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 17 | #include "common_video/video_render_frames.h" |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 18 | #include "rtc_base/checks.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 19 | #include "rtc_base/trace_event.h" |
mflodman@webrtc.org | 327ada1 | 2012-05-30 10:45:18 +0000 | [diff] [blame] | 20 | |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 21 | namespace webrtc { |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 22 | |
tommi | 2e82f38 | 2016-06-21 00:26:43 -0700 | [diff] [blame] | 23 | IncomingVideoStream::IncomingVideoStream( |
Sebastian Jansson | 74682c1 | 2019-03-01 11:50:20 +0100 | [diff] [blame] | 24 | TaskQueueFactory* task_queue_factory, |
tommi | 2e82f38 | 2016-06-21 00:26:43 -0700 | [diff] [blame] | 25 | int32_t delay_ms, |
| 26 | rtc::VideoSinkInterface<VideoFrame>* callback) |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 27 | : render_buffers_(delay_ms), |
| 28 | callback_(callback), |
Sebastian Jansson | 74682c1 | 2019-03-01 11:50:20 +0100 | [diff] [blame] | 29 | incoming_render_queue_(task_queue_factory->CreateTaskQueue( |
| 30 | "IncomingVideoStream", |
| 31 | TaskQueueFactory::Priority::HIGH)) {} |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 32 | |
mflodman@webrtc.org | 327ada1 | 2012-05-30 10:45:18 +0000 | [diff] [blame] | 33 | IncomingVideoStream::~IncomingVideoStream() { |
Sebastian Jansson | c01367d | 2019-04-08 15:20:44 +0200 | [diff] [blame] | 34 | RTC_DCHECK(main_thread_checker_.IsCurrent()); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 35 | } |
| 36 | |
nisse | 30f118e | 2016-05-03 01:09:11 -0700 | [diff] [blame] | 37 | void IncomingVideoStream::OnFrame(const VideoFrame& video_frame) { |
tommi | db23ea6 | 2017-03-03 07:21:18 -0800 | [diff] [blame] | 38 | TRACE_EVENT0("webrtc", "IncomingVideoStream::OnFrame"); |
Peter Boström | 02bafc6 | 2016-07-01 12:45:15 +0200 | [diff] [blame] | 39 | RTC_CHECK_RUNS_SERIALIZED(&decoder_race_checker_); |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 40 | RTC_DCHECK(!incoming_render_queue_.IsCurrent()); |
Sebastian Jansson | 86314cf | 2019-09-17 20:29:59 +0200 | [diff] [blame] | 41 | // TODO(srte): Using video_frame = std::move(video_frame) would move the frame |
| 42 | // into the lambda instead of copying it, but it doesn't work unless we change |
| 43 | // OnFrame to take its frame argument by value instead of const reference. |
| 44 | incoming_render_queue_.PostTask([this, video_frame = video_frame]() mutable { |
| 45 | RTC_DCHECK(incoming_render_queue_.IsCurrent()); |
| 46 | if (render_buffers_.AddFrame(std::move(video_frame)) == 1) |
| 47 | Dequeue(); |
| 48 | }); |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 49 | } |
| 50 | |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 51 | void IncomingVideoStream::Dequeue() { |
tommi | db23ea6 | 2017-03-03 07:21:18 -0800 | [diff] [blame] | 52 | TRACE_EVENT0("webrtc", "IncomingVideoStream::Dequeue"); |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 53 | RTC_DCHECK(incoming_render_queue_.IsCurrent()); |
Danil Chapovalov | 196100e | 2018-06-21 10:17:24 +0200 | [diff] [blame] | 54 | absl::optional<VideoFrame> frame_to_render = render_buffers_.FrameToRender(); |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 55 | if (frame_to_render) |
| 56 | callback_->OnFrame(*frame_to_render); |
mflodman@webrtc.org | 327ada1 | 2012-05-30 10:45:18 +0000 | [diff] [blame] | 57 | |
tommi | ede0759 | 2017-02-27 07:16:10 -0800 | [diff] [blame] | 58 | if (render_buffers_.HasPendingFrames()) { |
| 59 | uint32_t wait_time = render_buffers_.TimeToNextFrameRelease(); |
| 60 | incoming_render_queue_.PostDelayedTask([this]() { Dequeue(); }, wait_time); |
mflodman@webrtc.org | 327ada1 | 2012-05-30 10:45:18 +0000 | [diff] [blame] | 61 | } |
niklase@google.com | 470e71d | 2011-07-07 08:21:25 +0000 | [diff] [blame] | 62 | } |
| 63 | |
mflodman@webrtc.org | 327ada1 | 2012-05-30 10:45:18 +0000 | [diff] [blame] | 64 | } // namespace webrtc |