#ifndef WorkerContext_h
#define WorkerContext_h
#if ENABLE(WORKERS)
#include "ContentSecurityPolicy.h"
#include "EventListener.h"
#include "EventNames.h"
#include "EventTarget.h"
#include "GroupSettings.h"
#include "ScriptExecutionContext.h"
#include "WorkerEventQueue.h"
#include "WorkerScriptController.h"
#include <wtf/Assertions.h>
#include <wtf/HashMap.h>
#include <wtf/OwnPtr.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
#include <wtf/text/AtomicStringHash.h>
namespace WebCore {
class Blob;
class DOMURL;
class ScheduledAction;
class WorkerInspectorController;
class WorkerLocation;
class WorkerNavigator;
class WorkerThread;
class WorkerContext : public RefCounted<WorkerContext>, public ScriptExecutionContext, public EventTarget {
public:
virtual ~WorkerContext();
virtual bool isWorkerContext() const OVERRIDE { return true; }
virtual ScriptExecutionContext* scriptExecutionContext() const OVERRIDE;
virtual bool isSharedWorkerContext() const { return false; }
virtual bool isDedicatedWorkerContext() const { return false; }
const KURL& url() const { return m_url; }
KURL completeURL(const String&) const;
const GroupSettings* groupSettings() { return m_groupSettings.get(); }
virtual String userAgent(const KURL&) const;
virtual void disableEval(const String& errorMessage) OVERRIDE;
WorkerScriptController* script() { return m_script.get(); }
void clearScript() { m_script.clear(); }
#if ENABLE(INSPECTOR)
void clearInspector();
#endif
WorkerThread* thread() const { return m_thread; }
bool hasPendingActivity() const;
virtual void postTask(PassOwnPtr<Task>) OVERRIDE;
WorkerContext* self() { return this; }
WorkerLocation* location() const;
void close();
DEFINE_ATTRIBUTE_EVENT_LISTENER(error);
virtual void importScripts(const Vector<String>& urls, ExceptionCode&);
WorkerNavigator* navigator() const;
int setTimeout(PassOwnPtr<ScheduledAction>, int timeout);
void clearTimeout(int timeoutId);
int setInterval(PassOwnPtr<ScheduledAction>, int timeout);
void clearInterval(int timeoutId);
virtual WorkerEventQueue* eventQueue() const OVERRIDE;
virtual bool isContextThread() const OVERRIDE;
virtual bool isJSExecutionForbidden() const OVERRIDE;
#if ENABLE(INSPECTOR)
WorkerInspectorController* workerInspectorController() { return m_workerInspectorController.get(); }
#endif
WorkerNavigator* optionalNavigator() const { return m_navigator.get(); }
WorkerLocation* optionalLocation() const { return m_location.get(); }
using RefCounted<WorkerContext>::ref;
using RefCounted<WorkerContext>::deref;
bool isClosing() { return m_closing; }
class Observer {
WTF_MAKE_NONCOPYABLE(Observer);
public:
Observer(WorkerContext*);
virtual ~Observer();
virtual void notifyStop() = 0;
void stopObserving();
private:
WorkerContext* m_context;
};
friend class Observer;
void registerObserver(Observer*);
void unregisterObserver(Observer*);
void notifyObserversOfStop();
virtual SecurityOrigin* topOrigin() const OVERRIDE { return m_topOrigin.get(); }
protected:
WorkerContext(const KURL&, const String& userAgent, PassOwnPtr<GroupSettings>, WorkerThread*, PassRefPtr<SecurityOrigin> topOrigin);
void applyContentSecurityPolicyFromString(const String& contentSecurityPolicy, ContentSecurityPolicy::HeaderType);
virtual void logExceptionToConsole(const String& errorMessage, const String& sourceURL, int lineNumber, int columnNumber, PassRefPtr<ScriptCallStack>) OVERRIDE;
void addMessageToWorkerConsole(MessageSource, MessageLevel, const String& message, const String& sourceURL, unsigned lineNumber, unsigned columnNumber, PassRefPtr<ScriptCallStack>, ScriptState* = 0, unsigned long requestIdentifier = 0);
private:
virtual void refScriptExecutionContext() OVERRIDE { ref(); }
virtual void derefScriptExecutionContext() OVERRIDE { deref(); }
virtual void refEventTarget() OVERRIDE { ref(); }
virtual void derefEventTarget() OVERRIDE { deref(); }
virtual EventTargetData* eventTargetData() OVERRIDE;
virtual EventTargetData* ensureEventTargetData() OVERRIDE;
virtual const KURL& virtualURL() const OVERRIDE;
virtual KURL virtualCompleteURL(const String&) const;
virtual void addMessage(MessageSource, MessageLevel, const String& message, const String& sourceURL, unsigned lineNumber, unsigned columnNumber, PassRefPtr<ScriptCallStack>, ScriptState* = 0, unsigned long requestIdentifier = 0) OVERRIDE;
virtual void addConsoleMessage(MessageSource, MessageLevel, const String& message, unsigned long requestIdentifier = 0) OVERRIDE;
virtual EventTarget* errorEventTarget() OVERRIDE;
KURL m_url;
String m_userAgent;
OwnPtr<GroupSettings> m_groupSettings;
mutable RefPtr<WorkerLocation> m_location;
mutable RefPtr<WorkerNavigator> m_navigator;
OwnPtr<WorkerScriptController> m_script;
WorkerThread* m_thread;
#if ENABLE(BLOB)
mutable RefPtr<DOMURL> m_domURL;
#endif
#if ENABLE(INSPECTOR)
OwnPtr<WorkerInspectorController> m_workerInspectorController;
#endif
bool m_closing;
EventTargetData m_eventTargetData;
HashSet<Observer*> m_workerObservers;
OwnPtr<WorkerEventQueue> m_eventQueue;
RefPtr<SecurityOrigin> m_topOrigin;
};
}
#endif // ENABLE(WORKERS)
#endif // WorkerContext_h