diff options
author | atwilson@chromium.org <atwilson@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2009-11-05 06:29:08 +0000 |
---|---|---|
committer | atwilson@chromium.org <atwilson@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2009-11-05 06:29:08 +0000 |
commit | bec1ed112990143fe30b6cae4624fdde3015efce (patch) | |
tree | 24ca36e4bc748f6a872decfaccd7f41cac60c4b3 /chrome/worker/websharedworker_stub.cc | |
parent | c38a0c74b4a29e6eecb99babf7c98045f05c1c56 (diff) | |
download | chromium_src-bec1ed112990143fe30b6cae4624fdde3015efce.zip chromium_src-bec1ed112990143fe30b6cae4624fdde3015efce.tar.gz chromium_src-bec1ed112990143fe30b6cae4624fdde3015efce.tar.bz2 |
Added beginnings of browser-process support for shared workers.
Refactored WebWorkerClientProxy into two classes - WebWorkerDispatcher which dispatches incoming IPCs for the worker, and WebWorkerClientProxy, which handles outgoing API calls from WebWorkerImpl. This allows WebWorkerClientProxy to be reused by WebSharedWorkerDispatcher.
BUG=26233
TEST=none (will enable layout tests when basic functionality available)
Review URL: http://codereview.chromium.org/351004
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@31077 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'chrome/worker/websharedworker_stub.cc')
-rw-r--r-- | chrome/worker/websharedworker_stub.cc | 52 |
1 files changed, 52 insertions, 0 deletions
diff --git a/chrome/worker/websharedworker_stub.cc b/chrome/worker/websharedworker_stub.cc new file mode 100644 index 0000000..902f393 --- /dev/null +++ b/chrome/worker/websharedworker_stub.cc @@ -0,0 +1,52 @@ +// Copyright (c) 2009 The Chromium Authors. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "chrome/worker/websharedworker_stub.h" + +#include "chrome/common/webmessageportchannel_impl.h" +#include "chrome/common/worker_messages.h" +#include "webkit/api/public/WebSharedWorker.h" +#include "webkit/api/public/WebString.h" +#include "webkit/api/public/WebURL.h" + +WebSharedWorkerStub::WebSharedWorkerStub( + const string16& name, int route_id) + : WebWorkerStubBase(route_id), + name_(name) { + + // TODO(atwilson): Add support for NaCl when they support MessagePorts. + impl_ = WebKit::WebSharedWorker::create(client()); + +} + +WebSharedWorkerStub::~WebSharedWorkerStub() { + impl_->clientDestroyed(); +} + +void WebSharedWorkerStub::OnMessageReceived(const IPC::Message& message) { + IPC_BEGIN_MESSAGE_MAP(WebSharedWorkerStub, message) + IPC_MESSAGE_HANDLER(WorkerMsg_StartWorkerContext, OnStartWorkerContext) + IPC_MESSAGE_HANDLER(WorkerMsg_TerminateWorkerContext, + OnTerminateWorkerContext) + IPC_MESSAGE_HANDLER(WorkerMsg_Connect, OnConnect) + IPC_END_MESSAGE_MAP() +} + +void WebSharedWorkerStub::OnStartWorkerContext( + const GURL& url, const string16& user_agent, const string16& source_code) { + impl_->startWorkerContext(url, name_, user_agent, source_code); +} + +void WebSharedWorkerStub::OnConnect(int sent_message_port_id, int routing_id) { + WebKit::WebMessagePortChannel* channel = + new WebMessagePortChannelImpl(routing_id, sent_message_port_id); + impl_->connect(channel); +} + +void WebSharedWorkerStub::OnTerminateWorkerContext() { + impl_->terminateWorkerContext(); + + // Call the client to make sure context exits. + EnsureWorkerContextTerminates(); +} |