| Index: content/browser/service_worker/service_worker_database_task_manager.cc
|
| diff --git a/content/browser/service_worker/service_worker_database_task_manager.cc b/content/browser/service_worker/service_worker_database_task_manager.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..be7f4d0e796eda5adfd3a9304f81e7c2109bed26
|
| --- /dev/null
|
| +++ b/content/browser/service_worker/service_worker_database_task_manager.cc
|
| @@ -0,0 +1,71 @@
|
| +// 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 "base/sequenced_task_runner.h"
|
| +#include "base/threading/sequenced_worker_pool.h"
|
| +#include "content/browser/service_worker/service_worker_database_task_manager.h"
|
| +
|
| +namespace content {
|
| +
|
| +ServiceWorkerDatabaseTaskManagerImpl::ServiceWorkerDatabaseTaskManagerImpl(
|
| + base::SequencedWorkerPool* pool) {
|
| + base::SequencedWorkerPool::SequenceToken token = pool->GetSequenceToken();
|
| + task_runner_ = pool->GetSequencedTaskRunner(token);
|
| + shutdown_blocking_task_runner_ =
|
| + pool->GetSequencedTaskRunnerWithShutdownBehavior(
|
| + token, base::SequencedWorkerPool::BLOCK_SHUTDOWN);
|
| +}
|
| +
|
| +ServiceWorkerDatabaseTaskManagerImpl::~ServiceWorkerDatabaseTaskManagerImpl() {
|
| +}
|
| +
|
| +scoped_ptr<ServiceWorkerDatabaseTaskManager>
|
| +ServiceWorkerDatabaseTaskManagerImpl::Clone() {
|
| + return make_scoped_ptr(new ServiceWorkerDatabaseTaskManagerImpl(
|
| + task_runner_, shutdown_blocking_task_runner_));
|
| +}
|
| +
|
| +base::SequencedTaskRunner*
|
| +ServiceWorkerDatabaseTaskManagerImpl::GetTaskRunner() {
|
| + return task_runner_.get();
|
| +}
|
| +
|
| +base::SequencedTaskRunner*
|
| +ServiceWorkerDatabaseTaskManagerImpl::GetShutdownBlockingTaskRunner() {
|
| + return shutdown_blocking_task_runner_.get();
|
| +}
|
| +
|
| +ServiceWorkerDatabaseTaskManagerImpl::ServiceWorkerDatabaseTaskManagerImpl(
|
| + const scoped_refptr<base::SequencedTaskRunner>& task_runner,
|
| + const scoped_refptr<base::SequencedTaskRunner>&
|
| + shutdown_blocking_task_runner)
|
| + : task_runner_(task_runner),
|
| + shutdown_blocking_task_runner_(shutdown_blocking_task_runner) {
|
| +}
|
| +
|
| +MockServiceWorkerDatabaseTaskManager::MockServiceWorkerDatabaseTaskManager(
|
| + const scoped_refptr<base::SequencedTaskRunner>& task_runner)
|
| + : task_runner_(task_runner) {
|
| +}
|
| +
|
| +MockServiceWorkerDatabaseTaskManager::~MockServiceWorkerDatabaseTaskManager() {
|
| +}
|
| +
|
| +scoped_ptr<ServiceWorkerDatabaseTaskManager>
|
| +MockServiceWorkerDatabaseTaskManager::Clone() {
|
| + return make_scoped_ptr(
|
| + new MockServiceWorkerDatabaseTaskManager(task_runner_));
|
| +}
|
| +
|
| +base::SequencedTaskRunner*
|
| +MockServiceWorkerDatabaseTaskManager::GetTaskRunner() {
|
| + return task_runner_.get();
|
| +}
|
| +
|
| +base::SequencedTaskRunner*
|
| +MockServiceWorkerDatabaseTaskManager::GetShutdownBlockingTaskRunner() {
|
| + return task_runner_.get();
|
| +}
|
| +
|
| +} // namespace content
|
|
|