| Index: chrome/renderer/websharedworker_proxy.cc
|
| ===================================================================
|
| --- chrome/renderer/websharedworker_proxy.cc (revision 78516)
|
| +++ chrome/renderer/websharedworker_proxy.cc (working copy)
|
| @@ -1,89 +0,0 @@
|
| -// 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/renderer/websharedworker_proxy.h"
|
| -
|
| -#include "chrome/common/render_messages.h"
|
| -#include "content/common/webmessageportchannel_impl.h"
|
| -#include "content/common/worker_messages.h"
|
| -#include "third_party/WebKit/Source/WebKit/chromium/public/WebURL.h"
|
| -
|
| -WebSharedWorkerProxy::WebSharedWorkerProxy(ChildThread* child_thread,
|
| - unsigned long long document_id,
|
| - bool exists,
|
| - int route_id,
|
| - int render_view_route_id)
|
| - : WebWorkerBase(child_thread,
|
| - document_id,
|
| - exists ? route_id : MSG_ROUTING_NONE,
|
| - render_view_route_id,
|
| - 0),
|
| - pending_route_id_(route_id),
|
| - connect_listener_(NULL) {
|
| -}
|
| -
|
| -bool WebSharedWorkerProxy::isStarted() {
|
| - return IsStarted();
|
| -}
|
| -
|
| -void WebSharedWorkerProxy::startWorkerContext(
|
| - const WebKit::WebURL& script_url,
|
| - const WebKit::WebString& name,
|
| - const WebKit::WebString& user_agent,
|
| - const WebKit::WebString& source_code,
|
| - long long script_resource_appcache_id) {
|
| - DCHECK(!isStarted());
|
| - CreateSharedWorkerContext(script_url, name, user_agent, source_code,
|
| - pending_route_id_, script_resource_appcache_id);
|
| -}
|
| -
|
| -void WebSharedWorkerProxy::terminateWorkerContext() {
|
| - // This API should only be invoked from worker context.
|
| - NOTREACHED();
|
| -}
|
| -
|
| -void WebSharedWorkerProxy::clientDestroyed() {
|
| - // This API should only be invoked from worker context.
|
| - NOTREACHED();
|
| -}
|
| -
|
| -void WebSharedWorkerProxy::connect(WebKit::WebMessagePortChannel* channel,
|
| - ConnectListener* listener) {
|
| - WebMessagePortChannelImpl* webchannel =
|
| - static_cast<WebMessagePortChannelImpl*>(channel);
|
| -
|
| - int message_port_id = webchannel->message_port_id();
|
| - DCHECK(message_port_id != MSG_ROUTING_NONE);
|
| - webchannel->QueueMessages();
|
| -
|
| - Send(new WorkerMsg_Connect(route_id_, message_port_id, MSG_ROUTING_NONE));
|
| - if (HasQueuedMessages()) {
|
| - connect_listener_ = listener;
|
| - } else {
|
| - listener->connected();
|
| - // The listener may free this object, so do not access the object after
|
| - // this point.
|
| - }
|
| -}
|
| -
|
| -bool WebSharedWorkerProxy::OnMessageReceived(const IPC::Message& message) {
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(WebSharedWorkerProxy, message)
|
| - IPC_MESSAGE_HANDLER(ViewMsg_WorkerCreated, OnWorkerCreated)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - return handled;
|
| -}
|
| -
|
| -void WebSharedWorkerProxy::OnWorkerCreated() {
|
| - // The worker is created - now send off the CreateWorkerContext message and
|
| - // any other queued messages
|
| - SendQueuedMessages();
|
| -
|
| - // Inform any listener that the pending connect event has been sent
|
| - // (this can result in this object being freed).
|
| - if (connect_listener_) {
|
| - connect_listener_->connected();
|
| - }
|
| -}
|
|
|