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 "media/base/android/media_codec_video_decoder.h" | 5 #include "media/base/android/media_codec_video_decoder.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "media/base/android/media_codec_bridge.h" | 9 #include "media/base/android/media_codec_bridge.h" |
| 10 #include "media/base/android/media_drm_bridge.h" |
10 #include "media/base/demuxer_stream.h" | 11 #include "media/base/demuxer_stream.h" |
11 #include "media/base/timestamp_constants.h" | 12 #include "media/base/timestamp_constants.h" |
12 | 13 |
13 namespace media { | 14 namespace media { |
14 | 15 |
15 namespace { | 16 namespace { |
16 const int kDelayForStandAloneEOS = 2; // milliseconds | 17 const int kDelayForStandAloneEOS = 2; // milliseconds |
17 } | 18 } |
18 | 19 |
19 MediaCodecVideoDecoder::MediaCodecVideoDecoder( | 20 MediaCodecVideoDecoder::MediaCodecVideoDecoder( |
20 const scoped_refptr<base::SingleThreadTaskRunner>& media_task_runner, | 21 const scoped_refptr<base::SingleThreadTaskRunner>& media_task_runner, |
21 const base::Closure& request_data_cb, | 22 const base::Closure& request_data_cb, |
22 const base::Closure& starvation_cb, | 23 const base::Closure& starvation_cb, |
23 const base::Closure& decoder_drained_cb, | 24 const base::Closure& decoder_drained_cb, |
24 const base::Closure& stop_done_cb, | 25 const base::Closure& stop_done_cb, |
| 26 const base::Closure& key_required_cb, |
25 const base::Closure& error_cb, | 27 const base::Closure& error_cb, |
26 const SetTimeCallback& update_current_time_cb, | 28 const SetTimeCallback& update_current_time_cb, |
27 const VideoSizeChangedCallback& video_size_changed_cb, | 29 const VideoSizeChangedCallback& video_size_changed_cb, |
28 const base::Closure& codec_created_cb) | 30 const base::Closure& codec_created_cb) |
29 : MediaCodecDecoder(media_task_runner, | 31 : MediaCodecDecoder(media_task_runner, |
30 request_data_cb, | 32 request_data_cb, |
31 starvation_cb, | 33 starvation_cb, |
32 decoder_drained_cb, | 34 decoder_drained_cb, |
33 stop_done_cb, | 35 stop_done_cb, |
| 36 key_required_cb, |
34 error_cb, | 37 error_cb, |
35 "VideoDecoder"), | 38 "VideoDecoder"), |
36 update_current_time_cb_(update_current_time_cb), | 39 update_current_time_cb_(update_current_time_cb), |
37 video_size_changed_cb_(video_size_changed_cb), | 40 video_size_changed_cb_(video_size_changed_cb), |
38 codec_created_cb_(codec_created_cb) { | 41 codec_created_cb_(codec_created_cb) { |
39 } | 42 } |
40 | 43 |
41 MediaCodecVideoDecoder::~MediaCodecVideoDecoder() { | 44 MediaCodecVideoDecoder::~MediaCodecVideoDecoder() { |
42 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 45 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
43 DVLOG(1) << "VideoDecoder::~VideoDecoder()"; | 46 DVLOG(1) << "VideoDecoder::~VideoDecoder()"; |
(...skipping 15 matching lines...) Expand all Loading... |
59 | 62 |
60 configs_ = configs; | 63 configs_ = configs; |
61 | 64 |
62 if (video_size_.IsEmpty()) { | 65 if (video_size_.IsEmpty()) { |
63 video_size_ = configs_.video_size; | 66 video_size_ = configs_.video_size; |
64 media_task_runner_->PostTask( | 67 media_task_runner_->PostTask( |
65 FROM_HERE, base::Bind(video_size_changed_cb_, video_size_)); | 68 FROM_HERE, base::Bind(video_size_changed_cb_, video_size_)); |
66 } | 69 } |
67 } | 70 } |
68 | 71 |
| 72 bool MediaCodecVideoDecoder::IsContentEncrypted() const { |
| 73 return configs_.is_video_encrypted; |
| 74 } |
| 75 |
69 void MediaCodecVideoDecoder::ReleaseDecoderResources() { | 76 void MediaCodecVideoDecoder::ReleaseDecoderResources() { |
70 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 77 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
71 DVLOG(1) << class_name() << "::" << __FUNCTION__; | 78 DVLOG(1) << class_name() << "::" << __FUNCTION__; |
72 | 79 |
73 DoEmergencyStop(); | 80 DoEmergencyStop(); |
74 | 81 |
75 ReleaseMediaCodec(); | 82 ReleaseMediaCodec(); |
76 | 83 |
77 surface_ = gfx::ScopedJavaSurface(); | 84 surface_ = gfx::ScopedJavaSurface(); |
78 } | 85 } |
79 | 86 |
80 void MediaCodecVideoDecoder::ReleaseMediaCodec() { | 87 void MediaCodecVideoDecoder::ReleaseMediaCodec() { |
81 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 88 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
82 | 89 |
83 MediaCodecDecoder::ReleaseMediaCodec(); | 90 MediaCodecDecoder::ReleaseMediaCodec(); |
84 delayed_buffers_.clear(); | 91 delayed_buffers_.clear(); |
85 } | 92 } |
86 | 93 |
87 void MediaCodecVideoDecoder::SetVideoSurface(gfx::ScopedJavaSurface surface) { | 94 void MediaCodecVideoDecoder::SetVideoSurface(gfx::ScopedJavaSurface surface) { |
88 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 95 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
89 | 96 |
90 DVLOG(1) << class_name() << "::" << __FUNCTION__ | 97 DVLOG(1) << class_name() << "::" << __FUNCTION__ |
91 << (surface.IsEmpty() ? " empty" : " non-empty"); | 98 << (surface.IsEmpty() ? " empty" : " non-empty"); |
92 | 99 |
| 100 // Do not set unprotected surface if we know that we need a protected one. |
| 101 // Empty surface means the surface removal and we always allow for it. |
| 102 if (!surface.IsEmpty() && drm_bridge_ && |
| 103 drm_bridge_->IsProtectedSurfaceRequired() && !surface.is_protected()) { |
| 104 DVLOG(0) << class_name() << "::" << __FUNCTION__ |
| 105 << ": surface is not protected, ignoring"; |
| 106 return; |
| 107 } |
| 108 |
93 surface_ = surface.Pass(); | 109 surface_ = surface.Pass(); |
94 | 110 |
95 needs_reconfigure_ = true; | 111 needs_reconfigure_ = true; |
96 } | 112 } |
97 | 113 |
98 bool MediaCodecVideoDecoder::HasVideoSurface() const { | 114 bool MediaCodecVideoDecoder::HasVideoSurface() const { |
99 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 115 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
100 | 116 |
101 return !surface_.IsEmpty(); | 117 return !surface_.IsEmpty(); |
102 } | 118 } |
(...skipping 13 matching lines...) Expand all Loading... |
116 if (configs_.video_size.width() == next.video_size.width() && | 132 if (configs_.video_size.width() == next.video_size.width() && |
117 configs_.video_size.height() == next.video_size.height()) { | 133 configs_.video_size.height() == next.video_size.height()) { |
118 return false; // i.e. configs_ == next | 134 return false; // i.e. configs_ == next |
119 } | 135 } |
120 | 136 |
121 return !static_cast<VideoCodecBridge*>(media_codec_bridge_.get()) | 137 return !static_cast<VideoCodecBridge*>(media_codec_bridge_.get()) |
122 ->IsAdaptivePlaybackSupported(next.video_size.width(), | 138 ->IsAdaptivePlaybackSupported(next.video_size.width(), |
123 next.video_size.height()); | 139 next.video_size.height()); |
124 } | 140 } |
125 | 141 |
126 MediaCodecDecoder::ConfigStatus MediaCodecVideoDecoder::ConfigureInternal() { | 142 MediaCodecDecoder::ConfigStatus MediaCodecVideoDecoder::ConfigureInternal( |
| 143 jobject media_crypto) { |
127 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 144 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
128 | 145 |
129 DVLOG(1) << class_name() << "::" << __FUNCTION__; | 146 DVLOG(1) << class_name() << "::" << __FUNCTION__; |
130 | 147 |
131 // If we cannot find a key frame in cache, the browser seek is needed. | 148 // If we cannot find a key frame in cache, the browser seek is needed. |
132 if (!au_queue_.RewindToLastKeyFrame()) { | 149 if (!au_queue_.RewindToLastKeyFrame()) { |
133 DVLOG(1) << class_name() << "::" << __FUNCTION__ << " key frame required"; | 150 DVLOG(1) << class_name() << "::" << __FUNCTION__ << " key frame required"; |
134 return kConfigKeyFrameRequired; | 151 return kConfigKeyFrameRequired; |
135 } | 152 } |
136 | 153 |
137 if (configs_.video_codec == kUnknownVideoCodec) { | 154 if (configs_.video_codec == kUnknownVideoCodec) { |
138 DVLOG(0) << class_name() << "::" << __FUNCTION__ | 155 DVLOG(0) << class_name() << "::" << __FUNCTION__ |
139 << " configuration parameters are required"; | 156 << ": configuration parameters are required"; |
140 return kConfigFailure; | 157 return kConfigFailure; |
141 } | 158 } |
142 | 159 |
143 // TODO(timav): implement DRM. | |
144 // bool is_secure = is_content_encrypted() && drm_bridge() && | |
145 // drm_bridge()->IsProtectedSurfaceRequired(); | |
146 | |
147 bool is_secure = false; // DRM is not implemented | |
148 | |
149 if (surface_.IsEmpty()) { | 160 if (surface_.IsEmpty()) { |
150 DVLOG(0) << class_name() << "::" << __FUNCTION__ << " surface required"; | 161 DVLOG(0) << class_name() << "::" << __FUNCTION__ << ": surface is required"; |
151 return kConfigFailure; | 162 return kConfigFailure; |
152 } | 163 } |
153 | 164 |
| 165 bool is_secure = IsContentEncrypted() && drm_bridge_ && |
| 166 drm_bridge_->IsProtectedSurfaceRequired(); |
| 167 |
154 media_codec_bridge_.reset(VideoCodecBridge::CreateDecoder( | 168 media_codec_bridge_.reset(VideoCodecBridge::CreateDecoder( |
155 configs_.video_codec, | 169 configs_.video_codec, |
156 is_secure, | 170 is_secure, |
157 configs_.video_size, | 171 configs_.video_size, |
158 surface_.j_surface().obj(), | 172 surface_.j_surface().obj(), |
159 GetMediaCrypto().obj())); | 173 media_crypto)); |
160 | 174 |
161 if (!media_codec_bridge_) { | 175 if (!media_codec_bridge_) { |
162 DVLOG(0) << class_name() << "::" << __FUNCTION__ | 176 DVLOG(0) << class_name() << "::" << __FUNCTION__ |
163 << " failed: cannot create video codec"; | 177 << " failed: cannot create video codec"; |
164 return kConfigFailure; | 178 return kConfigFailure; |
165 } | 179 } |
166 | 180 |
167 DVLOG(0) << class_name() << "::" << __FUNCTION__ << " succeeded"; | 181 DVLOG(0) << class_name() << "::" << __FUNCTION__ << " succeeded"; |
168 | 182 |
169 media_task_runner_->PostTask(FROM_HERE, codec_created_cb_); | 183 media_task_runner_->PostTask(FROM_HERE, codec_created_cb_); |
(...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
320 | 334 |
321 // |update_current_time_cb_| might be null if there is audio stream. | 335 // |update_current_time_cb_| might be null if there is audio stream. |
322 // Do not update current time for stand-alone EOS frames. | 336 // Do not update current time for stand-alone EOS frames. |
323 if (!update_current_time_cb_.is_null() && update_time) { | 337 if (!update_current_time_cb_.is_null() && update_time) { |
324 media_task_runner_->PostTask( | 338 media_task_runner_->PostTask( |
325 FROM_HERE, base::Bind(update_current_time_cb_, pts, pts, false)); | 339 FROM_HERE, base::Bind(update_current_time_cb_, pts, pts, false)); |
326 } | 340 } |
327 } | 341 } |
328 | 342 |
329 } // namespace media | 343 } // namespace media |
OLD | NEW |