OLD | NEW |
| (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 | |
OLD | NEW |