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

Side by Side Diff: content/browser/shared_worker/shared_worker_message_filter.cc

Issue 258513002: Introduce WorkerStoragePartitionId and use it in SharedWorkerInstance. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Hold WorkerStoragePartition in SharedWorkerMessageFilter Created 6 years, 8 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
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "content/browser/shared_worker/shared_worker_message_filter.h" 5 #include "content/browser/shared_worker/shared_worker_message_filter.h"
6 6
7 #include "content/browser/devtools/worker_devtools_manager.h" 7 #include "content/browser/devtools/worker_devtools_manager.h"
8 #include "content/browser/message_port_message_filter.h" 8 #include "content/browser/message_port_message_filter.h"
9 #include "content/browser/shared_worker/shared_worker_service_impl.h" 9 #include "content/browser/shared_worker/shared_worker_service_impl.h"
10 #include "content/common/devtools_messages.h" 10 #include "content/common/devtools_messages.h"
11 #include "content/common/view_messages.h" 11 #include "content/common/view_messages.h"
12 #include "content/common/worker_messages.h" 12 #include "content/common/worker_messages.h"
13 13
14 namespace content { 14 namespace content {
15 namespace { 15 namespace {
16 const uint32 kFilteredMessageClasses[] = { 16 const uint32 kFilteredMessageClasses[] = {
17 ViewMsgStart, 17 ViewMsgStart,
18 WorkerMsgStart, 18 WorkerMsgStart,
19 }; 19 };
20 } // namespace 20 } // namespace
21 21
22 SharedWorkerMessageFilter::SharedWorkerMessageFilter( 22 SharedWorkerMessageFilter::SharedWorkerMessageFilter(
23 int render_process_id, 23 int render_process_id,
24 ResourceContext* resource_context, 24 ResourceContext* resource_context,
25 const WorkerStoragePartition& partition, 25 const WorkerStoragePartition& partition,
26 MessagePortMessageFilter* message_port_message_filter) 26 MessagePortMessageFilter* message_port_message_filter)
27 : BrowserMessageFilter( 27 : BrowserMessageFilter(kFilteredMessageClasses,
28 kFilteredMessageClasses, arraysize(kFilteredMessageClasses)), 28 arraysize(kFilteredMessageClasses)),
29 render_process_id_(render_process_id), 29 render_process_id_(render_process_id),
30 resource_context_(resource_context), 30 resource_context_(resource_context),
31 partition_(partition), 31 partition_(partition),
32 message_port_message_filter_(message_port_message_filter) { 32 message_port_message_filter_(message_port_message_filter) {
33 } 33 }
34 34
35 SharedWorkerMessageFilter::~SharedWorkerMessageFilter() { 35 SharedWorkerMessageFilter::~SharedWorkerMessageFilter() {
36 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); 36 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
37 } 37 }
38 38
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
72 int SharedWorkerMessageFilter::GetNextRoutingID() { 72 int SharedWorkerMessageFilter::GetNextRoutingID() {
73 return message_port_message_filter_->GetNextRoutingID(); 73 return message_port_message_filter_->GetNextRoutingID();
74 } 74 }
75 75
76 void SharedWorkerMessageFilter::OnCreateWorker( 76 void SharedWorkerMessageFilter::OnCreateWorker(
77 const ViewHostMsg_CreateWorker_Params& params, 77 const ViewHostMsg_CreateWorker_Params& params,
78 int* route_id) { 78 int* route_id) {
79 bool url_error = false; 79 bool url_error = false;
80 *route_id = GetNextRoutingID(); 80 *route_id = GetNextRoutingID();
81 SharedWorkerServiceImpl::GetInstance()->CreateWorker( 81 SharedWorkerServiceImpl::GetInstance()->CreateWorker(
82 params, *route_id, this, resource_context_, partition_, &url_error); 82 params,
83 *route_id,
84 this,
85 resource_context_,
86 WorkerStoragePartitionId(partition_),
87 &url_error);
83 if (url_error) 88 if (url_error)
84 *route_id = MSG_ROUTING_NONE; 89 *route_id = MSG_ROUTING_NONE;
85 } 90 }
86 91
87 void SharedWorkerMessageFilter::OnForwardToWorker(const IPC::Message& message) { 92 void SharedWorkerMessageFilter::OnForwardToWorker(const IPC::Message& message) {
88 SharedWorkerServiceImpl::GetInstance()->ForwardToWorker(message, this); 93 SharedWorkerServiceImpl::GetInstance()->ForwardToWorker(message, this);
89 } 94 }
90 95
91 void SharedWorkerMessageFilter::OnDocumentDetached( 96 void SharedWorkerMessageFilter::OnDocumentDetached(
92 unsigned long long document_id) { 97 unsigned long long document_id) {
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after
153 const base::string16& name, 158 const base::string16& name,
154 bool* result) { 159 bool* result) {
155 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(worker_route_id, 160 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(worker_route_id,
156 url, 161 url,
157 name, 162 name,
158 result, 163 result,
159 this); 164 this);
160 } 165 }
161 166
162 } // namespace content 167 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698