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 <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include "base/macros.h" | 9 #include "base/macros.h" |
10 #include "content/browser/message_port_message_filter.h" | |
11 #include "content/browser/shared_worker/shared_worker_service_impl.h" | 10 #include "content/browser/shared_worker/shared_worker_service_impl.h" |
12 #include "content/common/devtools_messages.h" | 11 #include "content/common/devtools_messages.h" |
13 #include "content/common/view_messages.h" | 12 #include "content/common/view_messages.h" |
14 #include "content/common/worker_messages.h" | 13 #include "content/common/worker_messages.h" |
15 #include "third_party/WebKit/public/web/WebSharedWorkerCreationErrors.h" | 14 #include "third_party/WebKit/public/web/WebSharedWorkerCreationErrors.h" |
16 | 15 |
17 namespace content { | 16 namespace content { |
18 namespace { | 17 namespace { |
19 | 18 |
20 const uint32_t kFilteredMessageClasses[] = { | 19 const uint32_t kFilteredMessageClasses[] = { |
21 ViewMsgStart, WorkerMsgStart, | 20 ViewMsgStart, WorkerMsgStart, |
22 }; | 21 }; |
23 | 22 |
24 } // namespace | 23 } // namespace |
25 | 24 |
26 SharedWorkerMessageFilter::SharedWorkerMessageFilter( | 25 SharedWorkerMessageFilter::SharedWorkerMessageFilter( |
27 int render_process_id, | 26 int render_process_id, |
28 ResourceContext* resource_context, | 27 ResourceContext* resource_context, |
29 const WorkerStoragePartition& partition, | 28 const WorkerStoragePartition& partition, |
30 MessagePortMessageFilter* message_port_message_filter) | 29 const NextRoutingIDCallback& next_routing_id_callback) |
31 : BrowserMessageFilter(kFilteredMessageClasses, | 30 : BrowserMessageFilter(kFilteredMessageClasses, |
32 arraysize(kFilteredMessageClasses)), | 31 arraysize(kFilteredMessageClasses)), |
33 render_process_id_(render_process_id), | 32 render_process_id_(render_process_id), |
34 resource_context_(resource_context), | 33 resource_context_(resource_context), |
35 partition_(partition), | 34 partition_(partition), |
36 message_port_message_filter_(message_port_message_filter) { | 35 next_routing_id_callback_(next_routing_id_callback) {} |
37 } | |
38 | 36 |
39 SharedWorkerMessageFilter::~SharedWorkerMessageFilter() { | 37 SharedWorkerMessageFilter::~SharedWorkerMessageFilter() { |
40 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 38 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
41 } | 39 } |
42 | 40 |
43 void SharedWorkerMessageFilter::OnChannelClosing() { | 41 void SharedWorkerMessageFilter::OnChannelClosing() { |
44 SharedWorkerServiceImpl::GetInstance()->OnSharedWorkerMessageFilterClosing( | 42 SharedWorkerServiceImpl::GetInstance()->OnSharedWorkerMessageFilterClosing( |
45 this); | 43 this); |
46 } | 44 } |
47 | 45 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
79 IPC_MESSAGE_HANDLER_DELAY_REPLY( | 77 IPC_MESSAGE_HANDLER_DELAY_REPLY( |
80 WorkerProcessHostMsg_RequestFileSystemAccessSync, | 78 WorkerProcessHostMsg_RequestFileSystemAccessSync, |
81 OnRequestFileSystemAccess) | 79 OnRequestFileSystemAccess) |
82 IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowIndexedDB, OnAllowIndexedDB) | 80 IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowIndexedDB, OnAllowIndexedDB) |
83 IPC_MESSAGE_UNHANDLED(handled = false) | 81 IPC_MESSAGE_UNHANDLED(handled = false) |
84 IPC_END_MESSAGE_MAP() | 82 IPC_END_MESSAGE_MAP() |
85 return handled; | 83 return handled; |
86 } | 84 } |
87 | 85 |
88 int SharedWorkerMessageFilter::GetNextRoutingID() { | 86 int SharedWorkerMessageFilter::GetNextRoutingID() { |
89 return message_port_message_filter_->GetNextRoutingID(); | 87 return next_routing_id_callback_.Run(); |
90 } | 88 } |
91 | 89 |
92 void SharedWorkerMessageFilter::OnCreateWorker( | 90 void SharedWorkerMessageFilter::OnCreateWorker( |
93 const ViewHostMsg_CreateWorker_Params& params, | 91 const ViewHostMsg_CreateWorker_Params& params, |
94 ViewHostMsg_CreateWorker_Reply* reply) { | 92 ViewHostMsg_CreateWorker_Reply* reply) { |
95 reply->route_id = GetNextRoutingID(); | 93 reply->route_id = GetNextRoutingID(); |
96 reply->error = SharedWorkerServiceImpl::GetInstance()->CreateWorker( | 94 reply->error = SharedWorkerServiceImpl::GetInstance()->CreateWorker( |
97 params, reply->route_id, this, resource_context_, | 95 params, reply->route_id, this, resource_context_, |
98 WorkerStoragePartitionId(partition_)); | 96 WorkerStoragePartitionId(partition_)); |
99 } | 97 } |
100 | 98 |
101 void SharedWorkerMessageFilter::OnRequestFileSystemAccess( | 99 void SharedWorkerMessageFilter::OnRequestFileSystemAccess( |
102 int worker_route_id, | 100 int worker_route_id, |
103 const GURL& url, | 101 const GURL& url, |
104 IPC::Message* reply_msg) { | 102 IPC::Message* reply_msg) { |
105 SharedWorkerServiceImpl::GetInstance()->AllowFileSystem(this, worker_route_id, | 103 SharedWorkerServiceImpl::GetInstance()->AllowFileSystem(this, worker_route_id, |
106 url, reply_msg); | 104 url, reply_msg); |
107 } | 105 } |
108 | 106 |
109 void SharedWorkerMessageFilter::OnAllowIndexedDB(int worker_route_id, | 107 void SharedWorkerMessageFilter::OnAllowIndexedDB(int worker_route_id, |
110 const GURL& url, | 108 const GURL& url, |
111 const base::string16& name, | 109 const base::string16& name, |
112 bool* result) { | 110 bool* result) { |
113 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(this, worker_route_id, | 111 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(this, worker_route_id, |
114 url, name, result); | 112 url, name, result); |
115 } | 113 } |
116 | 114 |
117 } // namespace content | 115 } // namespace content |
OLD | NEW |