| 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_fetch_dispatcher.h" | 5 #include "content/browser/service_worker/service_worker_fetch_dispatcher.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| 11 #include "base/time/time.h" | 11 #include "base/time/time.h" |
| 12 #include "base/trace_event/trace_event.h" | 12 #include "base/trace_event/trace_event.h" |
| 13 #include "content/browser/service_worker/embedded_worker_status.h" | 13 #include "content/browser/service_worker/embedded_worker_status.h" |
| 14 #include "content/browser/service_worker/service_worker_version.h" | 14 #include "content/browser/service_worker/service_worker_version.h" |
| 15 #include "content/common/service_worker/fetch_event_dispatcher.mojom.h" | |
| 16 #include "content/common/service_worker/service_worker_messages.h" | 15 #include "content/common/service_worker/service_worker_messages.h" |
| 17 #include "content/common/service_worker/service_worker_status_code.h" | |
| 18 #include "content/common/service_worker/service_worker_utils.h" | 16 #include "content/common/service_worker/service_worker_utils.h" |
| 19 #include "net/log/net_log.h" | 17 #include "net/log/net_log.h" |
| 20 #include "net/log/net_log_capture_mode.h" | 18 #include "net/log/net_log_capture_mode.h" |
| 21 | 19 |
| 22 #include "net/log/net_log_event_type.h" | 20 #include "net/log/net_log_event_type.h" |
| 23 | 21 |
| 24 namespace content { | 22 namespace content { |
| 25 | 23 |
| 26 namespace { | 24 namespace { |
| 27 | 25 |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 base::Bind(&NetLogServiceWorkerStatusCallback, status)); | 67 base::Bind(&NetLogServiceWorkerStatusCallback, status)); |
| 70 } | 68 } |
| 71 | 69 |
| 72 ServiceWorkerMetrics::EventType FetchTypeToWaitUntilEventType( | 70 ServiceWorkerMetrics::EventType FetchTypeToWaitUntilEventType( |
| 73 ServiceWorkerFetchType type) { | 71 ServiceWorkerFetchType type) { |
| 74 if (type == ServiceWorkerFetchType::FOREIGN_FETCH) | 72 if (type == ServiceWorkerFetchType::FOREIGN_FETCH) |
| 75 return ServiceWorkerMetrics::EventType::FOREIGN_FETCH_WAITUNTIL; | 73 return ServiceWorkerMetrics::EventType::FOREIGN_FETCH_WAITUNTIL; |
| 76 return ServiceWorkerMetrics::EventType::FETCH_WAITUNTIL; | 74 return ServiceWorkerMetrics::EventType::FETCH_WAITUNTIL; |
| 77 } | 75 } |
| 78 | 76 |
| 79 void OnFetchEventFinished(ServiceWorkerVersion* version, | |
| 80 int event_finish_id, | |
| 81 ServiceWorkerStatusCode status, | |
| 82 base::Time dispatch_event_time) { | |
| 83 version->FinishRequest(event_finish_id, status != SERVICE_WORKER_ERROR_ABORT, | |
| 84 dispatch_event_time); | |
| 85 } | |
| 86 | |
| 87 } // namespace | 77 } // namespace |
| 88 | 78 |
| 89 // Helper to receive the fetch event response even if | 79 // Helper to receive the fetch event response even if |
| 90 // ServiceWorkerFetchDispatcher has been destroyed. | 80 // ServiceWorkerFetchDispatcher has been destroyed. |
| 91 class ServiceWorkerFetchDispatcher::ResponseCallback { | 81 class ServiceWorkerFetchDispatcher::ResponseCallback { |
| 92 public: | 82 public: |
| 93 ResponseCallback(base::WeakPtr<ServiceWorkerFetchDispatcher> fetch_dispatcher, | 83 ResponseCallback(base::WeakPtr<ServiceWorkerFetchDispatcher> fetch_dispatcher, |
| 94 ServiceWorkerVersion* version) | 84 ServiceWorkerVersion* version) |
| 95 : fetch_dispatcher_(fetch_dispatcher), version_(version) {} | 85 : fetch_dispatcher_(fetch_dispatcher), version_(version) {} |
| 96 | 86 |
| (...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 214 int event_finish_id = version_->StartRequest( | 204 int event_finish_id = version_->StartRequest( |
| 215 FetchTypeToWaitUntilEventType(request_->fetch_type), | 205 FetchTypeToWaitUntilEventType(request_->fetch_type), |
| 216 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); | 206 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); |
| 217 | 207 |
| 218 ResponseCallback* response_callback = | 208 ResponseCallback* response_callback = |
| 219 new ResponseCallback(weak_factory_.GetWeakPtr(), version_.get()); | 209 new ResponseCallback(weak_factory_.GetWeakPtr(), version_.get()); |
| 220 version_->RegisterRequestCallback<ServiceWorkerHostMsg_FetchEventResponse>( | 210 version_->RegisterRequestCallback<ServiceWorkerHostMsg_FetchEventResponse>( |
| 221 response_id, | 211 response_id, |
| 222 base::Bind(&ServiceWorkerFetchDispatcher::ResponseCallback::Run, | 212 base::Bind(&ServiceWorkerFetchDispatcher::ResponseCallback::Run, |
| 223 base::Owned(response_callback))); | 213 base::Owned(response_callback))); |
| 224 | 214 version_->RegisterSimpleRequest<ServiceWorkerHostMsg_FetchEventFinished>( |
| 225 base::WeakPtr<mojom::FetchEventDispatcher> dispatcher = | 215 event_finish_id); |
| 226 version_->GetMojoServiceForRequest<mojom::FetchEventDispatcher>( | 216 version_->DispatchEvent({response_id, event_finish_id}, |
| 227 event_finish_id); | 217 ServiceWorkerMsg_FetchEvent( |
| 228 // |dispatcher| is owned by |version_|. So it is safe to pass the unretained | 218 response_id, event_finish_id, *request_.get())); |
| 229 // raw pointer of |version_| to OnFetchEventFinished callback. | |
| 230 dispatcher->DispatchFetchEvent( | |
| 231 response_id, *request_, | |
| 232 base::Bind(&OnFetchEventFinished, base::Unretained(version_.get()), | |
| 233 event_finish_id)); | |
| 234 } | 219 } |
| 235 | 220 |
| 236 void ServiceWorkerFetchDispatcher::DidFailToDispatch( | 221 void ServiceWorkerFetchDispatcher::DidFailToDispatch( |
| 237 ServiceWorkerStatusCode status) { | 222 ServiceWorkerStatusCode status) { |
| 238 EndNetLogEventWithServiceWorkerStatus( | 223 EndNetLogEventWithServiceWorkerStatus( |
| 239 net_log_, net::NetLogEventType::SERVICE_WORKER_FETCH_EVENT, status); | 224 net_log_, net::NetLogEventType::SERVICE_WORKER_FETCH_EVENT, status); |
| 240 DidFail(status); | 225 DidFail(status); |
| 241 } | 226 } |
| 242 | 227 |
| 243 void ServiceWorkerFetchDispatcher::DidFail(ServiceWorkerStatusCode status) { | 228 void ServiceWorkerFetchDispatcher::DidFail(ServiceWorkerStatusCode status) { |
| (...skipping 27 matching lines...) Expand all Loading... |
| 271 } | 256 } |
| 272 | 257 |
| 273 ServiceWorkerMetrics::EventType ServiceWorkerFetchDispatcher::GetEventType() | 258 ServiceWorkerMetrics::EventType ServiceWorkerFetchDispatcher::GetEventType() |
| 274 const { | 259 const { |
| 275 if (request_->fetch_type == ServiceWorkerFetchType::FOREIGN_FETCH) | 260 if (request_->fetch_type == ServiceWorkerFetchType::FOREIGN_FETCH) |
| 276 return ServiceWorkerMetrics::EventType::FOREIGN_FETCH; | 261 return ServiceWorkerMetrics::EventType::FOREIGN_FETCH; |
| 277 return ResourceTypeToEventType(resource_type_); | 262 return ResourceTypeToEventType(resource_type_); |
| 278 } | 263 } |
| 279 | 264 |
| 280 } // namespace content | 265 } // namespace content |
| OLD | NEW |