OLD | NEW |
| (Empty) |
1 // Copyright 2015 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 "components/scheduler/child/virtual_time_tqm_delegate.h" | |
6 | |
7 namespace scheduler { | |
8 | |
9 // static | |
10 scoped_refptr<VirtualTimeTqmDelegate> VirtualTimeTqmDelegate::Create( | |
11 base::MessageLoop* message_loop, | |
12 base::TimeTicks initial_now) { | |
13 return make_scoped_refptr( | |
14 new VirtualTimeTqmDelegate(message_loop, initial_now)); | |
15 } | |
16 | |
17 VirtualTimeTqmDelegate::VirtualTimeTqmDelegate(base::MessageLoop* message_loop, | |
18 base::TimeTicks initial_now) | |
19 : message_loop_(message_loop), | |
20 message_loop_task_runner_(message_loop->task_runner()), | |
21 now_(initial_now) {} | |
22 | |
23 VirtualTimeTqmDelegate::~VirtualTimeTqmDelegate() { | |
24 RestoreDefaultTaskRunner(); | |
25 } | |
26 | |
27 void VirtualTimeTqmDelegate::SetDefaultTaskRunner( | |
28 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { | |
29 message_loop_->SetTaskRunner(task_runner); | |
30 } | |
31 | |
32 void VirtualTimeTqmDelegate::RestoreDefaultTaskRunner() { | |
33 if (base::MessageLoop::current() == message_loop_) | |
34 message_loop_->SetTaskRunner(message_loop_task_runner_); | |
35 } | |
36 | |
37 bool VirtualTimeTqmDelegate::PostDelayedTask( | |
38 const tracked_objects::Location& from_here, | |
39 const base::Closure& task, | |
40 base::TimeDelta delay) { | |
41 if (delay > base::TimeDelta()) { | |
42 base::TimeTicks fire_time = now_ + delay; | |
43 delayed_wakeup_multimap_.insert(std::make_pair(fire_time, task)); | |
44 } | |
45 return message_loop_task_runner_->PostDelayedTask(from_here, task, delay); | |
46 } | |
47 | |
48 bool VirtualTimeTqmDelegate::PostNonNestableDelayedTask( | |
49 const tracked_objects::Location& from_here, | |
50 const base::Closure& task, | |
51 base::TimeDelta delay) { | |
52 return message_loop_task_runner_->PostNonNestableDelayedTask(from_here, task, | |
53 delay); | |
54 } | |
55 | |
56 bool VirtualTimeTqmDelegate::RunsTasksOnCurrentThread() const { | |
57 return message_loop_task_runner_->RunsTasksOnCurrentThread(); | |
58 } | |
59 | |
60 bool VirtualTimeTqmDelegate::IsNested() const { | |
61 return message_loop_->IsNested(); | |
62 } | |
63 | |
64 base::TimeTicks VirtualTimeTqmDelegate::NowTicks() { | |
65 return now_; | |
66 } | |
67 | |
68 double VirtualTimeTqmDelegate::CurrentTimeSeconds() const { | |
69 return (now_ - base::TimeTicks::UnixEpoch()).InSecondsF(); | |
70 } | |
71 | |
72 void VirtualTimeTqmDelegate::AdvancedTimeTo(base::TimeTicks now) { | |
73 now_ = now; | |
74 DCHECK_GE(now, now_); | |
75 while (!delayed_wakeup_multimap_.empty()) { | |
76 DelayedWakeupMultimap::iterator next_wakeup = | |
77 delayed_wakeup_multimap_.begin(); | |
78 if (next_wakeup->first > now) | |
79 break; | |
80 message_loop_task_runner_->PostDelayedTask(FROM_HERE, next_wakeup->second, | |
81 base::TimeDelta()); | |
82 delayed_wakeup_multimap_.erase(next_wakeup); | |
83 } | |
84 } | |
85 | |
86 void VirtualTimeTqmDelegate::OnNoMoreImmediateWork() { | |
87 if (delayed_wakeup_multimap_.empty()) | |
88 return; | |
89 | |
90 AdvancedTimeTo(delayed_wakeup_multimap_.begin()->first); | |
91 } | |
92 | |
93 } // namespace scheduler | |
OLD | NEW |