#ifndef WebWorkerBase_h
#define WebWorkerBase_h
#if ENABLE(WORKERS)
#include "ScriptExecutionContext.h"
#include "WebFrameClient.h"
#include "WorkerLoaderProxy.h"
#include "WorkerObjectProxy.h"
#include <wtf/PassOwnPtr.h>
#include <wtf/RefPtr.h>
namespace WebCore {
class WorkerThread;
}
namespace WebKit {
class WebApplicationCacheHost;
class WebApplicationCacheHostClient;
class WebCommonWorkerClient;
class WebSecurityOrigin;
class WebString;
class WebURL;
class WebView;
class WebWorker;
class WebWorkerClient;
class WebWorkerBase : public WebCore::WorkerObjectProxy
, public WebCore::WorkerLoaderProxy
, public WebFrameClient {
public:
WebWorkerBase();
virtual ~WebWorkerBase();
virtual void postMessageToWorkerObject(
PassRefPtr<WebCore::SerializedScriptValue>,
PassOwnPtr<WebCore::MessagePortChannelArray>);
virtual void postExceptionToWorkerObject(
const WebCore::String&, int, const WebCore::String&);
virtual void postConsoleMessageToWorkerObject(
WebCore::MessageSource, WebCore::MessageType,
WebCore::MessageLevel, const WebCore::String&, int, const WebCore::String&);
virtual void confirmMessageFromWorkerObject(bool);
virtual void reportPendingActivity(bool);
virtual void workerContextClosed();
virtual void workerContextDestroyed();
virtual void postTaskToLoader(PassOwnPtr<WebCore::ScriptExecutionContext::Task>);
virtual void postTaskForModeToWorkerContext(
PassOwnPtr<WebCore::ScriptExecutionContext::Task>, const WebCore::String& mode);
virtual void didCreateDataSource(WebFrame*, WebDataSource*);
virtual WebApplicationCacheHost* createApplicationCacheHost(WebFrame*, WebApplicationCacheHostClient*);
static void dispatchTaskToMainThread(PassOwnPtr<WebCore::ScriptExecutionContext::Task>);
protected:
virtual WebWorkerClient* client() = 0;
virtual WebCommonWorkerClient* commonClient() = 0;
void setWorkerThread(PassRefPtr<WebCore::WorkerThread> thread) { m_workerThread = thread; }
WebCore::WorkerThread* workerThread() { return m_workerThread.get(); }
void stopWorkerThread();
void initializeLoader(const WebURL&);
private:
static void invokeTaskMethod(void*);
static void postMessageTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr,
WebCore::String message,
PassOwnPtr<WebCore::MessagePortChannelArray> channels);
static void postExceptionTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr,
const WebCore::String& message,
int lineNumber,
const WebCore::String& sourceURL);
static void postConsoleMessageTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr,
int source,
int type,
int level,
const WebCore::String& message,
int lineNumber,
const WebCore::String& sourceURL);
static void confirmMessageTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr,
bool hasPendingActivity);
static void reportPendingActivityTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr,
bool hasPendingActivity);
static void workerContextClosedTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr);
static void workerContextDestroyedTask(
WebCore::ScriptExecutionContext* context,
WebWorkerBase* thisPtr);
RefPtr<WebCore::ScriptExecutionContext> m_loadingDocument;
WebView* m_webView;
bool m_askedToTerminate;
RefPtr<WebCore::WorkerThread> m_workerThread;
};
}
#endif // ENABLE(WORKERS)
#endif