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 "bindings/core/v8/RejectedPromises.h" | 6 #include "bindings/core/v8/RejectedPromises.h" |
7 | 7 |
8 #include "bindings/core/v8/ScopedPersistent.h" | 8 #include "bindings/core/v8/ScopedPersistent.h" |
9 #include "bindings/core/v8/ScriptState.h" | 9 #include "bindings/core/v8/ScriptState.h" |
10 #include "bindings/core/v8/ScriptValue.h" | 10 #include "bindings/core/v8/ScriptValue.h" |
(...skipping 225 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
236 } | 236 } |
237 } | 237 } |
238 | 238 |
239 PassOwnPtrWillBeRawPtr<RejectedPromises::MessageQueue> RejectedPromises::createM
essageQueue() | 239 PassOwnPtrWillBeRawPtr<RejectedPromises::MessageQueue> RejectedPromises::createM
essageQueue() |
240 { | 240 { |
241 return adoptPtrWillBeNoop(new MessageQueue()); | 241 return adoptPtrWillBeNoop(new MessageQueue()); |
242 } | 242 } |
243 | 243 |
244 void RejectedPromises::dispose() | 244 void RejectedPromises::dispose() |
245 { | 245 { |
246 if (m_queue.isEmpty()) | 246 if (!m_queue.isEmpty()) { |
247 return; | 247 OwnPtrWillBeRawPtr<MessageQueue> queue = createMessageQueue(); |
248 | 248 queue->swap(m_queue); |
249 OwnPtrWillBeRawPtr<MessageQueue> queue = createMessageQueue(); | 249 processQueueNow(queue.release()); |
250 queue->swap(m_queue); | 250 } |
251 processQueueNow(queue.release()); | 251 m_reportedAsErrors.clear(); |
252 } | 252 } |
253 | 253 |
254 void RejectedPromises::processQueue() | 254 void RejectedPromises::processQueue() |
255 { | 255 { |
256 if (m_queue.isEmpty()) | 256 if (m_queue.isEmpty()) |
257 return; | 257 return; |
258 | 258 |
259 OwnPtrWillBeRawPtr<MessageQueue> queue = createMessageQueue(); | 259 OwnPtrWillBeRawPtr<MessageQueue> queue = createMessageQueue(); |
260 queue->swap(m_queue); | 260 queue->swap(m_queue); |
261 Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTa
sk(BLINK_FROM_HERE, new Task(bind(&RejectedPromises::processQueueNow, PassRefPtr
WillBeRawPtr<RejectedPromises>(this), queue.release()))); | 261 Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTa
sk(BLINK_FROM_HERE, new Task(bind(&RejectedPromises::processQueueNow, PassRefPtr
WillBeRawPtr<RejectedPromises>(this), queue.release()))); |
(...skipping 20 matching lines...) Expand all Loading... |
282 } | 282 } |
283 } | 283 } |
284 } | 284 } |
285 | 285 |
286 void RejectedPromises::revokeNow(PassOwnPtrWillBeRawPtr<Message> message) | 286 void RejectedPromises::revokeNow(PassOwnPtrWillBeRawPtr<Message> message) |
287 { | 287 { |
288 message->revoke(); | 288 message->revoke(); |
289 } | 289 } |
290 | 290 |
291 } // namespace blink | 291 } // namespace blink |
OLD | NEW |