Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(431)

Side by Side Diff: webkit/browser/dom_storage/dom_storage_task_runner.cc

Issue 22297005: Move webkit/{browser,common}/dom_storage into content/ (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
(Empty)
1 // Copyright (c) 2012 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 "webkit/browser/dom_storage/dom_storage_task_runner.h"
6
7 #include "base/bind.h"
8 #include "base/bind_helpers.h"
9 #include "base/message_loop/message_loop_proxy.h"
10 #include "base/tracked_objects.h"
11
12 namespace dom_storage {
13
14 // DomStorageTaskRunner
15
16 bool DomStorageTaskRunner::RunsTasksOnCurrentThread() const {
17 return IsRunningOnSequence(PRIMARY_SEQUENCE);
18 }
19
20 // DomStorageWorkerPoolTaskRunner
21
22 DomStorageWorkerPoolTaskRunner::DomStorageWorkerPoolTaskRunner(
23 base::SequencedWorkerPool* sequenced_worker_pool,
24 base::SequencedWorkerPool::SequenceToken primary_sequence_token,
25 base::SequencedWorkerPool::SequenceToken commit_sequence_token,
26 base::MessageLoopProxy* delayed_task_loop)
27 : message_loop_(delayed_task_loop),
28 sequenced_worker_pool_(sequenced_worker_pool),
29 primary_sequence_token_(primary_sequence_token),
30 commit_sequence_token_(commit_sequence_token) {
31 }
32
33 DomStorageWorkerPoolTaskRunner::~DomStorageWorkerPoolTaskRunner() {
34 }
35
36 bool DomStorageWorkerPoolTaskRunner::PostDelayedTask(
37 const tracked_objects::Location& from_here,
38 const base::Closure& task,
39 base::TimeDelta delay) {
40 // Note base::TaskRunner implements PostTask in terms of PostDelayedTask
41 // with a delay of zero, we detect that usage and avoid the unecessary
42 // trip thru the message loop.
43 if (delay == base::TimeDelta()) {
44 return sequenced_worker_pool_->PostSequencedWorkerTaskWithShutdownBehavior(
45 primary_sequence_token_, from_here, task,
46 base::SequencedWorkerPool::BLOCK_SHUTDOWN);
47 }
48 // Post a task to call this->PostTask() after the delay.
49 return message_loop_->PostDelayedTask(
50 FROM_HERE,
51 base::Bind(base::IgnoreResult(&DomStorageWorkerPoolTaskRunner::PostTask),
52 this, from_here, task),
53 delay);
54 }
55
56 bool DomStorageWorkerPoolTaskRunner::PostShutdownBlockingTask(
57 const tracked_objects::Location& from_here,
58 SequenceID sequence_id,
59 const base::Closure& task) {
60 return sequenced_worker_pool_->PostSequencedWorkerTaskWithShutdownBehavior(
61 IDtoToken(sequence_id), from_here, task,
62 base::SequencedWorkerPool::BLOCK_SHUTDOWN);
63 }
64
65 bool DomStorageWorkerPoolTaskRunner::IsRunningOnSequence(
66 SequenceID sequence_id) const {
67 return sequenced_worker_pool_->IsRunningSequenceOnCurrentThread(
68 IDtoToken(sequence_id));
69 }
70
71 base::SequencedWorkerPool::SequenceToken
72 DomStorageWorkerPoolTaskRunner::IDtoToken(SequenceID id) const {
73 if (id == PRIMARY_SEQUENCE)
74 return primary_sequence_token_;
75 DCHECK_EQ(COMMIT_SEQUENCE, id);
76 return commit_sequence_token_;
77 }
78
79 // MockDomStorageTaskRunner
80
81 MockDomStorageTaskRunner::MockDomStorageTaskRunner(
82 base::MessageLoopProxy* message_loop)
83 : message_loop_(message_loop) {
84 }
85
86 MockDomStorageTaskRunner::~MockDomStorageTaskRunner() {
87 }
88
89 bool MockDomStorageTaskRunner::PostDelayedTask(
90 const tracked_objects::Location& from_here,
91 const base::Closure& task,
92 base::TimeDelta delay) {
93 return message_loop_->PostTask(from_here, task);
94 }
95
96 bool MockDomStorageTaskRunner::PostShutdownBlockingTask(
97 const tracked_objects::Location& from_here,
98 SequenceID sequence_id,
99 const base::Closure& task) {
100 return message_loop_->PostTask(from_here, task);
101 }
102
103 bool MockDomStorageTaskRunner::IsRunningOnSequence(SequenceID) const {
104 return message_loop_->RunsTasksOnCurrentThread();
105 }
106
107 } // namespace dom_storage
OLDNEW
« no previous file with comments | « webkit/browser/dom_storage/dom_storage_task_runner.h ('k') | webkit/browser/dom_storage/local_storage_database_adapter.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698