| Index: third_party/WebKit/Source/bindings/core/v8/RejectedPromises.cpp
|
| diff --git a/third_party/WebKit/Source/bindings/core/v8/RejectedPromises.cpp b/third_party/WebKit/Source/bindings/core/v8/RejectedPromises.cpp
|
| index 2661227470ac0759f7b83803a1774adbb0116511..b06ec4fdf91d9ba1d652a6d699302a08db4a9657 100644
|
| --- a/third_party/WebKit/Source/bindings/core/v8/RejectedPromises.cpp
|
| +++ b/third_party/WebKit/Source/bindings/core/v8/RejectedPromises.cpp
|
| @@ -19,6 +19,8 @@
|
| #include "public/platform/WebTaskRunner.h"
|
| #include "public/platform/WebThread.h"
|
| #include "wtf/Functional.h"
|
| +#include "wtf/PtrUtil.h"
|
| +#include <memory>
|
|
|
| namespace blink {
|
|
|
| @@ -26,9 +28,9 @@ static const unsigned maxReportedHandlersPendingResolution = 1000;
|
|
|
| class RejectedPromises::Message final {
|
| public:
|
| - static PassOwnPtr<Message> create(ScriptState* scriptState, v8::Local<v8::Promise> promise, v8::Local<v8::Value> exception, const String& errorMessage, PassOwnPtr<SourceLocation> location, AccessControlStatus corsStatus)
|
| + static std::unique_ptr<Message> create(ScriptState* scriptState, v8::Local<v8::Promise> promise, v8::Local<v8::Value> exception, const String& errorMessage, std::unique_ptr<SourceLocation> location, AccessControlStatus corsStatus)
|
| {
|
| - return adoptPtr(new Message(scriptState, promise, exception, errorMessage, std::move(location), corsStatus));
|
| + return wrapUnique(new Message(scriptState, promise, exception, errorMessage, std::move(location), corsStatus));
|
| }
|
|
|
| bool isCollected()
|
| @@ -145,7 +147,7 @@ public:
|
| }
|
|
|
| private:
|
| - Message(ScriptState* scriptState, v8::Local<v8::Promise> promise, v8::Local<v8::Value> exception, const String& errorMessage, PassOwnPtr<SourceLocation> location, AccessControlStatus corsStatus)
|
| + Message(ScriptState* scriptState, v8::Local<v8::Promise> promise, v8::Local<v8::Value> exception, const String& errorMessage, std::unique_ptr<SourceLocation> location, AccessControlStatus corsStatus)
|
| : m_scriptState(scriptState)
|
| , m_promise(scriptState->isolate(), promise)
|
| , m_exception(scriptState->isolate(), exception)
|
| @@ -175,7 +177,7 @@ private:
|
| ScopedPersistent<v8::Value> m_exception;
|
| String m_errorMessage;
|
| String m_resourceName;
|
| - OwnPtr<SourceLocation> m_location;
|
| + std::unique_ptr<SourceLocation> m_location;
|
| unsigned m_consoleMessageId;
|
| bool m_collected;
|
| bool m_shouldLogToConsole;
|
| @@ -190,7 +192,7 @@ RejectedPromises::~RejectedPromises()
|
| {
|
| }
|
|
|
| -void RejectedPromises::rejectedWithNoHandler(ScriptState* scriptState, v8::PromiseRejectMessage data, const String& errorMessage, PassOwnPtr<SourceLocation> location, AccessControlStatus corsStatus)
|
| +void RejectedPromises::rejectedWithNoHandler(ScriptState* scriptState, v8::PromiseRejectMessage data, const String& errorMessage, std::unique_ptr<SourceLocation> location, AccessControlStatus corsStatus)
|
| {
|
| m_queue.append(Message::create(scriptState, data.GetPromise(), data.GetValue(), errorMessage, std::move(location), corsStatus));
|
| }
|
| @@ -207,19 +209,19 @@ void RejectedPromises::handlerAdded(v8::PromiseRejectMessage data)
|
|
|
| // Then look it up in the reported errors.
|
| for (size_t i = 0; i < m_reportedAsErrors.size(); ++i) {
|
| - OwnPtr<Message>& message = m_reportedAsErrors.at(i);
|
| + std::unique_ptr<Message>& message = m_reportedAsErrors.at(i);
|
| if (!message->isCollected() && message->hasPromise(data.GetPromise())) {
|
| message->makePromiseStrong();
|
| - Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTask(BLINK_FROM_HERE, bind(&RejectedPromises::revokeNow, this, passed(std::move(message))));
|
| + Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&RejectedPromises::revokeNow, this, passed(std::move(message))));
|
| m_reportedAsErrors.remove(i);
|
| return;
|
| }
|
| }
|
| }
|
|
|
| -PassOwnPtr<RejectedPromises::MessageQueue> RejectedPromises::createMessageQueue()
|
| +std::unique_ptr<RejectedPromises::MessageQueue> RejectedPromises::createMessageQueue()
|
| {
|
| - return adoptPtr(new MessageQueue());
|
| + return wrapUnique(new MessageQueue());
|
| }
|
|
|
| void RejectedPromises::dispose()
|
| @@ -227,7 +229,7 @@ void RejectedPromises::dispose()
|
| if (m_queue.isEmpty())
|
| return;
|
|
|
| - OwnPtr<MessageQueue> queue = createMessageQueue();
|
| + std::unique_ptr<MessageQueue> queue = createMessageQueue();
|
| queue->swap(m_queue);
|
| processQueueNow(std::move(queue));
|
| }
|
| @@ -237,12 +239,12 @@ void RejectedPromises::processQueue()
|
| if (m_queue.isEmpty())
|
| return;
|
|
|
| - OwnPtr<MessageQueue> queue = createMessageQueue();
|
| + std::unique_ptr<MessageQueue> queue = createMessageQueue();
|
| queue->swap(m_queue);
|
| - Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTask(BLINK_FROM_HERE, bind(&RejectedPromises::processQueueNow, PassRefPtr<RejectedPromises>(this), passed(std::move(queue))));
|
| + Platform::current()->currentThread()->scheduler()->timerTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&RejectedPromises::processQueueNow, PassRefPtr<RejectedPromises>(this), passed(std::move(queue))));
|
| }
|
|
|
| -void RejectedPromises::processQueueNow(PassOwnPtr<MessageQueue> queue)
|
| +void RejectedPromises::processQueueNow(std::unique_ptr<MessageQueue> queue)
|
| {
|
| // Remove collected handlers.
|
| for (size_t i = 0; i < m_reportedAsErrors.size();) {
|
| @@ -253,7 +255,7 @@ void RejectedPromises::processQueueNow(PassOwnPtr<MessageQueue> queue)
|
| }
|
|
|
| while (!queue->isEmpty()) {
|
| - OwnPtr<Message> message = queue->takeFirst();
|
| + std::unique_ptr<Message> message = queue->takeFirst();
|
| if (message->isCollected())
|
| continue;
|
| if (!message->hasHandler()) {
|
| @@ -266,7 +268,7 @@ void RejectedPromises::processQueueNow(PassOwnPtr<MessageQueue> queue)
|
| }
|
| }
|
|
|
| -void RejectedPromises::revokeNow(PassOwnPtr<Message> message)
|
| +void RejectedPromises::revokeNow(std::unique_ptr<Message> message)
|
| {
|
| message->revoke();
|
| }
|
|
|