Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1230)

Side by Side Diff: webrtc/common_video/incoming_video_stream.cc

Issue 1813173002: Deletes the class VideoRendererCallback. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Delete unused method IncomingVideoStream::ModuleCallback. Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 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 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 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
(...skipping 13 matching lines...) Expand all
24 #include "webrtc/base/platform_thread.h" 24 #include "webrtc/base/platform_thread.h"
25 #include "webrtc/common_video/libyuv/include/webrtc_libyuv.h" 25 #include "webrtc/common_video/libyuv/include/webrtc_libyuv.h"
26 #include "webrtc/common_video/video_render_frames.h" 26 #include "webrtc/common_video/video_render_frames.h"
27 #include "webrtc/system_wrappers/include/critical_section_wrapper.h" 27 #include "webrtc/system_wrappers/include/critical_section_wrapper.h"
28 #include "webrtc/system_wrappers/include/event_wrapper.h" 28 #include "webrtc/system_wrappers/include/event_wrapper.h"
29 #include "webrtc/system_wrappers/include/tick_util.h" 29 #include "webrtc/system_wrappers/include/tick_util.h"
30 #include "webrtc/system_wrappers/include/trace.h" 30 #include "webrtc/system_wrappers/include/trace.h"
31 31
32 namespace webrtc { 32 namespace webrtc {
33 33
34 IncomingVideoStream::IncomingVideoStream(uint32_t stream_id, 34 IncomingVideoStream::IncomingVideoStream(bool disable_prerenderer_smoothing)
35 bool disable_prerenderer_smoothing) 35 : disable_prerenderer_smoothing_(disable_prerenderer_smoothing),
36 : stream_id_(stream_id),
37 disable_prerenderer_smoothing_(disable_prerenderer_smoothing),
38 incoming_render_thread_(), 36 incoming_render_thread_(),
39 deliver_buffer_event_(EventTimerWrapper::Create()), 37 deliver_buffer_event_(EventTimerWrapper::Create()),
40 running_(false), 38 running_(false),
41 external_callback_(nullptr), 39 external_callback_(nullptr),
42 render_callback_(nullptr), 40 render_callback_(nullptr),
43 render_buffers_(new VideoRenderFrames()), 41 render_buffers_(new VideoRenderFrames()),
44 incoming_rate_(0), 42 incoming_rate_(0),
45 last_rate_calculation_time_ms_(0), 43 last_rate_calculation_time_ms_(0),
46 num_frames_since_last_calculation_(0) {} 44 num_frames_since_last_calculation_(0) {}
47 45
48 IncomingVideoStream::~IncomingVideoStream() { 46 IncomingVideoStream::~IncomingVideoStream() {
49 Stop(); 47 Stop();
50 } 48 }
51 49
52 VideoRenderCallback* IncomingVideoStream::ModuleCallback() { 50 void IncomingVideoStream::OnFrame(const VideoFrame& video_frame) {
53 return this;
54 }
55
56 int32_t IncomingVideoStream::RenderFrame(const uint32_t stream_id,
57 const VideoFrame& video_frame) {
58 rtc::CritScope csS(&stream_critsect_); 51 rtc::CritScope csS(&stream_critsect_);
59 52
60 if (!running_) { 53 if (!running_) {
61 return -1; 54 return;
62 } 55 }
63 56
64 // Rate statistics. 57 // Rate statistics.
65 num_frames_since_last_calculation_++; 58 num_frames_since_last_calculation_++;
66 int64_t now_ms = TickTime::MillisecondTimestamp(); 59 int64_t now_ms = TickTime::MillisecondTimestamp();
67 if (now_ms >= last_rate_calculation_time_ms_ + kFrameRatePeriodMs) { 60 if (now_ms >= last_rate_calculation_time_ms_ + kFrameRatePeriodMs) {
68 incoming_rate_ = 61 incoming_rate_ =
69 static_cast<uint32_t>(1000 * num_frames_since_last_calculation_ / 62 static_cast<uint32_t>(1000 * num_frames_since_last_calculation_ /
70 (now_ms - last_rate_calculation_time_ms_)); 63 (now_ms - last_rate_calculation_time_ms_));
71 num_frames_since_last_calculation_ = 0; 64 num_frames_since_last_calculation_ = 0;
72 last_rate_calculation_time_ms_ = now_ms; 65 last_rate_calculation_time_ms_ = now_ms;
73 } 66 }
74 67
75 // Hand over or insert frame. 68 // Hand over or insert frame.
76 if (disable_prerenderer_smoothing_) { 69 if (disable_prerenderer_smoothing_) {
77 DeliverFrame(video_frame); 70 DeliverFrame(video_frame);
78 } else { 71 } else {
79 rtc::CritScope csB(&buffer_critsect_); 72 rtc::CritScope csB(&buffer_critsect_);
80 if (render_buffers_->AddFrame(video_frame) == 1) { 73 if (render_buffers_->AddFrame(video_frame) == 1) {
81 deliver_buffer_event_->Set(); 74 deliver_buffer_event_->Set();
82 } 75 }
83 } 76 }
84 return 0;
85 } 77 }
86 78
87 void IncomingVideoStream::SetRenderCallback( 79 void IncomingVideoStream::SetRenderCallback(
88 VideoRenderCallback* render_callback) { 80 rtc::VideoSinkInterface<VideoFrame>* render_callback) {
89 rtc::CritScope cs(&thread_critsect_); 81 rtc::CritScope cs(&thread_critsect_);
90 render_callback_ = render_callback; 82 render_callback_ = render_callback;
91 } 83 }
92 84
93 int32_t IncomingVideoStream::SetExpectedRenderDelay( 85 int32_t IncomingVideoStream::SetExpectedRenderDelay(
94 int32_t delay_ms) { 86 int32_t delay_ms) {
95 rtc::CritScope csS(&stream_critsect_); 87 rtc::CritScope csS(&stream_critsect_);
96 if (running_) { 88 if (running_) {
97 return -1; 89 return -1;
98 } 90 }
99 rtc::CritScope cs(&buffer_critsect_); 91 rtc::CritScope cs(&buffer_critsect_);
100 return render_buffers_->SetRenderDelay(delay_ms); 92 return render_buffers_->SetRenderDelay(delay_ms);
101 } 93 }
102 94
103 void IncomingVideoStream::SetExternalCallback( 95 void IncomingVideoStream::SetExternalCallback(
104 VideoRenderCallback* external_callback) { 96 rtc::VideoSinkInterface<VideoFrame>* external_callback) {
105 rtc::CritScope cs(&thread_critsect_); 97 rtc::CritScope cs(&thread_critsect_);
106 external_callback_ = external_callback; 98 external_callback_ = external_callback;
107 } 99 }
108 100
109 int32_t IncomingVideoStream::Start() { 101 int32_t IncomingVideoStream::Start() {
110 rtc::CritScope csS(&stream_critsect_); 102 rtc::CritScope csS(&stream_critsect_);
111 if (running_) { 103 if (running_) {
112 return 0; 104 return 0;
113 } 105 }
114 106
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
158 running_ = false; 150 running_ = false;
159 return 0; 151 return 0;
160 } 152 }
161 153
162 int32_t IncomingVideoStream::Reset() { 154 int32_t IncomingVideoStream::Reset() {
163 rtc::CritScope cs_buffer(&buffer_critsect_); 155 rtc::CritScope cs_buffer(&buffer_critsect_);
164 render_buffers_->ReleaseAllFrames(); 156 render_buffers_->ReleaseAllFrames();
165 return 0; 157 return 0;
166 } 158 }
167 159
168 uint32_t IncomingVideoStream::StreamId() const {
169 return stream_id_;
170 }
171
172 uint32_t IncomingVideoStream::IncomingRate() const { 160 uint32_t IncomingVideoStream::IncomingRate() const {
173 rtc::CritScope cs(&stream_critsect_); 161 rtc::CritScope cs(&stream_critsect_);
174 return incoming_rate_; 162 return incoming_rate_;
175 } 163 }
176 164
177 bool IncomingVideoStream::IncomingVideoStreamThreadFun(void* obj) { 165 bool IncomingVideoStream::IncomingVideoStreamThreadFun(void* obj) {
178 return static_cast<IncomingVideoStream*>(obj)->IncomingVideoStreamProcess(); 166 return static_cast<IncomingVideoStream*>(obj)->IncomingVideoStreamProcess();
179 } 167 }
180 168
181 bool IncomingVideoStream::IncomingVideoStreamProcess() { 169 bool IncomingVideoStream::IncomingVideoStreamProcess() {
(...skipping 26 matching lines...) Expand all
208 196
209 void IncomingVideoStream::DeliverFrame(const VideoFrame& video_frame) { 197 void IncomingVideoStream::DeliverFrame(const VideoFrame& video_frame) {
210 rtc::CritScope cs(&thread_critsect_); 198 rtc::CritScope cs(&thread_critsect_);
211 if (video_frame.IsZeroSize()) { 199 if (video_frame.IsZeroSize()) {
212 // No frame. 200 // No frame.
213 return; 201 return;
214 } 202 }
215 203
216 // Send frame for rendering. 204 // Send frame for rendering.
217 if (external_callback_) { 205 if (external_callback_) {
218 external_callback_->RenderFrame(stream_id_, video_frame); 206 external_callback_->OnFrame(video_frame);
219 } else if (render_callback_) { 207 } else if (render_callback_) {
220 render_callback_->RenderFrame(stream_id_, video_frame); 208 render_callback_->OnFrame(video_frame);
221 } 209 }
222 } 210 }
223 211
224 } // namespace webrtc 212 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/common_video/include/incoming_video_stream.h ('k') | webrtc/video/video_receive_stream.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698