OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "webkit/browser/fileapi/timed_task_helper.h" | 5 #include "storage/browser/fileapi/timed_task_helper.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "base/sequenced_task_runner.h" | 9 #include "base/sequenced_task_runner.h" |
10 | 10 |
11 namespace fileapi { | 11 namespace storage { |
12 | 12 |
13 struct TimedTaskHelper::Tracker { | 13 struct TimedTaskHelper::Tracker { |
14 explicit Tracker(TimedTaskHelper* timer) : timer(timer) {} | 14 explicit Tracker(TimedTaskHelper* timer) : timer(timer) {} |
15 | 15 |
16 ~Tracker() { | 16 ~Tracker() { |
17 if (timer) | 17 if (timer) |
18 timer->tracker_ = NULL; | 18 timer->tracker_ = NULL; |
19 } | 19 } |
20 | 20 |
21 TimedTaskHelper* timer; | 21 TimedTaskHelper* timer; |
22 }; | 22 }; |
23 | 23 |
24 TimedTaskHelper::TimedTaskHelper(base::SequencedTaskRunner* task_runner) | 24 TimedTaskHelper::TimedTaskHelper(base::SequencedTaskRunner* task_runner) |
25 : task_runner_(task_runner), | 25 : task_runner_(task_runner), tracker_(NULL) { |
26 tracker_(NULL) { | |
27 } | 26 } |
28 | 27 |
29 TimedTaskHelper::~TimedTaskHelper() { | 28 TimedTaskHelper::~TimedTaskHelper() { |
30 DCHECK(task_runner_->RunsTasksOnCurrentThread()); | 29 DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
31 if (tracker_) | 30 if (tracker_) |
32 tracker_->timer = NULL; | 31 tracker_->timer = NULL; |
33 } | 32 } |
34 | 33 |
35 bool TimedTaskHelper::IsRunning() const { | 34 bool TimedTaskHelper::IsRunning() const { |
36 DCHECK(task_runner_->RunsTasksOnCurrentThread()); | 35 DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
37 return tracker_ != NULL; | 36 return tracker_ != NULL; |
38 } | 37 } |
39 | 38 |
40 void TimedTaskHelper::Start( | 39 void TimedTaskHelper::Start(const tracked_objects::Location& posted_from, |
41 const tracked_objects::Location& posted_from, | 40 base::TimeDelta delay, |
42 base::TimeDelta delay, | 41 const base::Closure& user_task) { |
43 const base::Closure& user_task) { | |
44 posted_from_ = posted_from; | 42 posted_from_ = posted_from; |
45 delay_ = delay; | 43 delay_ = delay; |
46 user_task_ = user_task; | 44 user_task_ = user_task; |
47 Reset(); | 45 Reset(); |
48 } | 46 } |
49 | 47 |
50 void TimedTaskHelper::Reset() { | 48 void TimedTaskHelper::Reset() { |
51 DCHECK(task_runner_->RunsTasksOnCurrentThread()); | 49 DCHECK(task_runner_->RunsTasksOnCurrentThread()); |
52 DCHECK(!user_task_.is_null()); | 50 DCHECK(!user_task_.is_null()); |
53 desired_run_time_ = base::TimeTicks::Now() + delay_; | 51 desired_run_time_ = base::TimeTicks::Now() + delay_; |
(...skipping 28 matching lines...) Expand all Loading... |
82 } | 80 } |
83 | 81 |
84 void TimedTaskHelper::PostDelayedTask(scoped_ptr<Tracker> tracker, | 82 void TimedTaskHelper::PostDelayedTask(scoped_ptr<Tracker> tracker, |
85 base::TimeDelta delay) { | 83 base::TimeDelta delay) { |
86 task_runner_->PostDelayedTask( | 84 task_runner_->PostDelayedTask( |
87 posted_from_, | 85 posted_from_, |
88 base::Bind(&TimedTaskHelper::Fired, base::Passed(&tracker)), | 86 base::Bind(&TimedTaskHelper::Fired, base::Passed(&tracker)), |
89 delay); | 87 delay); |
90 } | 88 } |
91 | 89 |
92 } // namespace fileapi | 90 } // namespace storage |
OLD | NEW |