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

Side by Side Diff: components/scheduler/child/compositor_worker_scheduler.cc

Issue 2118903002: scheduler: Move the Blink scheduler into Blink (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased Created 4 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
OLDNEW
(Empty)
1 // Copyright 2016 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/compositor_worker_scheduler.h"
6
7 #include "base/message_loop/message_loop.h"
8 #include "base/threading/thread.h"
9
10 namespace scheduler {
11
12 // TODO(scheduler-dev): Get rid of this asap!
13 namespace {
14 class CompositorWorkerTaskRunnerWrapper : public TaskQueue {
15 public:
16 explicit CompositorWorkerTaskRunnerWrapper(
17 scoped_refptr<base::SingleThreadTaskRunner> task_runner)
18 : task_runner_(task_runner) {}
19
20 // TaskQueue implementation:
21 void UnregisterTaskQueue() override { NOTREACHED(); }
22
23 bool RunsTasksOnCurrentThread() const override {
24 return task_runner_->RunsTasksOnCurrentThread();
25 }
26
27 bool PostDelayedTask(const tracked_objects::Location& from_here,
28 const base::Closure& task,
29 base::TimeDelta delay) override {
30 return task_runner_->PostDelayedTask(from_here, task, delay);
31 }
32
33 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here,
34 const base::Closure& task,
35 base::TimeDelta delay) override {
36 return task_runner_->PostNonNestableDelayedTask(from_here, task, delay);
37 }
38
39 void SetQueueEnabled(bool enabled) override { NOTREACHED(); }
40
41 bool IsQueueEnabled() const override {
42 NOTREACHED();
43 return true;
44 }
45
46 bool IsEmpty() const override {
47 NOTREACHED();
48 return false;
49 };
50
51 bool HasPendingImmediateWork() const override {
52 NOTREACHED();
53 return false;
54 };
55
56 bool NeedsPumping() const override {
57 NOTREACHED();
58 return false;
59 };
60
61 const char* GetName() const override {
62 NOTREACHED();
63 return nullptr;
64 };
65
66 void SetQueuePriority(QueuePriority priority) override { NOTREACHED(); }
67
68 QueuePriority GetQueuePriority() const override {
69 NOTREACHED();
70 return QueuePriority::NORMAL_PRIORITY;
71 };
72
73 void SetPumpPolicy(PumpPolicy pump_policy) override { NOTREACHED(); }
74
75 PumpPolicy GetPumpPolicy() const override {
76 NOTREACHED();
77 return PumpPolicy::AUTO;
78 };
79
80 void PumpQueue(LazyNow*, bool may_post_dowork) override { NOTREACHED(); }
81
82 void AddTaskObserver(
83 base::MessageLoop::TaskObserver* task_observer) override {
84 NOTREACHED();
85 }
86
87 void RemoveTaskObserver(
88 base::MessageLoop::TaskObserver* task_observer) override {
89 NOTREACHED();
90 }
91
92 void SetTimeDomain(TimeDomain* domain) override { NOTREACHED(); }
93
94 TimeDomain* GetTimeDomain() const override {
95 NOTREACHED();
96 return nullptr;
97 }
98
99 void SetBlameContext(base::trace_event::BlameContext*) override {
100 NOTREACHED();
101 }
102
103 private:
104 ~CompositorWorkerTaskRunnerWrapper() override {}
105
106 scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
107 };
108 } // namespace
109
110 CompositorWorkerScheduler::CompositorWorkerScheduler(base::Thread* thread)
111 : thread_(thread) {}
112
113 CompositorWorkerScheduler::~CompositorWorkerScheduler() {}
114
115 void CompositorWorkerScheduler::Init() {}
116
117 scoped_refptr<TaskQueue> CompositorWorkerScheduler::DefaultTaskRunner() {
118 // TODO(sad): Implement a more robust scheduler that can do idle tasks for GC
119 // without regressing performance of the rest of the system.
120 return make_scoped_refptr(
121 new CompositorWorkerTaskRunnerWrapper(thread_->task_runner()));
122 }
123
124 scoped_refptr<scheduler::SingleThreadIdleTaskRunner>
125 CompositorWorkerScheduler::IdleTaskRunner() {
126 // TODO(flackr): This posts idle tasks as regular tasks. We need to create
127 // an idle task runner with the semantics we want for the compositor thread
128 // which runs them after the current frame has been drawn before the next
129 // vsync. https://crbug.com/609532
130 return make_scoped_refptr(new SingleThreadIdleTaskRunner(
131 thread_->task_runner(), thread_->task_runner(), this,
132 "compositor.scheduler"));
133 }
134
135 bool CompositorWorkerScheduler::CanExceedIdleDeadlineIfRequired() const {
136 return false;
137 }
138
139 bool CompositorWorkerScheduler::ShouldYieldForHighPriorityWork() {
140 return false;
141 }
142
143 void CompositorWorkerScheduler::AddTaskObserver(
144 base::MessageLoop::TaskObserver* task_observer) {
145 thread_->message_loop()->AddTaskObserver(task_observer);
146 }
147
148 void CompositorWorkerScheduler::RemoveTaskObserver(
149 base::MessageLoop::TaskObserver* task_observer) {
150 thread_->message_loop()->RemoveTaskObserver(task_observer);
151 }
152
153 void CompositorWorkerScheduler::Shutdown() {}
154
155 void CompositorWorkerScheduler::OnIdleTaskPosted() {}
156
157 base::TimeTicks CompositorWorkerScheduler::WillProcessIdleTask() {
158 // TODO(flackr): Return the next frame time as the deadline instead.
159 // TODO(flackr): Ensure that oilpan GC does happen on the compositor thread
160 // even though we will have no long idle periods. https://crbug.com/609531
161 return base::TimeTicks::Now() + base::TimeDelta::FromMillisecondsD(16.7);
162 }
163
164 void CompositorWorkerScheduler::DidProcessIdleTask() {}
165
166 } // namespace scheduler
OLDNEW
« no previous file with comments | « components/scheduler/child/compositor_worker_scheduler.h ('k') | components/scheduler/child/idle_helper.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698