Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(407)

Side by Side Diff: content/browser/worker_host/worker_message_filter.cc

Issue 411283002: Remove disable-embedded-shared-worker flag and shared worker process related codes. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(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/browser/worker_host/worker_message_filter.h"
6
7 #include "content/browser/message_port_message_filter.h"
8 #include "content/browser/worker_host/worker_service_impl.h"
9 #include "content/common/view_messages.h"
10 #include "content/common/worker_messages.h"
11 #include "content/public/browser/resource_context.h"
12
13 namespace content {
14
15 WorkerMessageFilter::WorkerMessageFilter(
16 int render_process_id,
17 ResourceContext* resource_context,
18 const WorkerStoragePartition& partition,
19 MessagePortMessageFilter* message_port_message_filter)
20 : BrowserMessageFilter(ViewMsgStart),
21 render_process_id_(render_process_id),
22 resource_context_(resource_context),
23 partition_(partition),
24 message_port_message_filter_(message_port_message_filter) {
25 // Note: This constructor is called on both IO or UI thread.
26 DCHECK(resource_context);
27 }
28
29 WorkerMessageFilter::~WorkerMessageFilter() {
30 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
31 }
32
33 void WorkerMessageFilter::OnChannelClosing() {
34 WorkerServiceImpl::GetInstance()->OnWorkerMessageFilterClosing(this);
35 }
36
37 bool WorkerMessageFilter::OnMessageReceived(const IPC::Message& message) {
38 bool handled = true;
39 IPC_BEGIN_MESSAGE_MAP(WorkerMessageFilter, message)
40 // Worker messages.
41 // Only sent from renderer for now, until we have nested workers.
42 IPC_MESSAGE_HANDLER(ViewHostMsg_CreateWorker, OnCreateWorker)
43 IPC_MESSAGE_HANDLER(ViewHostMsg_ForwardToWorker, OnForwardToWorker)
44 // Only sent from renderer.
45 IPC_MESSAGE_HANDLER(ViewHostMsg_DocumentDetached, OnDocumentDetached)
46 IPC_MESSAGE_UNHANDLED(handled = false)
47 IPC_END_MESSAGE_MAP()
48
49 return handled;
50 }
51
52 int WorkerMessageFilter::GetNextRoutingID() {
53 return message_port_message_filter_->GetNextRoutingID();
54 }
55
56 void WorkerMessageFilter::OnCreateWorker(
57 const ViewHostMsg_CreateWorker_Params& params,
58 int* route_id) {
59 bool url_error = false;
60 *route_id = GetNextRoutingID();
61 WorkerServiceImpl::GetInstance()->CreateWorker(
62 params, *route_id, this, resource_context_, partition_, &url_error);
63 if (url_error)
64 *route_id = MSG_ROUTING_NONE;
65 }
66
67 void WorkerMessageFilter::OnForwardToWorker(const IPC::Message& message) {
68 WorkerServiceImpl::GetInstance()->ForwardToWorker(message, this);
69 }
70
71 void WorkerMessageFilter::OnDocumentDetached(unsigned long long document_id) {
72 WorkerServiceImpl::GetInstance()->DocumentDetached(document_id, this);
73 }
74
75 } // namespace content
OLDNEW
« no previous file with comments | « content/browser/worker_host/worker_message_filter.h ('k') | content/browser/worker_host/worker_process_host.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698