| 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 |