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 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
82 IPC_MESSAGE_HANDLER_DELAY_REPLY( | 80 IPC_MESSAGE_HANDLER_DELAY_REPLY( |
83 WorkerProcessHostMsg_RequestFileSystemAccessSync, | 81 WorkerProcessHostMsg_RequestFileSystemAccessSync, |
84 OnRequestFileSystemAccess) | 82 OnRequestFileSystemAccess) |
85 IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowIndexedDB, OnAllowIndexedDB) | 83 IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowIndexedDB, OnAllowIndexedDB) |
86 IPC_MESSAGE_UNHANDLED(handled = false) | 84 IPC_MESSAGE_UNHANDLED(handled = false) |
87 IPC_END_MESSAGE_MAP() | 85 IPC_END_MESSAGE_MAP() |
88 return handled; | 86 return handled; |
89 } | 87 } |
90 | 88 |
91 int SharedWorkerMessageFilter::GetNextRoutingID() { | 89 int SharedWorkerMessageFilter::GetNextRoutingID() { |
92 return message_port_message_filter_->GetNextRoutingID(); | 90 return next_routing_id_callback_.Run(); |
93 } | 91 } |
94 | 92 |
95 void SharedWorkerMessageFilter::OnCreateWorker( | 93 void SharedWorkerMessageFilter::OnCreateWorker( |
96 const ViewHostMsg_CreateWorker_Params& params, | 94 const ViewHostMsg_CreateWorker_Params& params, |
97 ViewHostMsg_CreateWorker_Reply* reply) { | 95 ViewHostMsg_CreateWorker_Reply* reply) { |
98 reply->route_id = GetNextRoutingID(); | 96 reply->route_id = GetNextRoutingID(); |
99 reply->error = SharedWorkerServiceImpl::GetInstance()->CreateWorker( | 97 reply->error = SharedWorkerServiceImpl::GetInstance()->CreateWorker( |
100 params, reply->route_id, this, resource_context_, | 98 params, reply->route_id, this, resource_context_, |
101 WorkerStoragePartitionId(partition_)); | 99 WorkerStoragePartitionId(partition_)); |
102 } | 100 } |
103 | 101 |
104 void SharedWorkerMessageFilter::OnRequestFileSystemAccess( | 102 void SharedWorkerMessageFilter::OnRequestFileSystemAccess( |
105 int worker_route_id, | 103 int worker_route_id, |
106 const GURL& url, | 104 const GURL& url, |
107 IPC::Message* reply_msg) { | 105 IPC::Message* reply_msg) { |
108 SharedWorkerServiceImpl::GetInstance()->AllowFileSystem(this, worker_route_id, | 106 SharedWorkerServiceImpl::GetInstance()->AllowFileSystem(this, worker_route_id, |
109 url, reply_msg); | 107 url, reply_msg); |
110 } | 108 } |
111 | 109 |
112 void SharedWorkerMessageFilter::OnAllowIndexedDB(int worker_route_id, | 110 void SharedWorkerMessageFilter::OnAllowIndexedDB(int worker_route_id, |
113 const GURL& url, | 111 const GURL& url, |
114 const base::string16& name, | 112 const base::string16& name, |
115 bool* result) { | 113 bool* result) { |
116 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(this, worker_route_id, | 114 SharedWorkerServiceImpl::GetInstance()->AllowIndexedDB(this, worker_route_id, |
117 url, name, result); | 115 url, name, result); |
118 } | 116 } |
119 | 117 |
120 } // namespace content | 118 } // namespace content |
OLD | NEW |