| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "remoting/protocol/webrtc_video_stream.h" | 5 #include "remoting/protocol/webrtc_video_stream.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/single_thread_task_runner.h" | 8 #include "base/single_thread_task_runner.h" |
| 9 #include "base/task_runner_util.h" | 9 #include "base/task_runner_util.h" |
| 10 #include "base/threading/thread_task_runner_handle.h" | 10 #include "base/threading/thread_task_runner_handle.h" |
| (...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 159 } | 159 } |
| 160 | 160 |
| 161 void WebrtcVideoStream::SetLosslessEncode(bool want_lossless) { | 161 void WebrtcVideoStream::SetLosslessEncode(bool want_lossless) { |
| 162 NOTIMPLEMENTED(); | 162 NOTIMPLEMENTED(); |
| 163 } | 163 } |
| 164 | 164 |
| 165 void WebrtcVideoStream::SetLosslessColor(bool want_lossless) { | 165 void WebrtcVideoStream::SetLosslessColor(bool want_lossless) { |
| 166 NOTIMPLEMENTED(); | 166 NOTIMPLEMENTED(); |
| 167 } | 167 } |
| 168 | 168 |
| 169 void WebrtcVideoStream::SetSizeCallback(const SizeCallback& size_callback) { | 169 void WebrtcVideoStream::SetObserver(Observer* observer) { |
| 170 DCHECK(thread_checker_.CalledOnValidThread()); | 170 DCHECK(thread_checker_.CalledOnValidThread()); |
| 171 size_callback_ = size_callback; | 171 observer_ = observer; |
| 172 } | 172 } |
| 173 | 173 |
| 174 void WebrtcVideoStream::SetKeyFrameRequest() { | 174 void WebrtcVideoStream::SetKeyFrameRequest() { |
| 175 DCHECK(thread_checker_.CalledOnValidThread()); | 175 DCHECK(thread_checker_.CalledOnValidThread()); |
| 176 | 176 |
| 177 key_frame_request_ = true; | 177 key_frame_request_ = true; |
| 178 if (!received_first_frame_request_) { | 178 if (!received_first_frame_request_) { |
| 179 received_first_frame_request_ = true; | 179 received_first_frame_request_ = true; |
| 180 StartCaptureTimer(); | 180 StartCaptureTimer(); |
| 181 main_task_runner_->PostTask( | 181 main_task_runner_->PostTask( |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 223 | 223 |
| 224 // TODO(sergeyu): Handle ERROR_PERMANENT result here. | 224 // TODO(sergeyu): Handle ERROR_PERMANENT result here. |
| 225 | 225 |
| 226 webrtc::DesktopVector dpi = | 226 webrtc::DesktopVector dpi = |
| 227 frame->dpi().is_zero() ? webrtc::DesktopVector(kDefaultDpi, kDefaultDpi) | 227 frame->dpi().is_zero() ? webrtc::DesktopVector(kDefaultDpi, kDefaultDpi) |
| 228 : frame->dpi(); | 228 : frame->dpi(); |
| 229 | 229 |
| 230 if (!frame_size_.equals(frame->size()) || !frame_dpi_.equals(dpi)) { | 230 if (!frame_size_.equals(frame->size()) || !frame_dpi_.equals(dpi)) { |
| 231 frame_size_ = frame->size(); | 231 frame_size_ = frame->size(); |
| 232 frame_dpi_ = dpi; | 232 frame_dpi_ = dpi; |
| 233 if (!size_callback_.is_null()) | 233 if (observer_) |
| 234 size_callback_.Run(frame_size_, frame_dpi_); | 234 observer_->OnVideoSizeChanged(this, frame_size_, frame_dpi_); |
| 235 } | 235 } |
| 236 encode_pending_ = true; | 236 encode_pending_ = true; |
| 237 base::PostTaskAndReplyWithResult( | 237 base::PostTaskAndReplyWithResult( |
| 238 encode_task_runner_.get(), FROM_HERE, | 238 encode_task_runner_.get(), FROM_HERE, |
| 239 base::Bind(&EncodeFrame, encoder_.get(), base::Passed(std::move(frame)), | 239 base::Bind(&EncodeFrame, encoder_.get(), base::Passed(std::move(frame)), |
| 240 target_bitrate_kbps_, ClearAndGetKeyFrameRequest(), | 240 target_bitrate_kbps_, ClearAndGetKeyFrameRequest(), |
| 241 capture_timestamp_ms), | 241 capture_timestamp_ms), |
| 242 base::Bind(&WebrtcVideoStream::OnFrameEncoded, | 242 base::Bind(&WebrtcVideoStream::OnFrameEncoded, |
| 243 weak_factory_.GetWeakPtr())); | 243 weak_factory_.GetWeakPtr())); |
| 244 } | 244 } |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 279 } else { | 279 } else { |
| 280 LOG(ERROR) << "SendEncodedFrame() failed"; | 280 LOG(ERROR) << "SendEncodedFrame() failed"; |
| 281 } | 281 } |
| 282 capture_timer_->Start(FROM_HERE, | 282 capture_timer_->Start(FROM_HERE, |
| 283 base::TimeDelta::FromMilliseconds(next_sched_ms), this, | 283 base::TimeDelta::FromMilliseconds(next_sched_ms), this, |
| 284 &WebrtcVideoStream::CaptureNextFrame); | 284 &WebrtcVideoStream::CaptureNextFrame); |
| 285 } | 285 } |
| 286 | 286 |
| 287 } // namespace protocol | 287 } // namespace protocol |
| 288 } // namespace remoting | 288 } // namespace remoting |
| OLD | NEW |