| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/service_worker/service_worker_dispatcher_host.h" | 5 #include "content/browser/service_worker/service_worker_dispatcher_host.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/strings/utf_string_conversions.h" | 8 #include "base/strings/utf_string_conversions.h" |
| 9 #include "content/browser/message_port_message_filter.h" | 9 #include "content/browser/message_port_message_filter.h" |
| 10 #include "content/browser/message_port_service.h" | 10 #include "content/browser/message_port_service.h" |
| 11 #include "content/browser/service_worker/embedded_worker_registry.h" | 11 #include "content/browser/service_worker/embedded_worker_registry.h" |
| 12 #include "content/browser/service_worker/service_worker_context_core.h" | 12 #include "content/browser/service_worker/service_worker_context_core.h" |
| 13 #include "content/browser/service_worker/service_worker_context_wrapper.h" | 13 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
| 14 #include "content/browser/service_worker/service_worker_handle.h" | 14 #include "content/browser/service_worker/service_worker_handle.h" |
| 15 #include "content/browser/service_worker/service_worker_registration.h" | 15 #include "content/browser/service_worker/service_worker_registration.h" |
| 16 #include "content/browser/service_worker/service_worker_utils.h" | 16 #include "content/browser/service_worker/service_worker_utils.h" |
| 17 #include "content/common/service_worker/embedded_worker_messages.h" | 17 #include "content/common/service_worker/embedded_worker_messages.h" |
| 18 #include "content/common/service_worker/service_worker_messages.h" | 18 #include "content/common/service_worker/service_worker_messages.h" |
| 19 #include "ipc/ipc_message_macros.h" | 19 #include "ipc/ipc_message_macros.h" |
| 20 #include "third_party/WebKit/public/platform/WebServiceWorkerError.h" | 20 #include "third_party/WebKit/public/platform/WebServiceWorkerError.h" |
| 21 #include "url/gurl.h" | 21 #include "url/gurl.h" |
| 22 | 22 |
| 23 using blink::WebServiceWorkerError; | 23 using blink::WebServiceWorkerError; |
| 24 | 24 |
| 25 namespace content { | 25 namespace content { |
| 26 | 26 |
| 27 namespace { | 27 namespace { |
| 28 | 28 |
| 29 const char kDisabledErrorMessage[] = | 29 const char kShutdownErrorMessage[] = |
| 30 "ServiceWorker is disabled"; | 30 "The Service Worker system has shutdown."; |
| 31 const char kDomainMismatchErrorMessage[] = | 31 const char kDomainMismatchErrorMessage[] = |
| 32 "Scope and scripts do not have the same origin"; | 32 "Scope and scripts do not have the same origin"; |
| 33 | 33 |
| 34 const uint32 kFilteredMessageClasses[] = { | 34 const uint32 kFilteredMessageClasses[] = { |
| 35 ServiceWorkerMsgStart, | 35 ServiceWorkerMsgStart, |
| 36 EmbeddedWorkerMsgStart, | 36 EmbeddedWorkerMsgStart, |
| 37 }; | 37 }; |
| 38 | 38 |
| 39 bool CanRegisterServiceWorker(const GURL& document_url, | 39 bool CanRegisterServiceWorker(const GURL& document_url, |
| 40 const GURL& pattern, | 40 const GURL& pattern, |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 157 int handle_id = handle->handle_id(); | 157 int handle_id = handle->handle_id(); |
| 158 handles_.AddWithID(handle.release(), handle_id); | 158 handles_.AddWithID(handle.release(), handle_id); |
| 159 } | 159 } |
| 160 | 160 |
| 161 void ServiceWorkerDispatcherHost::OnRegisterServiceWorker( | 161 void ServiceWorkerDispatcherHost::OnRegisterServiceWorker( |
| 162 int thread_id, | 162 int thread_id, |
| 163 int request_id, | 163 int request_id, |
| 164 int provider_id, | 164 int provider_id, |
| 165 const GURL& pattern, | 165 const GURL& pattern, |
| 166 const GURL& script_url) { | 166 const GURL& script_url) { |
| 167 if (!GetContext() || !ServiceWorkerUtils::IsFeatureEnabled()) { | 167 if (!GetContext()) { |
| 168 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 168 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 169 thread_id, | 169 thread_id, |
| 170 request_id, | 170 request_id, |
| 171 WebServiceWorkerError::ErrorTypeDisabled, | 171 WebServiceWorkerError::ErrorTypeAbort, |
| 172 base::ASCIIToUTF16(kDisabledErrorMessage))); | 172 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 173 return; | 173 return; |
| 174 } | 174 } |
| 175 | 175 |
| 176 ServiceWorkerProviderHost* provider_host = GetContext()->GetProviderHost( | 176 ServiceWorkerProviderHost* provider_host = GetContext()->GetProviderHost( |
| 177 render_process_id_, provider_id); | 177 render_process_id_, provider_id); |
| 178 if (!provider_host) { | 178 if (!provider_host) { |
| 179 BadMessageReceived(); | 179 BadMessageReceived(); |
| 180 return; | 180 return; |
| 181 } | 181 } |
| 182 if (!provider_host->IsContextAlive()) { | 182 if (!provider_host->IsContextAlive()) { |
| 183 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 183 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 184 thread_id, | 184 thread_id, |
| 185 request_id, | 185 request_id, |
| 186 WebServiceWorkerError::ErrorTypeDisabled, | 186 WebServiceWorkerError::ErrorTypeAbort, |
| 187 base::ASCIIToUTF16(kDisabledErrorMessage))); | 187 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 188 return; | 188 return; |
| 189 } | 189 } |
| 190 | 190 |
| 191 if (!CanRegisterServiceWorker( | 191 if (!CanRegisterServiceWorker( |
| 192 provider_host->document_url(), pattern, script_url)) { | 192 provider_host->document_url(), pattern, script_url)) { |
| 193 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 193 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 194 thread_id, | 194 thread_id, |
| 195 request_id, | 195 request_id, |
| 196 WebServiceWorkerError::ErrorTypeSecurity, | 196 WebServiceWorkerError::ErrorTypeSecurity, |
| 197 base::ASCIIToUTF16(kDomainMismatchErrorMessage))); | 197 base::ASCIIToUTF16(kDomainMismatchErrorMessage))); |
| 198 return; | 198 return; |
| 199 } | 199 } |
| 200 GetContext()->RegisterServiceWorker( | 200 GetContext()->RegisterServiceWorker( |
| 201 pattern, | 201 pattern, |
| 202 script_url, | 202 script_url, |
| 203 render_process_id_, | 203 render_process_id_, |
| 204 provider_host, | 204 provider_host, |
| 205 base::Bind(&ServiceWorkerDispatcherHost::RegistrationComplete, | 205 base::Bind(&ServiceWorkerDispatcherHost::RegistrationComplete, |
| 206 this, | 206 this, |
| 207 thread_id, | 207 thread_id, |
| 208 request_id)); | 208 request_id)); |
| 209 } | 209 } |
| 210 | 210 |
| 211 void ServiceWorkerDispatcherHost::OnUnregisterServiceWorker( | 211 void ServiceWorkerDispatcherHost::OnUnregisterServiceWorker( |
| 212 int thread_id, | 212 int thread_id, |
| 213 int request_id, | 213 int request_id, |
| 214 int provider_id, | 214 int provider_id, |
| 215 const GURL& pattern) { | 215 const GURL& pattern) { |
| 216 if (!GetContext() || !ServiceWorkerUtils::IsFeatureEnabled()) { | 216 if (!GetContext()) { |
| 217 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 217 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 218 thread_id, | 218 thread_id, |
| 219 request_id, | 219 request_id, |
| 220 blink::WebServiceWorkerError::ErrorTypeDisabled, | 220 blink::WebServiceWorkerError::ErrorTypeAbort, |
| 221 base::ASCIIToUTF16(kDisabledErrorMessage))); | 221 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 222 return; | 222 return; |
| 223 } | 223 } |
| 224 | 224 |
| 225 ServiceWorkerProviderHost* provider_host = GetContext()->GetProviderHost( | 225 ServiceWorkerProviderHost* provider_host = GetContext()->GetProviderHost( |
| 226 render_process_id_, provider_id); | 226 render_process_id_, provider_id); |
| 227 if (!provider_host) { | 227 if (!provider_host) { |
| 228 BadMessageReceived(); | 228 BadMessageReceived(); |
| 229 return; | 229 return; |
| 230 } | 230 } |
| 231 if (!provider_host->IsContextAlive()) { | 231 if (!provider_host->IsContextAlive()) { |
| 232 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 232 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 233 thread_id, | 233 thread_id, |
| 234 request_id, | 234 request_id, |
| 235 blink::WebServiceWorkerError::ErrorTypeDisabled, | 235 blink::WebServiceWorkerError::ErrorTypeAbort, |
| 236 base::ASCIIToUTF16(kDisabledErrorMessage))); | 236 base::ASCIIToUTF16(kShutdownErrorMessage))); |
| 237 return; | 237 return; |
| 238 } | 238 } |
| 239 | 239 |
| 240 if (!CanUnregisterServiceWorker(provider_host->document_url(), pattern)) { | 240 if (!CanUnregisterServiceWorker(provider_host->document_url(), pattern)) { |
| 241 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 241 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 242 thread_id, | 242 thread_id, |
| 243 request_id, | 243 request_id, |
| 244 WebServiceWorkerError::ErrorTypeSecurity, | 244 WebServiceWorkerError::ErrorTypeSecurity, |
| 245 base::ASCIIToUTF16(kDomainMismatchErrorMessage))); | 245 base::ASCIIToUTF16(kDomainMismatchErrorMessage))); |
| 246 return; | 246 return; |
| 247 } | 247 } |
| 248 | 248 |
| 249 GetContext()->UnregisterServiceWorker( | 249 GetContext()->UnregisterServiceWorker( |
| 250 pattern, | 250 pattern, |
| 251 base::Bind(&ServiceWorkerDispatcherHost::UnregistrationComplete, | 251 base::Bind(&ServiceWorkerDispatcherHost::UnregistrationComplete, |
| 252 this, | 252 this, |
| 253 thread_id, | 253 thread_id, |
| 254 request_id)); | 254 request_id)); |
| 255 } | 255 } |
| 256 | 256 |
| 257 void ServiceWorkerDispatcherHost::OnPostMessageToWorker( | 257 void ServiceWorkerDispatcherHost::OnPostMessageToWorker( |
| 258 int handle_id, | 258 int handle_id, |
| 259 const base::string16& message, | 259 const base::string16& message, |
| 260 const std::vector<int>& sent_message_port_ids) { | 260 const std::vector<int>& sent_message_port_ids) { |
| 261 if (!GetContext() || !ServiceWorkerUtils::IsFeatureEnabled()) | 261 if (!GetContext()) |
| 262 return; | 262 return; |
| 263 | 263 |
| 264 ServiceWorkerHandle* handle = handles_.Lookup(handle_id); | 264 ServiceWorkerHandle* handle = handles_.Lookup(handle_id); |
| 265 if (!handle) { | 265 if (!handle) { |
| 266 BadMessageReceived(); | 266 BadMessageReceived(); |
| 267 return; | 267 return; |
| 268 } | 268 } |
| 269 | 269 |
| 270 std::vector<int> new_routing_ids; | 270 std::vector<int> new_routing_ids; |
| 271 message_port_message_filter_->UpdateMessagePortsWithNewRoutes( | 271 message_port_message_filter_->UpdateMessagePortsWithNewRoutes( |
| (...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 448 status, &error_type, &error_message); | 448 status, &error_type, &error_message); |
| 449 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( | 449 Send(new ServiceWorkerMsg_ServiceWorkerRegistrationError( |
| 450 thread_id, request_id, error_type, error_message)); | 450 thread_id, request_id, error_type, error_message)); |
| 451 } | 451 } |
| 452 | 452 |
| 453 ServiceWorkerContextCore* ServiceWorkerDispatcherHost::GetContext() { | 453 ServiceWorkerContextCore* ServiceWorkerDispatcherHost::GetContext() { |
| 454 return context_wrapper_->context(); | 454 return context_wrapper_->context(); |
| 455 } | 455 } |
| 456 | 456 |
| 457 } // namespace content | 457 } // namespace content |
| OLD | NEW |