OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 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 "config.h" | 5 #include "config.h" |
6 #include "core/dom/ScriptedIdleTaskController.h" | 6 #include "core/dom/ScriptedIdleTaskController.h" |
7 | 7 |
8 #include "core/dom/ExecutionContext.h" | 8 #include "core/dom/ExecutionContext.h" |
9 #include "core/dom/IdleRequestCallback.h" | 9 #include "core/dom/IdleRequestCallback.h" |
10 #include "core/loader/DocumentLoadTiming.h" | |
11 #include "platform/Logging.h" | 10 #include "platform/Logging.h" |
12 #include "platform/TraceEvent.h" | 11 #include "platform/TraceEvent.h" |
13 #include "public/platform/Platform.h" | 12 #include "public/platform/Platform.h" |
14 #include "public/platform/WebScheduler.h" | 13 #include "public/platform/WebScheduler.h" |
15 #include "public/platform/WebTraceLocation.h" | 14 #include "public/platform/WebTraceLocation.h" |
16 #include "wtf/CurrentTime.h" | 15 #include "wtf/CurrentTime.h" |
17 #include "wtf/Functional.h" | 16 #include "wtf/Functional.h" |
18 | 17 |
19 namespace blink { | 18 namespace blink { |
20 | 19 |
(...skipping 17 matching lines...) Expand all Loading... |
38 | 37 |
39 static void timeoutFired(PassRefPtr<IdleRequestCallbackWrapper> callbackWrap
per) | 38 static void timeoutFired(PassRefPtr<IdleRequestCallbackWrapper> callbackWrap
per) |
40 { | 39 { |
41 callbackWrapper->controller()->callbackFired(callbackWrapper->id(), mono
tonicallyIncreasingTime(), IdleCallbackDeadline::CallbackType::CalledByTimeout); | 40 callbackWrapper->controller()->callbackFired(callbackWrapper->id(), mono
tonicallyIncreasingTime(), IdleCallbackDeadline::CallbackType::CalledByTimeout); |
42 } | 41 } |
43 | 42 |
44 ScriptedIdleTaskController::CallbackId id() const { return m_id; } | 43 ScriptedIdleTaskController::CallbackId id() const { return m_id; } |
45 PassRefPtrWillBeRawPtr<ScriptedIdleTaskController> controller() const { retu
rn m_controller; } | 44 PassRefPtrWillBeRawPtr<ScriptedIdleTaskController> controller() const { retu
rn m_controller; } |
46 | 45 |
47 private: | 46 private: |
48 explicit IdleRequestCallbackWrapper(ScriptedIdleTaskController::CallbackId i
d, PassRefPtrWillBeRawPtr<ScriptedIdleTaskController> controller) | 47 IdleRequestCallbackWrapper(ScriptedIdleTaskController::CallbackId id, PassRe
fPtrWillBeRawPtr<ScriptedIdleTaskController> controller) |
49 : m_id(id) | 48 : m_id(id) |
50 , m_controller(controller) | 49 , m_controller(controller) |
51 { | 50 { |
52 } | 51 } |
53 | 52 |
54 ScriptedIdleTaskController::CallbackId m_id; | 53 ScriptedIdleTaskController::CallbackId m_id; |
55 RefPtrWillBePersistent<ScriptedIdleTaskController> m_controller; | 54 RefPtrWillBePersistent<ScriptedIdleTaskController> m_controller; |
56 }; | 55 }; |
57 | 56 |
58 } // namespace internal | 57 } // namespace internal |
59 | 58 |
60 ScriptedIdleTaskController::ScriptedIdleTaskController(ExecutionContext* context
, const DocumentLoadTiming& timing) | 59 ScriptedIdleTaskController::ScriptedIdleTaskController(ExecutionContext* context
) |
61 : ActiveDOMObject(context) | 60 : ActiveDOMObject(context) |
62 , m_timing(timing) | |
63 , m_scheduler(Platform::current()->currentThread()->scheduler()) | 61 , m_scheduler(Platform::current()->currentThread()->scheduler()) |
64 , m_nextCallbackId(0) | 62 , m_nextCallbackId(0) |
65 , m_suspended(false) | 63 , m_suspended(false) |
66 { | 64 { |
67 suspendIfNeeded(); | 65 suspendIfNeeded(); |
68 } | 66 } |
69 | 67 |
70 ScriptedIdleTaskController::~ScriptedIdleTaskController() | 68 ScriptedIdleTaskController::~ScriptedIdleTaskController() |
71 { | 69 { |
72 } | 70 } |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
104 | 102 |
105 if (m_suspended) { | 103 if (m_suspended) { |
106 if (callbackType == IdleCallbackDeadline::CallbackType::CalledByTimeout)
{ | 104 if (callbackType == IdleCallbackDeadline::CallbackType::CalledByTimeout)
{ |
107 // Queue for execution when we are resumed. | 105 // Queue for execution when we are resumed. |
108 m_pendingTimeouts.append(id); | 106 m_pendingTimeouts.append(id); |
109 } | 107 } |
110 // Just drop callbacks called while suspended, these will be reposted on
the idle task queue when we are resumed. | 108 // Just drop callbacks called while suspended, these will be reposted on
the idle task queue when we are resumed. |
111 return; | 109 return; |
112 } | 110 } |
113 | 111 |
114 double deadlineMillis = 1000.0 * m_timing.monotonicTimeToZeroBasedDocumentTi
me(deadlineSeconds); | 112 runCallback(id, deadlineSeconds, callbackType); |
115 runCallback(id, deadlineMillis, callbackType); | |
116 } | 113 } |
117 | 114 |
118 void ScriptedIdleTaskController::runCallback(CallbackId id, double deadlineMilli
s, IdleCallbackDeadline::CallbackType callbackType) | 115 void ScriptedIdleTaskController::runCallback(CallbackId id, double deadlineSecon
ds, IdleCallbackDeadline::CallbackType callbackType) |
119 { | 116 { |
120 ASSERT(!m_suspended); | 117 ASSERT(!m_suspended); |
121 auto callback = m_callbacks.take(id); | 118 auto callback = m_callbacks.take(id); |
122 if (!callback) | 119 if (!callback) |
123 return; | 120 return; |
124 | 121 |
125 // TODO(rmcilroy): Add devtools tracing. | 122 // TODO(rmcilroy): Add devtools tracing. |
126 callback->handleEvent(IdleCallbackDeadline::create(deadlineMillis, callbackT
ype, m_timing)); | 123 callback->handleEvent(IdleCallbackDeadline::create(deadlineSeconds, callback
Type)); |
127 } | 124 } |
128 | 125 |
129 void ScriptedIdleTaskController::stop() | 126 void ScriptedIdleTaskController::stop() |
130 { | 127 { |
131 m_callbacks.clear(); | 128 m_callbacks.clear(); |
132 } | 129 } |
133 | 130 |
134 void ScriptedIdleTaskController::suspend() | 131 void ScriptedIdleTaskController::suspend() |
135 { | 132 { |
136 m_suspended = true; | 133 m_suspended = true; |
(...skipping 16 matching lines...) Expand all Loading... |
153 m_scheduler->postIdleTask(FROM_HERE, WTF::bind<double>(&internal::IdleRe
questCallbackWrapper::idleTaskFired, callbackWrapper)); | 150 m_scheduler->postIdleTask(FROM_HERE, WTF::bind<double>(&internal::IdleRe
questCallbackWrapper::idleTaskFired, callbackWrapper)); |
154 } | 151 } |
155 } | 152 } |
156 | 153 |
157 bool ScriptedIdleTaskController::hasPendingActivity() const | 154 bool ScriptedIdleTaskController::hasPendingActivity() const |
158 { | 155 { |
159 return !m_callbacks.isEmpty(); | 156 return !m_callbacks.isEmpty(); |
160 } | 157 } |
161 | 158 |
162 } // namespace blink | 159 } // namespace blink |
OLD | NEW |