| 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 |