#ifndef MessagePort_h
#define MessagePort_h
#include "AtomicStringHash.h"
#include "EventListener.h"
#include "EventNames.h"
#include "EventTarget.h"
#include "MessagePortChannel.h"
#include <wtf/HashMap.h>
#include <wtf/OwnPtr.h>
#include <wtf/PassOwnPtr.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefPtr.h>
#include <wtf/Vector.h>
namespace WebCore {
class AtomicStringImpl;
class Event;
class Frame;
class MessagePort;
class ScriptExecutionContext;
class String;
typedef Vector<RefPtr<MessagePort>, 1> MessagePortArray;
class MessagePort : public RefCounted<MessagePort>, public EventTarget {
public:
static PassRefPtr<MessagePort> create(ScriptExecutionContext& scriptExecutionContext) { return adoptRef(new MessagePort(scriptExecutionContext)); }
~MessagePort();
void postMessage(PassRefPtr<SerializedScriptValue> message, ExceptionCode&);
void postMessage(PassRefPtr<SerializedScriptValue> message, const MessagePortArray*, ExceptionCode&);
void postMessage(PassRefPtr<SerializedScriptValue> message, MessagePort*, ExceptionCode&);
void start();
void close();
void entangle(PassOwnPtr<MessagePortChannel>);
PassOwnPtr<MessagePortChannel> disentangle(ExceptionCode&);
static PassOwnPtr<MessagePortChannelArray> disentanglePorts(const MessagePortArray*, ExceptionCode&);
static PassOwnPtr<MessagePortArray> entanglePorts(ScriptExecutionContext&, PassOwnPtr<MessagePortChannelArray>);
void messageAvailable();
bool started() const { return m_started; }
void contextDestroyed();
virtual ScriptExecutionContext* scriptExecutionContext() const;
virtual MessagePort* toMessagePort() { return this; }
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 && !isCloned(); }
bool isCloned() { return !m_entangledChannel; }
private:
MessagePort(ScriptExecutionContext&);
virtual void refEventTarget() { ref(); }
virtual void derefEventTarget() { deref(); }
virtual EventTargetData* eventTargetData();
virtual EventTargetData* ensureEventTargetData();
OwnPtr<MessagePortChannel> m_entangledChannel;
bool m_started;
bool m_closed;
ScriptExecutionContext* m_scriptExecutionContext;
EventTargetData m_eventTargetData;
};
}
#endif // MessagePort_h