Chromium Code Reviews| 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_url_request_job.h" | 5 #include "content/browser/service_worker/service_worker_url_request_job.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <limits> | 10 #include <limits> |
| 11 #include <map> | 11 #include <map> |
| 12 #include <memory> | 12 #include <memory> |
| 13 #include <string> | 13 #include <string> |
| 14 #include <utility> | 14 #include <utility> |
| 15 #include <vector> | 15 #include <vector> |
| 16 | 16 |
| 17 #include "base/bind.h" | 17 #include "base/bind.h" |
| 18 #include "base/guid.h" | 18 #include "base/guid.h" |
| 19 #include "base/location.h" | 19 #include "base/location.h" |
| 20 #include "base/single_thread_task_runner.h" | 20 #include "base/single_thread_task_runner.h" |
| 21 #include "base/strings/stringprintf.h" | 21 #include "base/strings/stringprintf.h" |
| 22 #include "base/threading/thread_task_runner_handle.h" | 22 #include "base/threading/thread_task_runner_handle.h" |
| 23 #include "base/time/time.h" | 23 #include "base/time/time.h" |
| 24 #include "content/browser/resource_context_impl.h" | 24 #include "content/browser/resource_context_impl.h" |
| 25 #include "content/browser/service_worker/embedded_worker_instance.h" | |
| 25 #include "content/browser/service_worker/service_worker_fetch_dispatcher.h" | 26 #include "content/browser/service_worker/service_worker_fetch_dispatcher.h" |
| 26 #include "content/browser/service_worker/service_worker_provider_host.h" | 27 #include "content/browser/service_worker/service_worker_provider_host.h" |
| 27 #include "content/browser/service_worker/service_worker_response_info.h" | 28 #include "content/browser/service_worker/service_worker_response_info.h" |
| 28 #include "content/browser/streams/stream.h" | 29 #include "content/browser/streams/stream.h" |
| 29 #include "content/browser/streams/stream_context.h" | 30 #include "content/browser/streams/stream_context.h" |
| 30 #include "content/browser/streams/stream_registry.h" | 31 #include "content/browser/streams/stream_registry.h" |
| 31 #include "content/common/resource_request_body.h" | 32 #include "content/common/resource_request_body.h" |
| 32 #include "content/common/service_worker/service_worker_types.h" | 33 #include "content/common/service_worker/service_worker_types.h" |
| 33 #include "content/common/service_worker/service_worker_utils.h" | 34 #include "content/common/service_worker/service_worker_utils.h" |
| 34 #include "content/public/browser/blob_handle.h" | 35 #include "content/public/browser/blob_handle.h" |
| (...skipping 590 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 625 NOTIMPLEMENTED(); | 626 NOTIMPLEMENTED(); |
| 626 } | 627 } |
| 627 } | 628 } |
| 628 | 629 |
| 629 request_body_blob_data_handle_ = | 630 request_body_blob_data_handle_ = |
| 630 blob_storage_context_->AddFinishedBlob(&blob_builder); | 631 blob_storage_context_->AddFinishedBlob(&blob_builder); |
| 631 *blob_uuid = uuid; | 632 *blob_uuid = uuid; |
| 632 *blob_size = total_size; | 633 *blob_size = total_size; |
| 633 } | 634 } |
| 634 | 635 |
| 635 void ServiceWorkerURLRequestJob::DidPrepareFetchEvent() { | 636 void ServiceWorkerURLRequestJob::DidPrepareFetchEvent( |
| 637 const scoped_refptr<ServiceWorkerVersion>& version) { | |
| 636 worker_ready_time_ = base::TimeTicks::Now(); | 638 worker_ready_time_ = base::TimeTicks::Now(); |
| 637 load_timing_info_.send_start = worker_ready_time_; | 639 load_timing_info_.send_start = worker_ready_time_; |
| 640 | |
| 641 if (resource_type_ == RESOURCE_TYPE_MAIN_FRAME && worker_already_activated_ && | |
| 642 !(version->skip_recording_startup_time() && | |
| 643 initial_worker_status_ != EmbeddedWorkerStatus::RUNNING) && | |
| 644 !ServiceWorkerMetrics::ShouldExcludeURLFromHistogram(request()->url())) { | |
| 645 ServiceWorkerMetrics::RecordActivatedWorkerPreparationTimeForMainFrame( | |
| 646 worker_ready_time_ - request()->creation_time(), initial_worker_status_, | |
|
falken
2016/06/07 03:46:12
When is request()->creation_time() set?
I'm wonde
horo
2016/06/07 05:58:12
This is set when net::URLRequest is created in Res
| |
| 647 version->embedded_worker()->start_situation()); | |
| 648 } | |
| 638 } | 649 } |
| 639 | 650 |
| 640 void ServiceWorkerURLRequestJob::DidDispatchFetchEvent( | 651 void ServiceWorkerURLRequestJob::DidDispatchFetchEvent( |
| 641 ServiceWorkerStatusCode status, | 652 ServiceWorkerStatusCode status, |
| 642 ServiceWorkerFetchEventResult fetch_result, | 653 ServiceWorkerFetchEventResult fetch_result, |
| 643 const ServiceWorkerResponse& response, | 654 const ServiceWorkerResponse& response, |
| 644 const scoped_refptr<ServiceWorkerVersion>& version) { | 655 const scoped_refptr<ServiceWorkerVersion>& version) { |
| 645 fetch_dispatcher_.reset(); | 656 fetch_dispatcher_.reset(); |
| 646 ServiceWorkerMetrics::RecordFetchEventStatus(IsMainResourceLoad(), status); | 657 ServiceWorkerMetrics::RecordFetchEventStatus(IsMainResourceLoad(), status); |
| 647 | 658 |
| (...skipping 307 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 955 ServiceWorkerMetrics::URLRequestJobResult result = | 966 ServiceWorkerMetrics::URLRequestJobResult result = |
| 956 ServiceWorkerMetrics::REQUEST_JOB_ERROR_BAD_DELEGATE; | 967 ServiceWorkerMetrics::REQUEST_JOB_ERROR_BAD_DELEGATE; |
| 957 ServiceWorkerVersion* active_worker = | 968 ServiceWorkerVersion* active_worker = |
| 958 delegate_->GetServiceWorkerVersion(&result); | 969 delegate_->GetServiceWorkerVersion(&result); |
| 959 if (!active_worker) { | 970 if (!active_worker) { |
| 960 RecordResult(result); | 971 RecordResult(result); |
| 961 DeliverErrorResponse(); | 972 DeliverErrorResponse(); |
| 962 return; | 973 return; |
| 963 } | 974 } |
| 964 | 975 |
| 976 worker_already_activated_ = | |
| 977 active_worker->status() == ServiceWorkerVersion::ACTIVATED; | |
| 978 initial_worker_status_ = active_worker->running_status(); | |
| 979 | |
| 965 DCHECK(!fetch_dispatcher_); | 980 DCHECK(!fetch_dispatcher_); |
| 966 fetch_dispatcher_.reset(new ServiceWorkerFetchDispatcher( | 981 fetch_dispatcher_.reset(new ServiceWorkerFetchDispatcher( |
| 967 CreateFetchRequest(), active_worker, resource_type_, | 982 CreateFetchRequest(), active_worker, resource_type_, |
| 968 base::Bind(&ServiceWorkerURLRequestJob::DidPrepareFetchEvent, | 983 base::Bind(&ServiceWorkerURLRequestJob::DidPrepareFetchEvent, |
| 969 weak_factory_.GetWeakPtr()), | 984 weak_factory_.GetWeakPtr(), active_worker), |
| 970 base::Bind(&ServiceWorkerURLRequestJob::DidDispatchFetchEvent, | 985 base::Bind(&ServiceWorkerURLRequestJob::DidDispatchFetchEvent, |
| 971 weak_factory_.GetWeakPtr()))); | 986 weak_factory_.GetWeakPtr()))); |
| 972 worker_start_time_ = base::TimeTicks::Now(); | 987 worker_start_time_ = base::TimeTicks::Now(); |
| 973 fetch_dispatcher_->Run(); | 988 fetch_dispatcher_->Run(); |
| 974 } | 989 } |
| 975 | 990 |
| 976 } // namespace content | 991 } // namespace content |
| OLD | NEW |