#include "config.h"
#include "WebWorkerImpl.h"
#include "DedicatedWorkerContext.h"
#include "DedicatedWorkerThread.h"
#include "GenericWorkerTask.h"
#include "KURL.h"
#include "MessageEvent.h"
#include "MessagePort.h"
#include "MessagePortChannel.h"
#include "ScriptExecutionContext.h"
#include "SecurityOrigin.h"
#include "SerializedScriptValue.h"
#include "SubstituteData.h"
#include <wtf/Threading.h>
#include "PlatformMessagePortChannel.h"
#include "WebMessagePortChannel.h"
#include "WebString.h"
#include "WebURL.h"
#include "WebWorkerClient.h"
using namespace WebCore;
namespace WebKit {
#if ENABLE(WORKERS)
WebWorker* WebWorker::create(WebWorkerClient* client)
{
return new WebWorkerImpl(client);
}
WebWorkerImpl::WebWorkerImpl(WebWorkerClient* client)
: m_client(client)
{
}
WebWorkerImpl::~WebWorkerImpl()
{
}
WebCommonWorkerClient* WebWorkerImpl::commonClient()
{
return m_client;
}
void WebWorkerImpl::postMessageToWorkerContextTask(WebCore::ScriptExecutionContext* context,
WebWorkerImpl* thisPtr,
const String& message,
PassOwnPtr<MessagePortChannelArray> channels)
{
ASSERT(context->isWorkerContext());
DedicatedWorkerContext* workerContext =
static_cast<DedicatedWorkerContext*>(context);
OwnPtr<MessagePortArray> ports =
MessagePort::entanglePorts(*context, channels.release());
RefPtr<SerializedScriptValue> serializedMessage =
SerializedScriptValue::createFromWire(message);
workerContext->dispatchEvent(MessageEvent::create(
ports.release(), serializedMessage.release()));
thisPtr->confirmMessageFromWorkerObject(workerContext->hasPendingActivity());
}
void WebWorkerImpl::startWorkerContext(const WebURL& scriptUrl,
const WebString& userAgent,
const WebString& sourceCode)
{
initializeLoader(scriptUrl);
setWorkerThread(DedicatedWorkerThread::create(scriptUrl, userAgent,
sourceCode, *this, *this));
reportPendingActivity(true);
workerThread()->start();
}
void WebWorkerImpl::terminateWorkerContext()
{
stopWorkerThread();
}
void WebWorkerImpl::postMessageToWorkerContext(const WebString& message,
const WebMessagePortChannelArray& webChannels)
{
OwnPtr<MessagePortChannelArray> channels;
if (webChannels.size()) {
channels = new MessagePortChannelArray(webChannels.size());
for (size_t i = 0; i < webChannels.size(); ++i) {
RefPtr<PlatformMessagePortChannel> platform_channel =
PlatformMessagePortChannel::create(webChannels[i]);
webChannels[i]->setClient(platform_channel.get());
(*channels)[i] = MessagePortChannel::create(platform_channel);
}
}
workerThread()->runLoop().postTask(
createCallbackTask(&postMessageToWorkerContextTask,
this, String(message), channels.release()));
}
void WebWorkerImpl::workerObjectDestroyed()
{
terminateWorkerContext();
}
void WebWorkerImpl::clientDestroyed()
{
m_client = 0;
}
#else
WebWorker* WebWorker::create(WebWorkerClient* client)
{
return 0;
}
#endif // ENABLE(WORKERS)
}