Index: third_party/WebKit/Source/core/dom/MessagePort.cpp |
diff --git a/third_party/WebKit/Source/core/dom/MessagePort.cpp b/third_party/WebKit/Source/core/dom/MessagePort.cpp |
index 59fce934a79d9c58fa21f281327cfb4db6de5c66..17fc8bb34158352ab78408b5fdfc3ca45dacac78 100644 |
--- a/third_party/WebKit/Source/core/dom/MessagePort.cpp |
+++ b/third_party/WebKit/Source/core/dom/MessagePort.cpp |
@@ -39,9 +39,7 @@ |
#include "core/workers/WorkerGlobalScope.h" |
#include "public/platform/WebString.h" |
#include "wtf/Functional.h" |
-#include "wtf/PtrUtil.h" |
#include "wtf/text/AtomicString.h" |
-#include <memory> |
namespace blink { |
@@ -81,7 +79,7 @@ void MessagePort::postMessage(ExecutionContext* context, PassRefPtr<SerializedSc |
return; |
} |
} |
- std::unique_ptr<MessagePortChannelArray> channels = MessagePort::disentanglePorts(context, ports, exceptionState); |
+ OwnPtr<MessagePortChannelArray> channels = MessagePort::disentanglePorts(context, ports, exceptionState); |
if (exceptionState.hadException()) |
return; |
@@ -89,16 +87,16 @@ void MessagePort::postMessage(ExecutionContext* context, PassRefPtr<SerializedSc |
getExecutionContext()->addConsoleMessage(ConsoleMessage::create(JSMessageSource, WarningMessageLevel, "MessagePort cannot send an ArrayBuffer as a transferable object yet. See http://crbug.com/334408")); |
WebString messageString = message->toWireString(); |
- std::unique_ptr<WebMessagePortChannelArray> webChannels = toWebMessagePortChannelArray(std::move(channels)); |
- m_entangledChannel->postMessage(messageString, webChannels.release()); |
+ OwnPtr<WebMessagePortChannelArray> webChannels = toWebMessagePortChannelArray(std::move(channels)); |
+ m_entangledChannel->postMessage(messageString, webChannels.leakPtr()); |
} |
// static |
-std::unique_ptr<WebMessagePortChannelArray> MessagePort::toWebMessagePortChannelArray(std::unique_ptr<MessagePortChannelArray> channels) |
+PassOwnPtr<WebMessagePortChannelArray> MessagePort::toWebMessagePortChannelArray(PassOwnPtr<MessagePortChannelArray> channels) |
{ |
- std::unique_ptr<WebMessagePortChannelArray> webChannels; |
+ OwnPtr<WebMessagePortChannelArray> webChannels; |
if (channels && channels->size()) { |
- webChannels = wrapUnique(new WebMessagePortChannelArray(channels->size())); |
+ webChannels = adoptPtr(new WebMessagePortChannelArray(channels->size())); |
for (size_t i = 0; i < channels->size(); ++i) |
(*webChannels)[i] = (*channels)[i].release(); |
} |
@@ -108,7 +106,7 @@ std::unique_ptr<WebMessagePortChannelArray> MessagePort::toWebMessagePortChannel |
// static |
MessagePortArray* MessagePort::toMessagePortArray(ExecutionContext* context, const WebMessagePortChannelArray& webChannels) |
{ |
- std::unique_ptr<MessagePortChannelArray> channels = wrapUnique(new MessagePortChannelArray(webChannels.size())); |
+ OwnPtr<MessagePortChannelArray> channels = adoptPtr(new MessagePortChannelArray(webChannels.size())); |
for (size_t i = 0; i < webChannels.size(); ++i) |
(*channels)[i] = WebMessagePortChannelUniquePtr(webChannels[i]); |
return MessagePort::entanglePorts(*context, std::move(channels)); |
@@ -165,7 +163,7 @@ const AtomicString& MessagePort::interfaceName() const |
return EventTargetNames::MessagePort; |
} |
-static bool tryGetMessageFrom(WebMessagePortChannel& webChannel, RefPtr<SerializedScriptValue>& message, std::unique_ptr<MessagePortChannelArray>& channels) |
+static bool tryGetMessageFrom(WebMessagePortChannel& webChannel, RefPtr<SerializedScriptValue>& message, OwnPtr<MessagePortChannelArray>& channels) |
{ |
WebString messageString; |
WebMessagePortChannelArray webChannels; |
@@ -173,7 +171,7 @@ static bool tryGetMessageFrom(WebMessagePortChannel& webChannel, RefPtr<Serializ |
return false; |
if (webChannels.size()) { |
- channels = wrapUnique(new MessagePortChannelArray(webChannels.size())); |
+ channels = adoptPtr(new MessagePortChannelArray(webChannels.size())); |
for (size_t i = 0; i < webChannels.size(); ++i) |
(*channels)[i] = WebMessagePortChannelUniquePtr(webChannels[i]); |
} |
@@ -181,7 +179,7 @@ static bool tryGetMessageFrom(WebMessagePortChannel& webChannel, RefPtr<Serializ |
return true; |
} |
-bool MessagePort::tryGetMessage(RefPtr<SerializedScriptValue>& message, std::unique_ptr<MessagePortChannelArray>& channels) |
+bool MessagePort::tryGetMessage(RefPtr<SerializedScriptValue>& message, OwnPtr<MessagePortChannelArray>& channels) |
{ |
if (!m_entangledChannel) |
return false; |
@@ -200,7 +198,7 @@ void MessagePort::dispatchMessages() |
return; |
RefPtr<SerializedScriptValue> message; |
- std::unique_ptr<MessagePortChannelArray> channels; |
+ OwnPtr<MessagePortChannelArray> channels; |
while (tryGetMessage(message, channels)) { |
// close() in Worker onmessage handler should prevent next message from dispatching. |
if (getExecutionContext()->isWorkerGlobalScope() && toWorkerGlobalScope(getExecutionContext())->isClosing()) |
@@ -220,7 +218,7 @@ bool MessagePort::hasPendingActivity() const |
return m_started && isEntangled(); |
} |
-std::unique_ptr<MessagePortChannelArray> MessagePort::disentanglePorts(ExecutionContext* context, const MessagePortArray& ports, ExceptionState& exceptionState) |
+PassOwnPtr<MessagePortChannelArray> MessagePort::disentanglePorts(ExecutionContext* context, const MessagePortArray& ports, ExceptionState& exceptionState) |
{ |
if (!ports.size()) |
return nullptr; |
@@ -247,13 +245,13 @@ std::unique_ptr<MessagePortChannelArray> MessagePort::disentanglePorts(Execution |
UseCounter::count(context, UseCounter::MessagePortsTransferred); |
// Passed-in ports passed validity checks, so we can disentangle them. |
- std::unique_ptr<MessagePortChannelArray> portArray = wrapUnique(new MessagePortChannelArray(ports.size())); |
+ OwnPtr<MessagePortChannelArray> portArray = adoptPtr(new MessagePortChannelArray(ports.size())); |
for (unsigned i = 0; i < ports.size(); ++i) |
(*portArray)[i] = ports[i]->disentangle(); |
return portArray; |
} |
-MessagePortArray* MessagePort::entanglePorts(ExecutionContext& context, std::unique_ptr<MessagePortChannelArray> channels) |
+MessagePortArray* MessagePort::entanglePorts(ExecutionContext& context, PassOwnPtr<MessagePortChannelArray> channels) |
{ |
// https://html.spec.whatwg.org/multipage/comms.html#message-ports |
// |ports| should be an empty array, not null even when there is no ports. |