diff options
Diffstat (limited to 'Source/WebCore/dom/MessagePort.h')
-rw-r--r-- | Source/WebCore/dom/MessagePort.h | 119 |
1 files changed, 51 insertions, 68 deletions
diff --git a/Source/WebCore/dom/MessagePort.h b/Source/WebCore/dom/MessagePort.h index 9e043748b..1bf676d62 100644 --- a/Source/WebCore/dom/MessagePort.h +++ b/Source/WebCore/dom/MessagePort.h @@ -10,10 +10,10 @@ * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * - * THIS SOFTWARE IS PROVIDED BY APPLE COMPUTER, INC. ``AS IS'' AND ANY + * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR - * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE COMPUTER, INC. OR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR @@ -24,98 +24,81 @@ * */ -#ifndef MessagePort_h -#define MessagePort_h +#pragma once -#include "EventListener.h" #include "EventTarget.h" +#include "ExceptionOr.h" #include "MessagePortChannel.h" -#include <wtf/Forward.h> -#include <wtf/OwnPtr.h> -#include <wtf/PassOwnPtr.h> -#include <wtf/PassRefPtr.h> -#include <wtf/RefPtr.h> -#include <wtf/Vector.h> -namespace WebCore { +namespace JSC { +class ExecState; +class JSObject; +class JSValue; +} - class Event; - class Frame; - class MessagePort; - class ScriptExecutionContext; +namespace WebCore { - // The overwhelmingly common case is sending a single port, so handle that efficiently with an inline buffer of size 1. - typedef Vector<RefPtr<MessagePort>, 1> MessagePortArray; +class Frame; - class MessagePort final : public RefCounted<MessagePort>, public EventTargetWithInlineData { - public: - static PassRefPtr<MessagePort> create(ScriptExecutionContext& scriptExecutionContext) { return adoptRef(new MessagePort(scriptExecutionContext)); } - virtual ~MessagePort(); +class MessagePort final : public RefCounted<MessagePort>, public EventTargetWithInlineData { +public: + static Ref<MessagePort> create(ScriptExecutionContext& scriptExecutionContext) { return adoptRef(*new MessagePort(scriptExecutionContext)); } + virtual ~MessagePort(); - void postMessage(PassRefPtr<SerializedScriptValue> message, const MessagePortArray*, ExceptionCode&); - // Needed for Objective-C bindings (see bug 28774). - void postMessage(PassRefPtr<SerializedScriptValue> message, MessagePort*, ExceptionCode&); + ExceptionOr<void> postMessage(JSC::ExecState&, JSC::JSValue message, Vector<JSC::Strong<JSC::JSObject>>&&); - void start(); - void close(); + void start(); + void close(); - void entangle(PassOwnPtr<MessagePortChannel>); - PassOwnPtr<MessagePortChannel> disentangle(); + void entangle(std::unique_ptr<MessagePortChannel>&&); - // Returns 0 if there is an exception, or if the passed-in array is 0/empty. - static PassOwnPtr<MessagePortChannelArray> disentanglePorts(const MessagePortArray*, ExceptionCode&); + // Returns nullptr if the passed-in vector is empty. + static ExceptionOr<std::unique_ptr<MessagePortChannelArray>> disentanglePorts(Vector<RefPtr<MessagePort>>&&); - // Returns 0 if the passed array is 0/empty. - static PassOwnPtr<MessagePortArray> entanglePorts(ScriptExecutionContext&, PassOwnPtr<MessagePortChannelArray>); + static Vector<RefPtr<MessagePort>> entanglePorts(ScriptExecutionContext&, std::unique_ptr<MessagePortChannelArray>&&); - void messageAvailable(); - bool started() const { return m_started; } + void messageAvailable(); + bool started() const { return m_started; } - void contextDestroyed(); + void contextDestroyed(); - virtual EventTargetInterface eventTargetInterface() const override { return MessagePortEventTargetInterfaceType; } - virtual ScriptExecutionContext* scriptExecutionContext() const override { return m_scriptExecutionContext; } - virtual bool isMessagePort() const override { return true; } + ScriptExecutionContext* scriptExecutionContext() const final { return m_scriptExecutionContext; } - void dispatchMessages(); + void dispatchMessages(); - using RefCounted<MessagePort>::ref; - using RefCounted<MessagePort>::deref; + bool hasPendingActivity(); - bool hasPendingActivity(); + // Returns null if there is no entangled port, or if the entangled port is run by a different thread. + // This is used solely to enable a GC optimization. Some platforms may not be able to determine ownership + // of the remote port (since it may live cross-process) - those platforms may always return null. + MessagePort* locallyEntangledPort(); - void setOnmessage(PassRefPtr<EventListener> listener) - { - setAttributeEventListener(eventNames().messageEvent, listener); - start(); - } - EventListener* onmessage() { return getAttributeEventListener(eventNames().messageEvent); } + using RefCounted::ref; + using RefCounted::deref; - // Returns null if there is no entangled port, or if the entangled port is run by a different thread. - // This is used solely to enable a GC optimization. Some platforms may not be able to determine ownership - // of the remote port (since it may live cross-process) - those platforms may always return null. - MessagePort* locallyEntangledPort(); +private: + explicit MessagePort(ScriptExecutionContext&); - // A port starts out its life entangled, and remains entangled until it is closed or is cloned. - bool isEntangled() { return !m_closed && !isNeutered(); } + void refEventTarget() final { ref(); } + void derefEventTarget() final { deref(); } - // A port gets neutered when it is transferred to a new owner via postMessage(). - bool isNeutered() { return !m_entangledChannel; } + bool isMessagePort() const final { return true; } + EventTargetInterface eventTargetInterface() const final { return MessagePortEventTargetInterfaceType; } - private: - explicit MessagePort(ScriptExecutionContext&); + bool addEventListener(const AtomicString& eventType, Ref<EventListener>&&, const AddEventListenerOptions&) final; - virtual void refEventTarget() override { ref(); } - virtual void derefEventTarget() override { deref(); } + std::unique_ptr<MessagePortChannel> disentangle(); - OwnPtr<MessagePortChannel> m_entangledChannel; + // A port starts out its life entangled, and remains entangled until it is closed or is cloned. + bool isEntangled() const { return !m_closed && !isNeutered(); } - bool m_started; - bool m_closed; + // A port gets neutered when it is transferred to a new owner via postMessage(). + bool isNeutered() const { return !m_entangledChannel; } - ScriptExecutionContext* m_scriptExecutionContext; - }; + std::unique_ptr<MessagePortChannel> m_entangledChannel; + bool m_started { false }; + bool m_closed { false }; + ScriptExecutionContext* m_scriptExecutionContext; +}; } // namespace WebCore - -#endif // MessagePort_h |