| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "content/worker/webworker_stub.h" | |
| 6 | |
| 7 #include "base/command_line.h" | |
| 8 #include "content/common/child_thread.h" | |
| 9 #include "content/common/file_system/file_system_dispatcher.h" | |
| 10 #include "content/common/webmessageportchannel_impl.h" | |
| 11 #include "content/common/worker_messages.h" | |
| 12 #include "content/public/common/content_client.h" | |
| 13 #include "third_party/WebKit/Source/WebKit/chromium/public/WebString.h" | |
| 14 #include "third_party/WebKit/Source/WebKit/chromium/public/WebURL.h" | |
| 15 #include "third_party/WebKit/Source/WebKit/chromium/public/WebWorker.h" | |
| 16 | |
| 17 using WebKit::WebWorker; | |
| 18 | |
| 19 WebWorkerStub::WebWorkerStub(const GURL& url, int route_id, | |
| 20 const WorkerAppCacheInitInfo& appcache_init_info) | |
| 21 : WebWorkerStubBase(route_id, appcache_init_info), | |
| 22 ALLOW_THIS_IN_INITIALIZER_LIST(impl_(WebWorker::create(client()))), | |
| 23 url_(url) { | |
| 24 } | |
| 25 | |
| 26 WebWorkerStub::~WebWorkerStub() { | |
| 27 impl_->clientDestroyed(); | |
| 28 } | |
| 29 | |
| 30 void WebWorkerStub::OnChannelError() { | |
| 31 OnTerminateWorkerContext(); | |
| 32 } | |
| 33 | |
| 34 const GURL& WebWorkerStub::url() const { | |
| 35 return url_; | |
| 36 } | |
| 37 | |
| 38 bool WebWorkerStub::OnMessageReceived(const IPC::Message& message) { | |
| 39 if (!impl_) | |
| 40 return false; | |
| 41 | |
| 42 bool handled = true; | |
| 43 IPC_BEGIN_MESSAGE_MAP(WebWorkerStub, message) | |
| 44 IPC_MESSAGE_FORWARD(WorkerMsg_StartWorkerContext, impl_, | |
| 45 WebWorker::startWorkerContext) | |
| 46 IPC_MESSAGE_HANDLER(WorkerMsg_TerminateWorkerContext, | |
| 47 OnTerminateWorkerContext) | |
| 48 IPC_MESSAGE_HANDLER(WorkerMsg_PostMessage, OnPostMessage) | |
| 49 IPC_MESSAGE_FORWARD(WorkerMsg_WorkerObjectDestroyed, impl_, | |
| 50 WebWorker::workerObjectDestroyed) | |
| 51 IPC_MESSAGE_UNHANDLED(handled = false) | |
| 52 IPC_END_MESSAGE_MAP() | |
| 53 return handled; | |
| 54 } | |
| 55 | |
| 56 void WebWorkerStub::OnTerminateWorkerContext() { | |
| 57 impl_->terminateWorkerContext(); | |
| 58 | |
| 59 // Call the client to make sure context exits. | |
| 60 EnsureWorkerContextTerminates(); | |
| 61 } | |
| 62 | |
| 63 void WebWorkerStub::OnPostMessage( | |
| 64 const string16& message, | |
| 65 const std::vector<int>& sent_message_port_ids, | |
| 66 const std::vector<int>& new_routing_ids) { | |
| 67 WebKit::WebMessagePortChannelArray channels(sent_message_port_ids.size()); | |
| 68 for (size_t i = 0; i < sent_message_port_ids.size(); i++) { | |
| 69 channels[i] = new WebMessagePortChannelImpl( | |
| 70 new_routing_ids[i], sent_message_port_ids[i]); | |
| 71 } | |
| 72 | |
| 73 impl_->postMessageToWorkerContext(message, channels); | |
| 74 } | |
| OLD | NEW |