| Index: media/mojo/services/mojo_cdm_promise.cc
|
| diff --git a/media/mojo/services/mojo_cdm_promise.cc b/media/mojo/services/mojo_cdm_promise.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..11361ed46f13a9621ea80f1f6dded586d6c962f1
|
| --- /dev/null
|
| +++ b/media/mojo/services/mojo_cdm_promise.cc
|
| @@ -0,0 +1,85 @@
|
| +// Copyright 2014 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "media/mojo/services/mojo_cdm_promise.h"
|
| +
|
| +#include "base/bind.h"
|
| +#include "base/logging.h"
|
| +#include "media/base/decryptor.h"
|
| +
|
| +namespace media {
|
| +
|
| +static mojo::CdmPromiseResultPtr GetRejectResult(
|
| + MediaKeys::Exception exception_code,
|
| + uint32 system_code,
|
| + const std::string& error_message) {
|
| + mojo::CdmPromiseResultPtr cdm_promise_result(mojo::CdmPromiseResult::New());
|
| + cdm_promise_result->success = false;
|
| + cdm_promise_result->exception_code =
|
| + static_cast<mojo::CdmException>(exception_code);
|
| + cdm_promise_result->system_code = system_code;
|
| + cdm_promise_result->error_message = error_message;
|
| + return cdm_promise_result.Pass();
|
| +}
|
| +
|
| +SimpleMojoCdmPromise::SimpleMojoCdmPromise(
|
| + const mojo::Callback<void(mojo::CdmPromiseResultPtr)>& callback)
|
| + : callback_(callback) {
|
| + DCHECK(!callback_.is_null());
|
| +}
|
| +
|
| +SimpleMojoCdmPromise::~SimpleMojoCdmPromise() {
|
| + if (!callback_.is_null())
|
| + DVLOG(1) << "Promise not resolved before destruction.";
|
| +}
|
| +
|
| +void SimpleMojoCdmPromise::resolve() {
|
| + mojo::CdmPromiseResultPtr cdm_promise_result(mojo::CdmPromiseResult::New());
|
| + cdm_promise_result->success = true;
|
| + callback_.Run(cdm_promise_result.Pass());
|
| + callback_.reset();
|
| +}
|
| +
|
| +void SimpleMojoCdmPromise::reject(MediaKeys::Exception exception_code,
|
| + uint32 system_code,
|
| + const std::string& error_message) {
|
| + callback_.Run(GetRejectResult(exception_code, system_code, error_message));
|
| + callback_.reset();
|
| +}
|
| +
|
| +template <typename Type, typename MojoType>
|
| +MojoCdmPromise<Type, MojoType>::MojoCdmPromise(
|
| + const mojo::Callback<void(mojo::CdmPromiseResultPtr, MojoType)>& callback)
|
| + : callback_(callback) {
|
| + DCHECK(!callback_.is_null());
|
| +}
|
| +
|
| +template <typename Type, typename MojoType>
|
| +MojoCdmPromise<Type, MojoType>::~MojoCdmPromise() {
|
| + if (!callback_.is_null())
|
| + DVLOG(1) << "Promise not resolved before destruction.";
|
| +}
|
| +
|
| +template <typename Type, typename MojoType>
|
| +void MojoCdmPromise<Type, MojoType>::resolve(const Type& arg) {
|
| + mojo::CdmPromiseResultPtr cdm_promise_result(mojo::CdmPromiseResult::New());
|
| + cdm_promise_result->success = true;
|
| + callback_.Run(cdm_promise_result.Pass(), MojoType::From(arg));
|
| + callback_.reset();
|
| +}
|
| +
|
| +template <typename Type, typename MojoType>
|
| +void MojoCdmPromise<Type, MojoType>::reject(MediaKeys::Exception exception_code,
|
| + uint32 system_code,
|
| + const std::string& error_message) {
|
| + callback_.Run(GetRejectResult(exception_code, system_code, error_message),
|
| + MojoType());
|
| + callback_.reset();
|
| +}
|
| +
|
| +template class MojoCdmPromise<std::string, mojo::String>;
|
| +template class MojoCdmPromise<std::vector<std::vector<uint8_t>>,
|
| + mojo::Array<mojo::Array<uint8_t>>>;
|
| +
|
| +} // namespace media
|
|
|