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

Side by Side Diff: third_party/WebKit/Source/platform/scheduler/renderer/renderer_scheduler_impl.h

Issue 2812313002: [scheduler] Remove blink::scheduler::TaskQueue from public API. (Closed)
Patch Set: Rebased & addressed skyostil@'s comment Created 3 years, 8 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
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDULER _IMPL_H_ 5 #ifndef THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDULER _IMPL_H_
6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDULER _IMPL_H_ 6 #define THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDULER _IMPL_H_
7 7
8 #include "base/atomicops.h" 8 #include "base/atomicops.h"
9 #include "base/gtest_prod_util.h" 9 #include "base/gtest_prod_util.h"
10 #include "base/macros.h" 10 #include "base/macros.h"
11 #include "base/synchronization/lock.h" 11 #include "base/synchronization/lock.h"
12 #include "base/trace_event/trace_log.h" 12 #include "base/trace_event/trace_log.h"
13 #include "device/base/synchronization/shared_memory_seqlock_buffer.h" 13 #include "device/base/synchronization/shared_memory_seqlock_buffer.h"
14 #include "platform/scheduler/base/pollable_thread_safe_flag.h" 14 #include "platform/scheduler/base/pollable_thread_safe_flag.h"
15 #include "platform/scheduler/base/queueing_time_estimator.h" 15 #include "platform/scheduler/base/queueing_time_estimator.h"
16 #include "platform/scheduler/base/task_time_observer.h"
16 #include "platform/scheduler/base/thread_load_tracker.h" 17 #include "platform/scheduler/base/thread_load_tracker.h"
17 #include "platform/scheduler/child/idle_canceled_delayed_task_sweeper.h" 18 #include "platform/scheduler/child/idle_canceled_delayed_task_sweeper.h"
18 #include "platform/scheduler/child/idle_helper.h" 19 #include "platform/scheduler/child/idle_helper.h"
19 #include "platform/scheduler/child/scheduler_helper.h" 20 #include "platform/scheduler/child/scheduler_helper.h"
20 #include "platform/scheduler/renderer/deadline_task_runner.h" 21 #include "platform/scheduler/renderer/deadline_task_runner.h"
21 #include "platform/scheduler/renderer/idle_time_estimator.h" 22 #include "platform/scheduler/renderer/idle_time_estimator.h"
22 #include "platform/scheduler/renderer/render_widget_signals.h" 23 #include "platform/scheduler/renderer/render_widget_signals.h"
23 #include "platform/scheduler/renderer/task_cost_estimator.h" 24 #include "platform/scheduler/renderer/task_cost_estimator.h"
24 #include "platform/scheduler/renderer/user_model.h" 25 #include "platform/scheduler/renderer/user_model.h"
25 #include "platform/scheduler/renderer/web_view_scheduler_impl.h" 26 #include "platform/scheduler/renderer/web_view_scheduler_impl.h"
26 #include "public/platform/scheduler/renderer/renderer_scheduler.h" 27 #include "public/platform/scheduler/renderer/renderer_scheduler.h"
27 #include "public/platform/scheduler/base/task_time_observer.h"
28 28
29 namespace base { 29 namespace base {
30 namespace trace_event { 30 namespace trace_event {
31 class ConvertableToTraceFormat; 31 class ConvertableToTraceFormat;
32 } 32 }
33 } 33 }
34 34
35 namespace blink { 35 namespace blink {
36 namespace scheduler { 36 namespace scheduler {
37 class AutoAdvancingVirtualTimeDomain; 37 class AutoAdvancingVirtualTimeDomain;
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
78 FIRST_USE_CASE = NONE, 78 FIRST_USE_CASE = NONE,
79 }; 79 };
80 static const char* UseCaseToString(UseCase use_case); 80 static const char* UseCaseToString(UseCase use_case);
81 static const char* RAILModeToString(v8::RAILMode rail_mode); 81 static const char* RAILModeToString(v8::RAILMode rail_mode);
82 82
83 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner); 83 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner);
84 ~RendererSchedulerImpl() override; 84 ~RendererSchedulerImpl() override;
85 85
86 // RendererScheduler implementation: 86 // RendererScheduler implementation:
87 std::unique_ptr<WebThread> CreateMainThread() override; 87 std::unique_ptr<WebThread> CreateMainThread() override;
88 scoped_refptr<TaskQueue> DefaultTaskRunner() override;
89 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override; 88 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override;
90 scoped_refptr<TaskQueue> CompositorTaskRunner() override;
91 scoped_refptr<TaskQueue> LoadingTaskRunner() override;
92 scoped_refptr<TaskQueue> TimerTaskRunner() override;
93 scoped_refptr<TaskQueue> NewLoadingTaskRunner(
94 TaskQueue::QueueType queue_type) override;
95 scoped_refptr<TaskQueue> NewTimerTaskRunner(
96 TaskQueue::QueueType queue_type) override;
97 scoped_refptr<TaskQueue> NewUnthrottledTaskRunner(
98 TaskQueue::QueueType queue_type) override;
99 std::unique_ptr<RenderWidgetSchedulingState> NewRenderWidgetSchedulingState() 89 std::unique_ptr<RenderWidgetSchedulingState> NewRenderWidgetSchedulingState()
100 override; 90 override;
101 void WillBeginFrame(const cc::BeginFrameArgs& args) override; 91 void WillBeginFrame(const cc::BeginFrameArgs& args) override;
102 void BeginFrameNotExpectedSoon() override; 92 void BeginFrameNotExpectedSoon() override;
103 void DidCommitFrameToCompositor() override; 93 void DidCommitFrameToCompositor() override;
104 void DidHandleInputEventOnCompositorThread( 94 void DidHandleInputEventOnCompositorThread(
105 const WebInputEvent& web_input_event, 95 const WebInputEvent& web_input_event,
106 InputEventState event_state) override; 96 InputEventState event_state) override;
107 void DidHandleInputEventOnMainThread(const WebInputEvent& web_input_event, 97 void DidHandleInputEventOnMainThread(const WebInputEvent& web_input_event,
108 WebInputEventResult result) override; 98 WebInputEventResult result) override;
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
143 // TaskTimeObserver implementation: 133 // TaskTimeObserver implementation:
144 void WillProcessTask(TaskQueue* task_queue, double start_time) override; 134 void WillProcessTask(TaskQueue* task_queue, double start_time) override;
145 void DidProcessTask(TaskQueue* task_queue, 135 void DidProcessTask(TaskQueue* task_queue,
146 double start_time, 136 double start_time,
147 double end_time) override; 137 double end_time) override;
148 void OnBeginNestedMessageLoop() override; 138 void OnBeginNestedMessageLoop() override;
149 139
150 // QueueingTimeEstimator::Client implementation: 140 // QueueingTimeEstimator::Client implementation:
151 void OnQueueingTimeForWindowEstimated(base::TimeDelta queueing_time) override; 141 void OnQueueingTimeForWindowEstimated(base::TimeDelta queueing_time) override;
152 142
153 // Returns a task runner where tasks run at the highest possible priority. 143 scoped_refptr<TaskQueue> DefaultTaskQueue();
154 scoped_refptr<TaskQueue> ControlTaskRunner(); 144 scoped_refptr<TaskQueue> CompositorTaskQueue();
145 scoped_refptr<TaskQueue> LoadingTaskQueue();
146 scoped_refptr<TaskQueue> TimerTaskQueue();
147
148 // Returns a new loading task queue. This queue is intended for tasks related
149 // to resource dispatch, foreground HTML parsing, etc...
150 scoped_refptr<TaskQueue> NewLoadingTaskQueue(TaskQueue::QueueType queue_type);
151
152 // Returns a new timer task queue. This queue is intended for DOM Timers.
153 scoped_refptr<TaskQueue> NewTimerTaskQueue(TaskQueue::QueueType queue_type);
154
155 // Returns a task queue for tasks which should never get throttled.
156 scoped_refptr<TaskQueue> NewUnthrottledTaskQueue(
157 TaskQueue::QueueType queue_type);
158
159 // Returns a task queue where tasks run at the highest possible priority.
160 scoped_refptr<TaskQueue> ControlTaskQueue();
155 161
156 void RegisterTimeDomain(TimeDomain* time_domain); 162 void RegisterTimeDomain(TimeDomain* time_domain);
157 void UnregisterTimeDomain(TimeDomain* time_domain); 163 void UnregisterTimeDomain(TimeDomain* time_domain);
158 164
159 // Tells the scheduler that all TaskQueues should use virtual time. 165 // Tells the scheduler that all TaskQueues should use virtual time.
160 void EnableVirtualTime(); 166 void EnableVirtualTime();
161 167
162 // Migrates all task queues to real time. 168 // Migrates all task queues to real time.
163 void DisableVirtualTimeForTesting(); 169 void DisableVirtualTimeForTesting();
164 170
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
199 TaskQueueThrottler* task_queue_throttler() const { 205 TaskQueueThrottler* task_queue_throttler() const {
200 return task_queue_throttler_.get(); 206 return task_queue_throttler_.get();
201 } 207 }
202 208
203 void OnFirstMeaningfulPaint(); 209 void OnFirstMeaningfulPaint();
204 210
205 // base::trace_event::TraceLog::EnabledStateObserver implementation: 211 // base::trace_event::TraceLog::EnabledStateObserver implementation:
206 void OnTraceLogEnabled() override; 212 void OnTraceLogEnabled() override;
207 void OnTraceLogDisabled() override; 213 void OnTraceLogDisabled() override;
208 214
215 protected:
216 // RendererScheduler implementation.
217 // Use *TaskQueue internally.
218 scoped_refptr<base::SingleThreadTaskRunner> DefaultTaskRunner() override;
219 scoped_refptr<base::SingleThreadTaskRunner> CompositorTaskRunner() override;
220 scoped_refptr<base::SingleThreadTaskRunner> LoadingTaskRunner() override;
221 scoped_refptr<base::SingleThreadTaskRunner> TimerTaskRunner() override;
222
209 private: 223 private:
210 friend class RendererSchedulerImplTest; 224 friend class RendererSchedulerImplTest;
211 friend class RendererSchedulerImplForTest; 225 friend class RendererSchedulerImplForTest;
212 friend class RenderWidgetSchedulingState; 226 friend class RenderWidgetSchedulingState;
213 FRIEND_TEST_ALL_PREFIXES(RendererSchedulerImplTest, Tracing); 227 FRIEND_TEST_ALL_PREFIXES(RendererSchedulerImplTest, Tracing);
214 228
215 enum class ExpensiveTaskPolicy { RUN, BLOCK, THROTTLE }; 229 enum class ExpensiveTaskPolicy { RUN, BLOCK, THROTTLE };
216 230
217 enum class TimeDomainType { 231 enum class TimeDomainType {
218 REAL, 232 REAL,
(...skipping 312 matching lines...) Expand 10 before | Expand all | Expand 10 after
531 545
532 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; 546 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_;
533 547
534 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); 548 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl);
535 }; 549 };
536 550
537 } // namespace scheduler 551 } // namespace scheduler
538 } // namespace blink 552 } // namespace blink
539 553
540 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDU LER_IMPL_H_ 554 #endif // THIRD_PARTY_WEBKIT_SOURCE_PLATFORM_SCHEDULER_RENDERER_RENDERER_SCHEDU LER_IMPL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698