#ifndef Worker_h
#define Worker_h
#if ENABLE(WORKERS)
#include "AtomicStringHash.h"
#include "ActiveDOMObject.h"
#include "CachedResourceClient.h"
#include "CachedResourceHandle.h"
#include "EventListener.h"
#include "EventTarget.h"
#include <wtf/PassRefPtr.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
namespace WebCore {
class CachedResource;
class CachedScript;
class ScriptExecutionContext;
class String;
class WorkerContextProxy;
typedef int ExceptionCode;
class Worker : public RefCounted<Worker>, public ActiveDOMObject, private CachedResourceClient, public EventTarget {
public:
static PassRefPtr<Worker> create(const String& url, ScriptExecutionContext* context, ExceptionCode& ec) { return adoptRef(new Worker(url, context, ec)); }
~Worker();
virtual ScriptExecutionContext* scriptExecutionContext() const { return ActiveDOMObject::scriptExecutionContext(); }
virtual Worker* toWorker() { return this; }
void postMessage(const String& message);
void terminate();
void dispatchMessage(const String&);
void dispatchErrorEvent();
virtual bool canSuspend() const;
virtual void stop();
virtual bool hasPendingActivity() const;
virtual void addEventListener(const AtomicString& eventType, PassRefPtr<EventListener>, bool useCapture);
virtual void removeEventListener(const AtomicString& eventType, EventListener*, bool useCapture);
virtual bool dispatchEvent(PassRefPtr<Event>, ExceptionCode&);
typedef Vector<RefPtr<EventListener> > ListenerVector;
typedef HashMap<AtomicString, ListenerVector> EventListenersMap;
EventListenersMap& eventListeners() { return m_eventListeners; }
using RefCounted<Worker>::ref;
using RefCounted<Worker>::deref;
void setOnmessage(PassRefPtr<EventListener> eventListener) { m_onMessageListener = eventListener; }
EventListener* onmessage() const { return m_onMessageListener.get(); }
void setOnerror(PassRefPtr<EventListener> eventListener) { m_onErrorListener = eventListener; }
EventListener* onerror() const { return m_onErrorListener.get(); }
private:
Worker(const String&, ScriptExecutionContext*, ExceptionCode&);
virtual void notifyFinished(CachedResource*);
virtual void refEventTarget() { ref(); }
virtual void derefEventTarget() { deref(); }
KURL m_scriptURL;
CachedResourceHandle<CachedScript> m_cachedScript;
WorkerContextProxy* m_contextProxy;
RefPtr<EventListener> m_onMessageListener;
RefPtr<EventListener> m_onErrorListener;
EventListenersMap m_eventListeners;
};
}
#endif // ENABLE(WORKERS)
#endif // Worker_h