| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/renderer/service_worker/service_worker_context_client.h" | 5 #include "content/renderer/service_worker/service_worker_context_client.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
| (...skipping 154 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 165 struct ServiceWorkerContextClient::WorkerContextData { | 165 struct ServiceWorkerContextClient::WorkerContextData { |
| 166 using ClientsCallbacksMap = | 166 using ClientsCallbacksMap = |
| 167 IDMap<blink::WebServiceWorkerClientsCallbacks, IDMapOwnPointer>; | 167 IDMap<blink::WebServiceWorkerClientsCallbacks, IDMapOwnPointer>; |
| 168 using ClaimClientsCallbacksMap = | 168 using ClaimClientsCallbacksMap = |
| 169 IDMap<blink::WebServiceWorkerClientsClaimCallbacks, IDMapOwnPointer>; | 169 IDMap<blink::WebServiceWorkerClientsClaimCallbacks, IDMapOwnPointer>; |
| 170 using ClientCallbacksMap = | 170 using ClientCallbacksMap = |
| 171 IDMap<blink::WebServiceWorkerClientCallbacks, IDMapOwnPointer>; | 171 IDMap<blink::WebServiceWorkerClientCallbacks, IDMapOwnPointer>; |
| 172 using SkipWaitingCallbacksMap = | 172 using SkipWaitingCallbacksMap = |
| 173 IDMap<blink::WebServiceWorkerSkipWaitingCallbacks, IDMapOwnPointer>; | 173 IDMap<blink::WebServiceWorkerSkipWaitingCallbacks, IDMapOwnPointer>; |
| 174 using SyncEventCallbacksMap = | 174 using SyncEventCallbacksMap = |
| 175 IDMap<const mojo::Callback<void(mojom::ServiceWorkerEventStatus)>, | 175 IDMap<const mojo::Callback<void(blink::mojom::ServiceWorkerEventStatus)>, |
| 176 IDMapOwnPointer>; | 176 IDMapOwnPointer>; |
| 177 | 177 |
| 178 explicit WorkerContextData(ServiceWorkerContextClient* owner) | 178 explicit WorkerContextData(ServiceWorkerContextClient* owner) |
| 179 : weak_factory(owner), proxy_weak_factory(owner->proxy_) {} | 179 : weak_factory(owner), proxy_weak_factory(owner->proxy_) {} |
| 180 | 180 |
| 181 ~WorkerContextData() { | 181 ~WorkerContextData() { |
| 182 DCHECK(thread_checker.CalledOnValidThread()); | 182 DCHECK(thread_checker.CalledOnValidThread()); |
| 183 } | 183 } |
| 184 | 184 |
| 185 // Pending callbacks for GetClientDocuments(). | 185 // Pending callbacks for GetClientDocuments(). |
| (...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 545 } | 545 } |
| 546 | 546 |
| 547 void ServiceWorkerContextClient::didHandleSyncEvent( | 547 void ServiceWorkerContextClient::didHandleSyncEvent( |
| 548 int request_id, | 548 int request_id, |
| 549 blink::WebServiceWorkerEventResult result) { | 549 blink::WebServiceWorkerEventResult result) { |
| 550 const SyncCallback* callback = | 550 const SyncCallback* callback = |
| 551 context_->sync_event_callbacks.Lookup(request_id); | 551 context_->sync_event_callbacks.Lookup(request_id); |
| 552 if (!callback) | 552 if (!callback) |
| 553 return; | 553 return; |
| 554 if (result == blink::WebServiceWorkerEventResultCompleted) { | 554 if (result == blink::WebServiceWorkerEventResultCompleted) { |
| 555 callback->Run(mojom::ServiceWorkerEventStatus::COMPLETED); | 555 callback->Run(blink::mojom::ServiceWorkerEventStatus::COMPLETED); |
| 556 } else { | 556 } else { |
| 557 callback->Run(mojom::ServiceWorkerEventStatus::REJECTED); | 557 callback->Run(blink::mojom::ServiceWorkerEventStatus::REJECTED); |
| 558 } | 558 } |
| 559 context_->sync_event_callbacks.Remove(request_id); | 559 context_->sync_event_callbacks.Remove(request_id); |
| 560 } | 560 } |
| 561 | 561 |
| 562 blink::WebServiceWorkerNetworkProvider* | 562 blink::WebServiceWorkerNetworkProvider* |
| 563 ServiceWorkerContextClient::createServiceWorkerNetworkProvider( | 563 ServiceWorkerContextClient::createServiceWorkerNetworkProvider( |
| 564 blink::WebDataSource* data_source) { | 564 blink::WebDataSource* data_source) { |
| 565 DCHECK(main_thread_task_runner_->RunsTasksOnCurrentThread()); | 565 DCHECK(main_thread_task_runner_->RunsTasksOnCurrentThread()); |
| 566 | 566 |
| 567 // Create a content::ServiceWorkerNetworkProvider for this data source so | 567 // Create a content::ServiceWorkerNetworkProvider for this data source so |
| (...skipping 456 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1024 } | 1024 } |
| 1025 | 1025 |
| 1026 base::WeakPtr<ServiceWorkerContextClient> | 1026 base::WeakPtr<ServiceWorkerContextClient> |
| 1027 ServiceWorkerContextClient::GetWeakPtr() { | 1027 ServiceWorkerContextClient::GetWeakPtr() { |
| 1028 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); | 1028 DCHECK(worker_task_runner_->RunsTasksOnCurrentThread()); |
| 1029 DCHECK(context_); | 1029 DCHECK(context_); |
| 1030 return context_->weak_factory.GetWeakPtr(); | 1030 return context_->weak_factory.GetWeakPtr(); |
| 1031 } | 1031 } |
| 1032 | 1032 |
| 1033 } // namespace content | 1033 } // namespace content |
| OLD | NEW |