Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(131)

Side by Side Diff: content/browser/service_worker/service_worker_controllee_request_handler.cc

Issue 2019613003: ServiceWorker: Bypass SW when the script doesn't have fetch handler (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Change the struct to class and move codes out of the ctor Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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) {
falken 2016/05/31 02:24:51 nit: const SWVersion*
shimazu 2016/05/31 04:15:10 Done.
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698