| 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/logging.h" | 10 #include "base/logging.h" |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 83 base::Bind(&PpapiDecryptor::OnSessionKeysChange, weak_this), | 83 base::Bind(&PpapiDecryptor::OnSessionKeysChange, weak_this), |
| 84 base::Bind(&PpapiDecryptor::OnSessionExpirationUpdate, weak_this), | 84 base::Bind(&PpapiDecryptor::OnSessionExpirationUpdate, weak_this), |
| 85 base::Bind(&PpapiDecryptor::OnFatalPluginError, weak_this)); | 85 base::Bind(&PpapiDecryptor::OnFatalPluginError, weak_this)); |
| 86 } | 86 } |
| 87 | 87 |
| 88 PpapiDecryptor::~PpapiDecryptor() { | 88 PpapiDecryptor::~PpapiDecryptor() { |
| 89 pepper_cdm_wrapper_.reset(); | 89 pepper_cdm_wrapper_.reset(); |
| 90 } | 90 } |
| 91 | 91 |
| 92 void PpapiDecryptor::SetServerCertificate( | 92 void PpapiDecryptor::SetServerCertificate( |
| 93 const uint8* certificate_data, | 93 const std::vector<uint8>& certificate, |
| 94 int certificate_data_length, | |
| 95 scoped_ptr<media::SimpleCdmPromise> promise) { | 94 scoped_ptr<media::SimpleCdmPromise> promise) { |
| 96 DVLOG(2) << __FUNCTION__; | 95 DVLOG(2) << __FUNCTION__; |
| 97 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 96 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 98 | 97 |
| 99 if (!CdmDelegate()) { | 98 if (!CdmDelegate()) { |
| 100 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 99 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
| 101 return; | 100 return; |
| 102 } | 101 } |
| 103 | 102 |
| 104 CdmDelegate()->SetServerCertificate( | 103 CdmDelegate()->SetServerCertificate(certificate, promise.Pass()); |
| 105 certificate_data, certificate_data_length, promise.Pass()); | |
| 106 } | 104 } |
| 107 | 105 |
| 108 void PpapiDecryptor::CreateSessionAndGenerateRequest( | 106 void PpapiDecryptor::CreateSessionAndGenerateRequest( |
| 109 SessionType session_type, | 107 SessionType session_type, |
| 110 media::EmeInitDataType init_data_type, | 108 media::EmeInitDataType init_data_type, |
| 111 const uint8* init_data, | 109 const std::vector<uint8>& init_data, |
| 112 int init_data_length, | |
| 113 scoped_ptr<media::NewSessionCdmPromise> promise) { | 110 scoped_ptr<media::NewSessionCdmPromise> promise) { |
| 114 DVLOG(2) << __FUNCTION__; | 111 DVLOG(2) << __FUNCTION__; |
| 115 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 112 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 116 | 113 |
| 117 if (!CdmDelegate()) { | 114 if (!CdmDelegate()) { |
| 118 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 115 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
| 119 return; | 116 return; |
| 120 } | 117 } |
| 121 | 118 |
| 122 CdmDelegate()->CreateSessionAndGenerateRequest(session_type, init_data_type, | 119 CdmDelegate()->CreateSessionAndGenerateRequest(session_type, init_data_type, |
| 123 init_data, init_data_length, | 120 init_data, promise.Pass()); |
| 124 promise.Pass()); | |
| 125 } | 121 } |
| 126 | 122 |
| 127 void PpapiDecryptor::LoadSession( | 123 void PpapiDecryptor::LoadSession( |
| 128 SessionType session_type, | 124 SessionType session_type, |
| 129 const std::string& session_id, | 125 const std::string& session_id, |
| 130 scoped_ptr<media::NewSessionCdmPromise> promise) { | 126 scoped_ptr<media::NewSessionCdmPromise> promise) { |
| 131 DVLOG(2) << __FUNCTION__; | 127 DVLOG(2) << __FUNCTION__; |
| 132 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 128 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 133 | 129 |
| 134 if (!CdmDelegate()) { | 130 if (!CdmDelegate()) { |
| 135 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 131 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
| 136 return; | 132 return; |
| 137 } | 133 } |
| 138 CdmDelegate()->LoadSession(session_type, session_id, promise.Pass()); | 134 CdmDelegate()->LoadSession(session_type, session_id, promise.Pass()); |
| 139 } | 135 } |
| 140 | 136 |
| 141 void PpapiDecryptor::UpdateSession( | 137 void PpapiDecryptor::UpdateSession( |
| 142 const std::string& session_id, | 138 const std::string& session_id, |
| 143 const uint8* response, | 139 const std::vector<uint8>& response, |
| 144 int response_length, | |
| 145 scoped_ptr<media::SimpleCdmPromise> promise) { | 140 scoped_ptr<media::SimpleCdmPromise> promise) { |
| 146 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 141 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 147 | 142 |
| 148 if (!CdmDelegate()) { | 143 if (!CdmDelegate()) { |
| 149 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 144 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
| 150 return; | 145 return; |
| 151 } | 146 } |
| 152 CdmDelegate()->UpdateSession(session_id, response, response_length, | 147 CdmDelegate()->UpdateSession(session_id, response, promise.Pass()); |
| 153 promise.Pass()); | |
| 154 } | 148 } |
| 155 | 149 |
| 156 void PpapiDecryptor::CloseSession(const std::string& session_id, | 150 void PpapiDecryptor::CloseSession(const std::string& session_id, |
| 157 scoped_ptr<media::SimpleCdmPromise> promise) { | 151 scoped_ptr<media::SimpleCdmPromise> promise) { |
| 158 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 152 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 159 | 153 |
| 160 if (!CdmDelegate()) { | 154 if (!CdmDelegate()) { |
| 161 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); | 155 promise->reject(INVALID_STATE_ERROR, 0, "CdmDelegate() does not exist."); |
| 162 return; | 156 return; |
| 163 } | 157 } |
| (...skipping 284 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 448 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 442 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 449 pepper_cdm_wrapper_.reset(); | 443 pepper_cdm_wrapper_.reset(); |
| 450 } | 444 } |
| 451 | 445 |
| 452 ContentDecryptorDelegate* PpapiDecryptor::CdmDelegate() { | 446 ContentDecryptorDelegate* PpapiDecryptor::CdmDelegate() { |
| 453 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); | 447 DCHECK(render_loop_proxy_->BelongsToCurrentThread()); |
| 454 return (pepper_cdm_wrapper_) ? pepper_cdm_wrapper_->GetCdmDelegate() : NULL; | 448 return (pepper_cdm_wrapper_) ? pepper_cdm_wrapper_->GetCdmDelegate() : NULL; |
| 455 } | 449 } |
| 456 | 450 |
| 457 } // namespace content | 451 } // namespace content |
| OLD | NEW |