diff options
author | atwilson@chromium.org <atwilson@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2009-11-05 16:27:06 +0000 |
---|---|---|
committer | atwilson@chromium.org <atwilson@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2009-11-05 16:27:06 +0000 |
commit | 6898bbedb15bfddf91ea125e3ffde4b1789d9bf3 (patch) | |
tree | e3950c1d597f704af541572cfc39e9874131d667 /chrome/worker/webworker_stub_base.cc | |
parent | 1bbe5f61a331b2fb3cd1c0e18cf3aefa7105e635 (diff) | |
download | chromium_src-6898bbedb15bfddf91ea125e3ffde4b1789d9bf3.zip chromium_src-6898bbedb15bfddf91ea125e3ffde4b1789d9bf3.tar.gz chromium_src-6898bbedb15bfddf91ea125e3ffde4b1789d9bf3.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)
Committed: http://src.chromium.org/viewvc/chrome?view=rev&revision=31077
Review URL: http://codereview.chromium.org/351004
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@31096 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'chrome/worker/webworker_stub_base.cc')
-rw-r--r-- | chrome/worker/webworker_stub_base.cc | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/chrome/worker/webworker_stub_base.cc b/chrome/worker/webworker_stub_base.cc new file mode 100644 index 0000000..8ea2a15 --- /dev/null +++ b/chrome/worker/webworker_stub_base.cc @@ -0,0 +1,32 @@ +// 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/webworker_stub_base.h" + +#include "base/compiler_specific.h" +#include "chrome/common/child_process.h" +#include "chrome/worker/worker_thread.h" + +WebWorkerStubBase::WebWorkerStubBase(int route_id) + : route_id_(route_id), + ALLOW_THIS_IN_INITIALIZER_LIST(client_(route_id, this)) { + + // Start processing incoming IPCs for this worker. + WorkerThread::current()->AddRoute(route_id_, this); + ChildProcess::current()->AddRefProcess(); +} + +WebWorkerStubBase::~WebWorkerStubBase() { + WorkerThread::current()->RemoveRoute(route_id_); + ChildProcess::current()->ReleaseProcess(); +} + +void WebWorkerStubBase::Shutdown() { + // The worker has exited - free ourselves and the client. + delete this; +} + +void WebWorkerStubBase::EnsureWorkerContextTerminates() { + client_.EnsureWorkerContextTerminates(); +} |