OLD | NEW |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |