OLD | NEW |
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 Loading... |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |