OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "media/cast/sender/video_sender.h" | 5 #include "media/cast/sender/video_sender.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <cstring> | 8 #include <cstring> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/logging.h" | 11 #include "base/logging.h" |
12 #include "base/trace_event/trace_event.h" | 12 #include "base/trace_event/trace_event.h" |
13 #include "media/cast/cast_defines.h" | 13 #include "media/cast/cast_defines.h" |
14 #include "media/cast/net/cast_transport_config.h" | 14 #include "media/cast/net/cast_transport_config.h" |
15 #include "media/cast/sender/external_video_encoder.h" | 15 #include "media/cast/sender/video_encoder.h" |
16 #include "media/cast/sender/video_encoder_impl.h" | |
17 #include "media/cast/sender/video_frame_factory.h" | |
18 | |
19 #if defined(OS_MACOSX) | |
20 #include "media/cast/sender/h264_vt_encoder.h" | |
21 #endif | |
22 | 16 |
23 namespace media { | 17 namespace media { |
24 namespace cast { | 18 namespace cast { |
25 | 19 |
26 namespace { | 20 namespace { |
27 | 21 |
28 // The following two constants are used to adjust the target | 22 // The following two constants are used to adjust the target |
29 // playout delay (when allowed). They were calculated using | 23 // playout delay (when allowed). They were calculated using |
30 // a combination of cast_benchmark runs and manual testing. | 24 // a combination of cast_benchmark runs and manual testing. |
31 // | 25 // |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
64 NewFixedCongestionControl( | 58 NewFixedCongestionControl( |
65 (video_config.min_bitrate + video_config.max_bitrate) / 2) : | 59 (video_config.min_bitrate + video_config.max_bitrate) / 2) : |
66 NewAdaptiveCongestionControl(cast_environment->Clock(), | 60 NewAdaptiveCongestionControl(cast_environment->Clock(), |
67 video_config.max_bitrate, | 61 video_config.max_bitrate, |
68 video_config.min_bitrate, | 62 video_config.min_bitrate, |
69 video_config.max_frame_rate)), | 63 video_config.max_frame_rate)), |
70 frames_in_encoder_(0), | 64 frames_in_encoder_(0), |
71 last_bitrate_(0), | 65 last_bitrate_(0), |
72 playout_delay_change_cb_(playout_delay_change_cb), | 66 playout_delay_change_cb_(playout_delay_change_cb), |
73 weak_factory_(this) { | 67 weak_factory_(this) { |
74 #if defined(OS_MACOSX) | 68 video_encoder_ = VideoEncoder::Create( |
75 // On Apple platforms, use the hardware H.264 encoder if possible. It is the | 69 cast_environment_, |
76 // only reasonable option for iOS. | 70 video_config, |
77 if (!video_config.use_external_encoder && | 71 status_change_cb, |
78 video_config.codec == CODEC_VIDEO_H264) { | 72 create_vea_cb, |
79 video_encoder_.reset(new H264VideoToolboxEncoder( | 73 create_video_encode_mem_cb); |
80 cast_environment, | |
81 video_config, | |
82 gfx::Size(video_config.width, video_config.height), | |
83 status_change_cb)); | |
84 } | |
85 #endif // defined(OS_MACOSX) | |
86 #if !defined(OS_IOS) | |
87 if (video_config.use_external_encoder) { | |
88 video_encoder_.reset(new ExternalVideoEncoder( | |
89 cast_environment, | |
90 video_config, | |
91 gfx::Size(video_config.width, video_config.height), | |
92 status_change_cb, | |
93 create_vea_cb, | |
94 create_video_encode_mem_cb)); | |
95 } else if (!video_encoder_) { | |
96 // Software encoder is initialized immediately. | |
97 video_encoder_.reset(new VideoEncoderImpl( | |
98 cast_environment, video_config, status_change_cb)); | |
99 } | |
100 #endif // !defined(OS_IOS) | |
101 | |
102 if (!video_encoder_) { | 74 if (!video_encoder_) { |
103 cast_environment_->PostTask( | 75 cast_environment_->PostTask( |
104 CastEnvironment::MAIN, | 76 CastEnvironment::MAIN, |
105 FROM_HERE, | 77 FROM_HERE, |
106 base::Bind(status_change_cb, STATUS_UNSUPPORTED_CODEC)); | 78 base::Bind(status_change_cb, STATUS_UNSUPPORTED_CODEC)); |
107 } | 79 } |
108 | 80 |
109 media::cast::CastTransportRtpConfig transport_config; | 81 media::cast::CastTransportRtpConfig transport_config; |
110 transport_config.ssrc = video_config.ssrc; | 82 transport_config.ssrc = video_config.ssrc; |
111 transport_config.feedback_ssrc = video_config.receiver_ssrc; | 83 transport_config.feedback_ssrc = video_config.receiver_ssrc; |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
195 return; | 167 return; |
196 } | 168 } |
197 | 169 |
198 uint32 bitrate = congestion_control_->GetBitrate( | 170 uint32 bitrate = congestion_control_->GetBitrate( |
199 reference_time + target_playout_delay_, target_playout_delay_); | 171 reference_time + target_playout_delay_, target_playout_delay_); |
200 if (bitrate != last_bitrate_) { | 172 if (bitrate != last_bitrate_) { |
201 video_encoder_->SetBitRate(bitrate); | 173 video_encoder_->SetBitRate(bitrate); |
202 last_bitrate_ = bitrate; | 174 last_bitrate_ = bitrate; |
203 } | 175 } |
204 | 176 |
| 177 if (video_frame->visible_rect().IsEmpty()) { |
| 178 VLOG(1) << "Rejecting empty video frame."; |
| 179 return; |
| 180 } |
| 181 |
205 if (video_encoder_->EncodeVideoFrame( | 182 if (video_encoder_->EncodeVideoFrame( |
206 video_frame, | 183 video_frame, |
207 reference_time, | 184 reference_time, |
208 base::Bind(&VideoSender::OnEncodedVideoFrame, | 185 base::Bind(&VideoSender::OnEncodedVideoFrame, |
209 weak_factory_.GetWeakPtr(), | 186 weak_factory_.GetWeakPtr(), |
210 bitrate))) { | 187 bitrate))) { |
211 frames_in_encoder_++; | 188 frames_in_encoder_++; |
212 duration_in_encoder_ += duration_added_by_next_frame; | 189 duration_in_encoder_ += duration_added_by_next_frame; |
213 last_enqueued_frame_rtp_timestamp_ = rtp_timestamp; | 190 last_enqueued_frame_rtp_timestamp_ = rtp_timestamp; |
214 last_enqueued_frame_reference_time_ = reference_time; | 191 last_enqueued_frame_reference_time_ = reference_time; |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
248 DCHECK_GE(frames_in_encoder_, 0); | 225 DCHECK_GE(frames_in_encoder_, 0); |
249 | 226 |
250 duration_in_encoder_ = | 227 duration_in_encoder_ = |
251 last_enqueued_frame_reference_time_ - encoded_frame->reference_time; | 228 last_enqueued_frame_reference_time_ - encoded_frame->reference_time; |
252 | 229 |
253 SendEncodedFrame(encoder_bitrate, encoded_frame.Pass()); | 230 SendEncodedFrame(encoder_bitrate, encoded_frame.Pass()); |
254 } | 231 } |
255 | 232 |
256 } // namespace cast | 233 } // namespace cast |
257 } // namespace media | 234 } // namespace media |
OLD | NEW |