Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "base/sequenced_task_runner.h" | |
| 6 #include "base/threading/sequenced_worker_pool.h" | |
| 7 #include "content/browser/service_worker/service_worker_database_task_manager.h" | |
| 8 | |
| 9 namespace content { | |
| 10 | |
| 11 namespace { | |
| 12 | |
| 13 const char kServiceWorkerDatabaseTaskSequenceTokenName[] = | |
| 14 "service-worker-database-task-token"; | |
| 15 | |
| 16 } // namespace | |
| 17 | |
| 18 ServiceWorkerDatabaseTaskManagerImpl::ServiceWorkerDatabaseTaskManagerImpl( | |
| 19 base::SequencedWorkerPool* pool) | |
| 20 : pool_(pool) { | |
| 21 base::SequencedWorkerPool::SequenceToken token = | |
| 22 pool->GetNamedSequenceToken(kServiceWorkerDatabaseTaskSequenceTokenName); | |
|
michaeln
2014/10/16 01:15:04
In the existing code, each swcontext uses a unique
falken
2014/10/16 02:04:51
Good point! Done.
| |
| 23 task_runner_ = pool_->GetSequencedTaskRunner(token); | |
| 24 shutdown_blocking_task_runner_ = | |
| 25 pool_->GetSequencedTaskRunnerWithShutdownBehavior( | |
| 26 token, base::SequencedWorkerPool::BLOCK_SHUTDOWN); | |
| 27 } | |
| 28 | |
| 29 ServiceWorkerDatabaseTaskManagerImpl::~ServiceWorkerDatabaseTaskManagerImpl() { | |
| 30 } | |
| 31 | |
| 32 scoped_ptr<ServiceWorkerDatabaseTaskManager> | |
| 33 ServiceWorkerDatabaseTaskManagerImpl::Clone() { | |
| 34 return make_scoped_ptr(new ServiceWorkerDatabaseTaskManagerImpl(pool_.get())); | |
| 35 } | |
| 36 | |
| 37 base::SequencedTaskRunner* | |
| 38 ServiceWorkerDatabaseTaskManagerImpl::GetTaskRunner() { | |
| 39 return task_runner_.get(); | |
| 40 } | |
| 41 | |
| 42 base::SequencedTaskRunner* | |
| 43 ServiceWorkerDatabaseTaskManagerImpl::GetShutdownBlockingTaskRunner() { | |
| 44 return shutdown_blocking_task_runner_.get(); | |
| 45 } | |
| 46 | |
| 47 MockServiceWorkerDatabaseTaskManager::MockServiceWorkerDatabaseTaskManager( | |
| 48 const scoped_refptr<base::SequencedTaskRunner>& task_runner) | |
| 49 : task_runner_(task_runner) { | |
| 50 } | |
| 51 | |
| 52 MockServiceWorkerDatabaseTaskManager::~MockServiceWorkerDatabaseTaskManager() { | |
| 53 } | |
| 54 | |
| 55 scoped_ptr<ServiceWorkerDatabaseTaskManager> | |
| 56 MockServiceWorkerDatabaseTaskManager::Clone() { | |
| 57 return make_scoped_ptr( | |
| 58 new MockServiceWorkerDatabaseTaskManager(task_runner_)); | |
| 59 } | |
| 60 | |
| 61 base::SequencedTaskRunner* | |
| 62 MockServiceWorkerDatabaseTaskManager::GetTaskRunner() { | |
| 63 return task_runner_.get(); | |
| 64 } | |
| 65 | |
| 66 base::SequencedTaskRunner* | |
| 67 MockServiceWorkerDatabaseTaskManager::GetShutdownBlockingTaskRunner() { | |
| 68 return task_runner_.get(); | |
| 69 } | |
| 70 | |
| 71 } // namespace content | |
| OLD | NEW |