WebSharedWorkerImpl.h [plain text]
#ifndef WebSharedWorkerImpl_h
#define WebSharedWorkerImpl_h
#include "WebSharedWorker.h"
#if ENABLE(SHARED_WORKERS)
#include "ScriptExecutionContext.h"
#include "WebCommonWorkerClient.h"
#include "WebContentSecurityPolicy.h"
#include "WebFrameClient.h"
#include "WebSharedWorkerClient.h"
#include "WebWorkerBase.h"
#include "WorkerLoaderProxy.h"
#include "WorkerObjectProxy.h"
#include "WorkerThread.h"
#include <wtf/PassOwnPtr.h>
#include <wtf/RefPtr.h>
namespace WebKit {
class WebApplicationCacheHost;
class WebApplicationCacheHostClient;
class WebWorkerClient;
class WebSecurityOrigin;
class WebString;
class WebURL;
class WebView;
class WebWorker;
class WebSharedWorkerClient;
class WebSharedWorkerImpl : public WebCore::WorkerObjectProxy
, public WebWorkerBase
, public WebFrameClient
, public WebSharedWorker {
public:
explicit WebSharedWorkerImpl(WebSharedWorkerClient*);
virtual void postMessageToWorkerObject(
PassRefPtr<WebCore::SerializedScriptValue>,
PassOwnPtr<WebCore::MessagePortChannelArray>);
virtual void postExceptionToWorkerObject(
const WTF::String&, int, const WTF::String&);
virtual void postConsoleMessageToWorkerObject(
WebCore::MessageSource, WebCore::MessageType,
WebCore::MessageLevel, const WTF::String&, int, const WTF::String&);
virtual void postMessageToPageInspector(const WTF::String&);
virtual void updateInspectorStateCookie(const WTF::String&);
virtual void confirmMessageFromWorkerObject(bool);
virtual void reportPendingActivity(bool);
virtual void workerContextClosed();
virtual void workerContextDestroyed();
virtual WebView* view() const { return m_webView; }
virtual void postTaskToLoader(PassOwnPtr<WebCore::ScriptExecutionContext::Task>);
virtual bool postTaskForModeToWorkerContext(
PassOwnPtr<WebCore::ScriptExecutionContext::Task>, const WTF::String& mode);
virtual void didCreateDataSource(WebFrame*, WebDataSource*);
virtual WebApplicationCacheHost* createApplicationCacheHost(WebFrame*, WebApplicationCacheHostClient*);
virtual bool isStarted();
virtual void startWorkerContext(const WebURL&, const WebString& name, const WebString& userAgent, const WebString& sourceCode, const WebString& contentSecurityPolicy, WebContentSecurityPolicyType, long long cacheId);
virtual void connect(WebMessagePortChannel*, ConnectListener*);
virtual void terminateWorkerContext();
virtual void clientDestroyed();
virtual void pauseWorkerContextOnStart();
virtual void resumeWorkerContext();
virtual void attachDevTools();
virtual void reattachDevTools(const WebString& savedState);
virtual void detachDevTools();
virtual void dispatchDevToolsMessage(const WebString&);
WebCommonWorkerClient* commonClient() { return m_client; }
private:
virtual ~WebSharedWorkerImpl();
WebSharedWorkerClient* client() { return m_client; }
void setWorkerThread(PassRefPtr<WebCore::WorkerThread> thread) { m_workerThread = thread; }
WebCore::WorkerThread* workerThread() { return m_workerThread.get(); }
void stopWorkerThread();
void initializeLoader(const WebURL&);
static void connectTask(WebCore::ScriptExecutionContext*, PassOwnPtr<WebCore::MessagePortChannel>);
static void postMessageTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr,
WTF::String message,
PassOwnPtr<WebCore::MessagePortChannelArray> channels);
static void postExceptionTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr,
const WTF::String& message,
int lineNumber,
const WTF::String& sourceURL);
static void postConsoleMessageTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr,
int source,
int type,
int level,
const WTF::String& message,
int lineNumber,
const WTF::String& sourceURL);
static void postMessageToPageInspectorTask(WebCore::ScriptExecutionContext*, WebSharedWorkerImpl*, const WTF::String&);
static void updateInspectorStateCookieTask(WebCore::ScriptExecutionContext*, WebSharedWorkerImpl* thisPtr, const WTF::String& cookie);
static void confirmMessageTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr,
bool hasPendingActivity);
static void reportPendingActivityTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr,
bool hasPendingActivity);
static void workerContextClosedTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr);
static void workerContextDestroyedTask(
WebCore::ScriptExecutionContext*,
WebSharedWorkerImpl* thisPtr);
RefPtr<WebCore::ScriptExecutionContext> m_loadingDocument;
WebView* m_webView;
bool m_askedToTerminate;
RefPtr<WebCore::WorkerThread> m_workerThread;
WebSharedWorkerClient* m_client;
bool m_pauseWorkerContextOnStart;
};
}
#endif // ENABLE(SHARED_WORKERS)
#endif