#ifndef WorkerContext_h
#define WorkerContext_h
#if ENABLE(WORKERS)
#include "AtomicStringHash.h"
#include "EventListener.h"
#include "EventTarget.h"
#include "ScriptExecutionContext.h"
#include "WorkerScriptController.h"
#include <wtf/OwnPtr.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
namespace WebCore {
class ScheduledAction;
class WorkerLocation;
class WorkerNavigator;
class WorkerThread;
class WorkerContext : public RefCounted<WorkerContext>, public ScriptExecutionContext, public EventTarget {
public:
static PassRefPtr<WorkerContext> create(const KURL& url, const String& userAgent, WorkerThread* thread)
{
return adoptRef(new WorkerContext(url, userAgent, thread));
}
virtual ~WorkerContext();
virtual bool isWorkerContext() const { return true; }
virtual WorkerContext* toWorkerContext() { return this; }
virtual ScriptExecutionContext* scriptExecutionContext() const;
const KURL& url() const { return m_url; }
KURL completeURL(const String&) const;
virtual String userAgent(const KURL&) const;
WorkerScriptController* script() { return m_script.get(); }
void clearScript() { return m_script.clear(); }
WorkerThread* thread() { return m_thread; }
bool hasPendingActivity() const;
virtual void reportException(const String& errorMessage, int lineNumber, const String& sourceURL);
virtual void addMessage(MessageDestination, MessageSource, MessageLevel, const String& message, unsigned lineNumber, const String& sourceURL);
virtual void resourceRetrievedByXMLHttpRequest(unsigned long identifier, const ScriptString& sourceString);
virtual void scriptImported(unsigned long identifier, const String& sourceString);
virtual void postTask(PassRefPtr<Task>);
WorkerContext* self() { return this; }
WorkerLocation* location() const;
void close();
void importScripts(const Vector<String>& urls, const String& callerURL, int callerLine, ExceptionCode&);
WorkerNavigator* navigator() const;
void postMessage(const String&, ExceptionCode&);
void postMessage(const String&, MessagePort*, ExceptionCode&);
void setOnmessage(PassRefPtr<EventListener> eventListener) { m_onmessageListener = eventListener; }
EventListener* onmessage() const { return m_onmessageListener.get(); }
int setTimeout(ScheduledAction*, int timeout);
void clearTimeout(int timeoutId);
int setInterval(ScheduledAction*, int timeout);
void clearInterval(int timeoutId);
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; }
void dispatchMessage(const String&, PassRefPtr<MessagePort>);
WorkerNavigator* optionalNavigator() const { return m_navigator.get(); }
WorkerLocation* optionalLocation() const { return m_location.get(); }
using RefCounted<WorkerContext>::ref;
using RefCounted<WorkerContext>::deref;
private:
WorkerContext(const KURL&, const String&, WorkerThread*);
virtual void refScriptExecutionContext() { ref(); }
virtual void derefScriptExecutionContext() { deref(); }
virtual void refEventTarget() { ref(); }
virtual void derefEventTarget() { deref(); }
virtual const KURL& virtualURL() const;
virtual KURL virtualCompleteURL(const String&) const;
KURL m_url;
String m_userAgent;
mutable RefPtr<WorkerLocation> m_location;
mutable RefPtr<WorkerNavigator> m_navigator;
OwnPtr<WorkerScriptController> m_script;
WorkerThread* m_thread;
RefPtr<EventListener> m_onmessageListener;
EventListenersMap m_eventListeners;
bool m_closing;
};
}
#endif // ENABLE(WORKERS)
#endif // WorkerContext_h