#ifndef MessagePort_h
#define MessagePort_h
#include "EventListener.h"
#include "EventTarget.h"
#include "MessagePortChannel.h"
#include <memory>
#include <wtf/Forward.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefPtr.h>
#include <wtf/Vector.h>
namespace WebCore {
class Event;
class Frame;
class MessagePort;
class ScriptExecutionContext;
typedef Vector<RefPtr<MessagePort>, 1> MessagePortArray;
class MessagePort final : public RefCounted<MessagePort>, public EventTargetWithInlineData {
public:
static PassRefPtr<MessagePort> create(ScriptExecutionContext& scriptExecutionContext) { return adoptRef(new MessagePort(scriptExecutionContext)); }
virtual ~MessagePort();
void postMessage(PassRefPtr<SerializedScriptValue> message, const MessagePortArray*, ExceptionCode&);
void postMessage(PassRefPtr<SerializedScriptValue> message, MessagePort*, ExceptionCode&);
void start();
void close();
void entangle(std::unique_ptr<MessagePortChannel>);
std::unique_ptr<MessagePortChannel> disentangle();
static std::unique_ptr<MessagePortChannelArray> disentanglePorts(const MessagePortArray*, ExceptionCode&);
static std::unique_ptr<MessagePortArray> entanglePorts(ScriptExecutionContext&, std::unique_ptr<MessagePortChannelArray>);
void messageAvailable();
bool started() const { return m_started; }
void contextDestroyed();
virtual EventTargetInterface eventTargetInterface() const override { return MessagePortEventTargetInterfaceType; }
virtual ScriptExecutionContext* scriptExecutionContext() const override { return m_scriptExecutionContext; }
virtual bool isMessagePort() const override { return true; }
void dispatchMessages();
using RefCounted<MessagePort>::ref;
using RefCounted<MessagePort>::deref;
bool hasPendingActivity();
void setOnmessage(PassRefPtr<EventListener> listener)
{
setAttributeEventListener(eventNames().messageEvent, listener);
start();
}
EventListener* onmessage() { return getAttributeEventListener(eventNames().messageEvent); }
MessagePort* locallyEntangledPort();
bool isEntangled() { return !m_closed && !isNeutered(); }
bool isNeutered() { return !m_entangledChannel; }
private:
explicit MessagePort(ScriptExecutionContext&);
virtual void refEventTarget() override { ref(); }
virtual void derefEventTarget() override { deref(); }
std::unique_ptr<MessagePortChannel> m_entangledChannel;
bool m_started;
bool m_closed;
ScriptExecutionContext* m_scriptExecutionContext;
};
}
#endif // MessagePort_h