OLD | NEW |
---|---|
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "content/renderer/media/crypto/ppapi_decryptor.h" | 5 #include "content/renderer/media/crypto/ppapi_decryptor.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
48 DCHECK(is_pending_); | 48 DCHECK(is_pending_); |
49 is_pending_ = false; | 49 is_pending_ = false; |
50 caller_promise_->reject(exception_code, system_code, error_message); | 50 caller_promise_->reject(exception_code, system_code, error_message); |
51 } | 51 } |
52 | 52 |
53 protected: | 53 protected: |
54 scoped_ptr<media::SimpleCdmPromise> caller_promise_; | 54 scoped_ptr<media::SimpleCdmPromise> caller_promise_; |
55 base::Closure additional_resolve_cb_; | 55 base::Closure additional_resolve_cb_; |
56 }; | 56 }; |
57 | 57 |
58 // This class is needed so that resolving an SessionLoaded() promise triggers | |
ddorwin
2014/08/08 23:36:22
nit: s/an/a/
jrummell
2014/08/11 18:59:02
Done.
| |
59 // playback of the stream. It intercepts the resolve() call to invoke an | |
60 // additional callback. | |
ddorwin
2014/08/08 23:36:23
Note that this is only needed until KeysChange is
jrummell
2014/08/11 18:59:02
Done.
| |
61 class SessionLoadedPromise : public media::NewSessionCdmPromise { | |
62 public: | |
63 SessionLoadedPromise(scoped_ptr<media::NewSessionCdmPromise> caller_promise, | |
64 base::Closure additional_resolve_cb) | |
65 : caller_promise_(caller_promise.Pass()), | |
66 additional_resolve_cb_(additional_resolve_cb) {} | |
67 | |
68 virtual void resolve(const std::string& web_session_id) OVERRIDE { | |
69 DCHECK(is_pending_); | |
70 is_pending_ = false; | |
ddorwin
2014/08/08 23:36:22
This is one problem with inheriting implementation
jrummell
2014/08/11 18:59:02
Acknowledged.
| |
71 additional_resolve_cb_.Run(); | |
72 caller_promise_->resolve(web_session_id); | |
73 } | |
74 | |
75 virtual void reject(media::MediaKeys::Exception exception_code, | |
76 uint32 system_code, | |
77 const std::string& error_message) OVERRIDE { | |
78 DCHECK(is_pending_); | |
79 is_pending_ = false; | |
80 caller_promise_->reject(exception_code, system_code, error_message); | |
81 } | |
82 | |
83 protected: | |
84 scoped_ptr<media::NewSessionCdmPromise> caller_promise_; | |
85 base::Closure additional_resolve_cb_; | |
86 }; | |
87 | |
58 scoped_ptr<PpapiDecryptor> PpapiDecryptor::Create( | 88 scoped_ptr<PpapiDecryptor> PpapiDecryptor::Create( |
59 const std::string& key_system, | 89 const std::string& key_system, |
60 const GURL& security_origin, | 90 const GURL& security_origin, |
61 const CreatePepperCdmCB& create_pepper_cdm_cb, | 91 const CreatePepperCdmCB& create_pepper_cdm_cb, |
62 const media::SessionMessageCB& session_message_cb, | 92 const media::SessionMessageCB& session_message_cb, |
63 const media::SessionReadyCB& session_ready_cb, | 93 const media::SessionReadyCB& session_ready_cb, |
64 const media::SessionClosedCB& session_closed_cb, | 94 const media::SessionClosedCB& session_closed_cb, |
65 const media::SessionErrorCB& session_error_cb) { | 95 const media::SessionErrorCB& session_error_cb) { |
66 std::string plugin_type = GetPepperType(key_system); | 96 std::string plugin_type = GetPepperType(key_system); |
67 DCHECK(!plugin_type.empty()); | 97 DCHECK(!plugin_type.empty()); |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
140 const std::string& web_session_id, | 170 const std::string& web_session_id, |
141 scoped_ptr<media::NewSessionCdmPromise> promise) { | 171 scoped_ptr<media::NewSessionCdmPromise> promise) { |
142 DVLOG(2) << __FUNCTION__; | 172 DVLOG(2) << __FUNCTION__; |
143 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 173 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
144 | 174 |
145 if (!CdmDelegate()) { | 175 if (!CdmDelegate()) { |
146 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 176 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
147 return; | 177 return; |
148 } | 178 } |
149 | 179 |
150 CdmDelegate()->LoadSession(web_session_id, promise.Pass()); | 180 scoped_ptr<SessionLoadedPromise> session_loaded_promise( |
181 new SessionLoadedPromise(promise.Pass(), | |
182 base::Bind(&PpapiDecryptor::ResumePlayback, | |
183 weak_ptr_factory_.GetWeakPtr()))); | |
184 | |
185 CdmDelegate()->LoadSession( | |
186 web_session_id, | |
187 session_loaded_promise.PassAs<media::NewSessionCdmPromise>()); | |
151 } | 188 } |
152 | 189 |
153 void PpapiDecryptor::UpdateSession( | 190 void PpapiDecryptor::UpdateSession( |
154 const std::string& web_session_id, | 191 const std::string& web_session_id, |
155 const uint8* response, | 192 const uint8* response, |
156 int response_length, | 193 int response_length, |
157 scoped_ptr<media::SimpleCdmPromise> promise) { | 194 scoped_ptr<media::SimpleCdmPromise> promise) { |
158 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 195 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
159 | 196 |
160 if (!CdmDelegate()) { | 197 if (!CdmDelegate()) { |
(...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
434 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 471 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
435 pepper_cdm_wrapper_.reset(); | 472 pepper_cdm_wrapper_.reset(); |
436 } | 473 } |
437 | 474 |
438 ContentDecryptorDelegate* PpapiDecryptor::CdmDelegate() { | 475 ContentDecryptorDelegate* PpapiDecryptor::CdmDelegate() { |
439 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 476 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
440 return (pepper_cdm_wrapper_) ? pepper_cdm_wrapper_->GetCdmDelegate() : NULL; | 477 return (pepper_cdm_wrapper_) ? pepper_cdm_wrapper_->GetCdmDelegate() : NULL; |
441 } | 478 } |
442 | 479 |
443 } // namespace content | 480 } // namespace content |
OLD | NEW |