#ifndef WorkerContext_h
#define WorkerContext_h
#if ENABLE(WORKERS)
#include "AtomicStringHash.h"
#include "Database.h"
#include "DatabaseCallback.h"
#include "EventListener.h"
#include "EventNames.h"
#include "EventTarget.h"
#include "ScriptExecutionContext.h"
#include "WorkerScriptController.h"
#include <wtf/Assertions.h>
#include <wtf/OwnPtr.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
namespace WebCore {
class Database;
class NotificationCenter;
class ScheduledAction;
class WorkerLocation;
class WorkerNavigator;
class WorkerThread;
class WorkerContext : public RefCounted<WorkerContext>, public ScriptExecutionContext, public EventTarget {
public:
virtual ~WorkerContext();
virtual bool isWorkerContext() const { return true; }
virtual ScriptExecutionContext* scriptExecutionContext() const;
virtual bool isSharedWorkerContext() const { return false; }
virtual bool isDedicatedWorkerContext() const { return false; }
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() { m_script.clear(); }
WorkerThread* thread() const { return m_thread; }
bool hasPendingActivity() const;
virtual void postTask(PassOwnPtr<Task>);
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(ScheduledAction*, int timeout);
void clearTimeout(int timeoutId);
int setInterval(ScheduledAction*, int timeout);
void clearInterval(int timeoutId);
virtual void reportException(const String& errorMessage, int lineNumber, const String& sourceURL);
virtual void addMessage(MessageSource, MessageType, MessageLevel, const String& message, unsigned lineNumber, const String& sourceURL);
#if ENABLE(NOTIFICATIONS)
NotificationCenter* webkitNotifications() const;
#endif
#if ENABLE(DATABASE)
PassRefPtr<Database> openDatabase(const String& name, const String& version, const String& displayName, unsigned long estimatedSize, PassRefPtr<DatabaseCallback> creationCallback, ExceptionCode&);
virtual bool isDatabaseReadOnly() const { return false; }
virtual void databaseExceededQuota(const String&) { }
#endif
virtual bool isContextThread() const;
virtual bool isJSExecutionTerminated() const;
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; }
protected:
WorkerContext(const KURL&, const String&, WorkerThread*);
private:
virtual void refScriptExecutionContext() { ref(); }
virtual void derefScriptExecutionContext() { deref(); }
virtual void refEventTarget() { ref(); }
virtual void derefEventTarget() { deref(); }
virtual EventTargetData* eventTargetData();
virtual EventTargetData* ensureEventTargetData();
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;
#if ENABLE_NOTIFICATIONS
mutable RefPtr<NotificationCenter> m_notifications;
#endif
bool m_closing;
bool m_reportingException;
EventTargetData m_eventTargetData;
};
}
#endif // ENABLE(WORKERS)
#endif // WorkerContext_h