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/service_worker/service_worker_controllee_request_handl
er.h" | 5 #include "content/browser/service_worker/service_worker_controllee_request_handl
er.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/trace_event/trace_event.h" | 10 #include "base/trace_event/trace_event.h" |
11 #include "content/browser/service_worker/service_worker_context_core.h" | 11 #include "content/browser/service_worker/service_worker_context_core.h" |
12 #include "content/browser/service_worker/service_worker_metrics.h" | 12 #include "content/browser/service_worker/service_worker_metrics.h" |
13 #include "content/browser/service_worker/service_worker_provider_host.h" | 13 #include "content/browser/service_worker/service_worker_provider_host.h" |
14 #include "content/browser/service_worker/service_worker_registration.h" | 14 #include "content/browser/service_worker/service_worker_registration.h" |
15 #include "content/browser/service_worker/service_worker_response_info.h" | 15 #include "content/browser/service_worker/service_worker_response_info.h" |
16 #include "content/browser/service_worker/service_worker_url_request_job.h" | 16 #include "content/browser/service_worker/service_worker_url_request_job.h" |
17 #include "content/common/resource_request_body.h" | 17 #include "content/common/resource_request_body.h" |
18 #include "content/common/service_worker/service_worker_types.h" | 18 #include "content/common/service_worker/service_worker_types.h" |
19 #include "content/common/service_worker/service_worker_utils.h" | 19 #include "content/common/service_worker/service_worker_utils.h" |
20 #include "content/public/browser/content_browser_client.h" | 20 #include "content/public/browser/content_browser_client.h" |
21 #include "content/public/common/content_client.h" | 21 #include "content/public/common/content_client.h" |
22 #include "content/public/common/resource_response_info.h" | 22 #include "content/public/common/resource_response_info.h" |
23 #include "net/base/load_flags.h" | 23 #include "net/base/load_flags.h" |
24 #include "net/base/url_util.h" | 24 #include "net/base/url_util.h" |
25 #include "net/url_request/url_request.h" | 25 #include "net/url_request/url_request.h" |
26 | 26 |
27 namespace content { | 27 namespace content { |
28 | 28 |
| 29 namespace { |
| 30 |
| 31 bool MaybeForwardToServiceWorker(ServiceWorkerURLRequestJob* job, |
| 32 ServiceWorkerVersion* version) { |
| 33 DCHECK(job); |
| 34 DCHECK(version); |
| 35 if (version->has_fetch_handler()) { |
| 36 job->ForwardToServiceWorker(); |
| 37 return true; |
| 38 } |
| 39 |
| 40 job->FallbackToNetwork(); |
| 41 return false; |
| 42 } |
| 43 |
| 44 } // namespace |
| 45 |
29 ServiceWorkerControlleeRequestHandler::ServiceWorkerControlleeRequestHandler( | 46 ServiceWorkerControlleeRequestHandler::ServiceWorkerControlleeRequestHandler( |
30 base::WeakPtr<ServiceWorkerContextCore> context, | 47 base::WeakPtr<ServiceWorkerContextCore> context, |
31 base::WeakPtr<ServiceWorkerProviderHost> provider_host, | 48 base::WeakPtr<ServiceWorkerProviderHost> provider_host, |
32 base::WeakPtr<storage::BlobStorageContext> blob_storage_context, | 49 base::WeakPtr<storage::BlobStorageContext> blob_storage_context, |
33 FetchRequestMode request_mode, | 50 FetchRequestMode request_mode, |
34 FetchCredentialsMode credentials_mode, | 51 FetchCredentialsMode credentials_mode, |
35 FetchRedirectMode redirect_mode, | 52 FetchRedirectMode redirect_mode, |
36 ResourceType resource_type, | 53 ResourceType resource_type, |
37 RequestContextType request_context_type, | 54 RequestContextType request_context_type, |
38 RequestContextFrameType frame_type, | 55 RequestContextFrameType frame_type, |
(...skipping 205 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
244 "ServiceWorker", | 261 "ServiceWorker", |
245 "ServiceWorkerControlleeRequestHandler::PrepareForMainResource", | 262 "ServiceWorkerControlleeRequestHandler::PrepareForMainResource", |
246 job_.get(), | 263 job_.get(), |
247 "Status", status, | 264 "Status", status, |
248 "Info", | 265 "Info", |
249 "ServiceWorkerVersion is not available, so falling back to network"); | 266 "ServiceWorkerVersion is not available, so falling back to network"); |
250 return; | 267 return; |
251 } | 268 } |
252 | 269 |
253 ServiceWorkerMetrics::CountControlledPageLoad(stripped_url_); | 270 ServiceWorkerMetrics::CountControlledPageLoad(stripped_url_); |
| 271 bool is_forwarded = |
| 272 MaybeForwardToServiceWorker(job_.get(), active_version.get()); |
254 | 273 |
255 job_->ForwardToServiceWorker(); | |
256 TRACE_EVENT_ASYNC_END2( | 274 TRACE_EVENT_ASYNC_END2( |
257 "ServiceWorker", | 275 "ServiceWorker", |
258 "ServiceWorkerControlleeRequestHandler::PrepareForMainResource", | 276 "ServiceWorkerControlleeRequestHandler::PrepareForMainResource", |
259 job_.get(), | 277 job_.get(), "Status", status, "Info", |
260 "Status", status, | 278 (is_forwarded) ? "Forwarded to the ServiceWorker" |
261 "Info", | 279 : "Skipped the ServiceWorker which has no fetch handler"); |
262 "Forwarded to the ServiceWorker"); | |
263 } | 280 } |
264 | 281 |
265 void ServiceWorkerControlleeRequestHandler::OnVersionStatusChanged( | 282 void ServiceWorkerControlleeRequestHandler::OnVersionStatusChanged( |
266 ServiceWorkerRegistration* registration, | 283 ServiceWorkerRegistration* registration, |
267 ServiceWorkerVersion* version) { | 284 ServiceWorkerVersion* version) { |
268 // The job may have been canceled and then destroyed before this was invoked. | 285 // The job may have been canceled and then destroyed before this was invoked. |
269 if (!job_) | 286 if (!job_) |
270 return; | 287 return; |
271 | 288 |
272 if (provider_host_) | 289 if (provider_host_) |
273 provider_host_->SetAllowAssociation(true); | 290 provider_host_->SetAllowAssociation(true); |
274 if (version != registration->active_version() || | 291 if (version != registration->active_version() || |
275 version->status() != ServiceWorkerVersion::ACTIVATED || | 292 version->status() != ServiceWorkerVersion::ACTIVATED || |
276 !provider_host_) { | 293 !provider_host_) { |
277 job_->FallbackToNetwork(); | 294 job_->FallbackToNetwork(); |
278 return; | 295 return; |
279 } | 296 } |
280 | 297 |
281 ServiceWorkerMetrics::CountControlledPageLoad(stripped_url_); | 298 ServiceWorkerMetrics::CountControlledPageLoad(stripped_url_); |
282 | 299 |
283 provider_host_->AssociateRegistration(registration, | 300 provider_host_->AssociateRegistration(registration, |
284 false /* notify_controllerchange */); | 301 false /* notify_controllerchange */); |
285 job_->ForwardToServiceWorker(); | 302 |
| 303 MaybeForwardToServiceWorker(job_.get(), version); |
286 } | 304 } |
287 | 305 |
288 void ServiceWorkerControlleeRequestHandler::DidUpdateRegistration( | 306 void ServiceWorkerControlleeRequestHandler::DidUpdateRegistration( |
289 const scoped_refptr<ServiceWorkerRegistration>& original_registration, | 307 const scoped_refptr<ServiceWorkerRegistration>& original_registration, |
290 ServiceWorkerStatusCode status, | 308 ServiceWorkerStatusCode status, |
291 const std::string& status_message, | 309 const std::string& status_message, |
292 int64_t registration_id) { | 310 int64_t registration_id) { |
293 DCHECK(force_update_started_); | 311 DCHECK(force_update_started_); |
294 | 312 |
295 // The job may have been canceled and then destroyed before this was invoked. | 313 // The job may have been canceled and then destroyed before this was invoked. |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
345 } | 363 } |
346 version->RegisterStatusChangeCallback( | 364 version->RegisterStatusChangeCallback( |
347 base::Bind(&self::OnUpdatedVersionStatusChanged, | 365 base::Bind(&self::OnUpdatedVersionStatusChanged, |
348 weak_factory_.GetWeakPtr(), registration, version)); | 366 weak_factory_.GetWeakPtr(), registration, version)); |
349 } | 367 } |
350 | 368 |
351 void ServiceWorkerControlleeRequestHandler::PrepareForSubResource() { | 369 void ServiceWorkerControlleeRequestHandler::PrepareForSubResource() { |
352 DCHECK(job_.get()); | 370 DCHECK(job_.get()); |
353 DCHECK(context_); | 371 DCHECK(context_); |
354 DCHECK(provider_host_->active_version()); | 372 DCHECK(provider_host_->active_version()); |
355 job_->ForwardToServiceWorker(); | 373 MaybeForwardToServiceWorker(job_.get(), provider_host_->active_version()); |
356 } | 374 } |
357 | 375 |
358 void ServiceWorkerControlleeRequestHandler::OnPrepareToRestart() { | 376 void ServiceWorkerControlleeRequestHandler::OnPrepareToRestart() { |
359 use_network_ = true; | 377 use_network_ = true; |
360 ClearJob(); | 378 ClearJob(); |
361 } | 379 } |
362 | 380 |
363 ServiceWorkerVersion* | 381 ServiceWorkerVersion* |
364 ServiceWorkerControlleeRequestHandler::GetServiceWorkerVersion( | 382 ServiceWorkerControlleeRequestHandler::GetServiceWorkerVersion( |
365 ServiceWorkerMetrics::URLRequestJobResult* result) { | 383 ServiceWorkerMetrics::URLRequestJobResult* result) { |
(...skipping 23 matching lines...) Expand all Loading... |
389 DCHECK(provider_host_); | 407 DCHECK(provider_host_); |
390 // Detach the controller so subresource requests also skip the worker. | 408 // Detach the controller so subresource requests also skip the worker. |
391 provider_host_->NotifyControllerLost(); | 409 provider_host_->NotifyControllerLost(); |
392 } | 410 } |
393 | 411 |
394 void ServiceWorkerControlleeRequestHandler::ClearJob() { | 412 void ServiceWorkerControlleeRequestHandler::ClearJob() { |
395 job_.reset(); | 413 job_.reset(); |
396 } | 414 } |
397 | 415 |
398 } // namespace content | 416 } // namespace content |
OLD | NEW |