OLD | NEW |
---|---|
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_dispatcher_host.h" | 5 #include "content/browser/service_worker/service_worker_dispatcher_host.h" |
6 | 6 |
7 #include "base/command_line.h" | |
7 #include "base/logging.h" | 8 #include "base/logging.h" |
8 #include "base/profiler/scoped_tracker.h" | 9 #include "base/profiler/scoped_tracker.h" |
9 #include "base/strings/utf_string_conversions.h" | 10 #include "base/strings/utf_string_conversions.h" |
10 #include "base/trace_event/trace_event.h" | 11 #include "base/trace_event/trace_event.h" |
11 #include "content/browser/bad_message.h" | 12 #include "content/browser/bad_message.h" |
12 #include "content/browser/message_port_message_filter.h" | 13 #include "content/browser/message_port_message_filter.h" |
13 #include "content/browser/message_port_service.h" | 14 #include "content/browser/message_port_service.h" |
14 #include "content/browser/service_worker/embedded_worker_registry.h" | 15 #include "content/browser/service_worker/embedded_worker_registry.h" |
15 #include "content/browser/service_worker/service_worker_context_core.h" | 16 #include "content/browser/service_worker/service_worker_context_core.h" |
16 #include "content/browser/service_worker/service_worker_context_wrapper.h" | 17 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
17 #include "content/browser/service_worker/service_worker_handle.h" | 18 #include "content/browser/service_worker/service_worker_handle.h" |
19 #include "content/browser/service_worker/service_worker_navigation_handle_core.h " | |
18 #include "content/browser/service_worker/service_worker_registration.h" | 20 #include "content/browser/service_worker/service_worker_registration.h" |
19 #include "content/browser/service_worker/service_worker_registration_handle.h" | 21 #include "content/browser/service_worker/service_worker_registration_handle.h" |
20 #include "content/common/service_worker/embedded_worker_messages.h" | 22 #include "content/common/service_worker/embedded_worker_messages.h" |
21 #include "content/common/service_worker/service_worker_messages.h" | 23 #include "content/common/service_worker/service_worker_messages.h" |
22 #include "content/common/service_worker/service_worker_types.h" | 24 #include "content/common/service_worker/service_worker_types.h" |
23 #include "content/common/service_worker/service_worker_utils.h" | 25 #include "content/common/service_worker/service_worker_utils.h" |
24 #include "content/public/browser/content_browser_client.h" | 26 #include "content/public/browser/content_browser_client.h" |
25 #include "content/public/common/content_client.h" | 27 #include "content/public/common/content_client.h" |
28 #include "content/public/common/content_switches.h" | |
26 #include "content/public/common/origin_util.h" | 29 #include "content/public/common/origin_util.h" |
27 #include "ipc/ipc_message_macros.h" | 30 #include "ipc/ipc_message_macros.h" |
28 #include "net/base/net_util.h" | 31 #include "net/base/net_util.h" |
29 #include "third_party/WebKit/public/platform/modules/serviceworker/WebServiceWor kerError.h" | 32 #include "third_party/WebKit/public/platform/modules/serviceworker/WebServiceWor kerError.h" |
30 #include "url/gurl.h" | 33 #include "url/gurl.h" |
31 | 34 |
32 using blink::WebServiceWorkerError; | 35 using blink::WebServiceWorkerError; |
33 | 36 |
34 namespace content { | 37 namespace content { |
35 | 38 |
(...skipping 690 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
726 "477117 ServiceWorkerDispatcherHost::OnProviderCreated")); | 729 "477117 ServiceWorkerDispatcherHost::OnProviderCreated")); |
727 TRACE_EVENT0("ServiceWorker", | 730 TRACE_EVENT0("ServiceWorker", |
728 "ServiceWorkerDispatcherHost::OnProviderCreated"); | 731 "ServiceWorkerDispatcherHost::OnProviderCreated"); |
729 if (!GetContext()) | 732 if (!GetContext()) |
730 return; | 733 return; |
731 if (GetContext()->GetProviderHost(render_process_id_, provider_id)) { | 734 if (GetContext()->GetProviderHost(render_process_id_, provider_id)) { |
732 bad_message::ReceivedBadMessage(this, | 735 bad_message::ReceivedBadMessage(this, |
733 bad_message::SWDH_PROVIDER_CREATED_NO_HOST); | 736 bad_message::SWDH_PROVIDER_CREATED_NO_HOST); |
734 return; | 737 return; |
735 } | 738 } |
736 scoped_ptr<ServiceWorkerProviderHost> provider_host( | 739 |
737 new ServiceWorkerProviderHost(render_process_id_, route_id, provider_id, | 740 scoped_ptr<ServiceWorkerProviderHost> provider_host; |
738 provider_type, GetContext()->AsWeakPtr(), | 741 if (base::CommandLine::ForCurrentProcess()->HasSwitch( |
739 this)); | 742 switches::kEnableBrowserSideNavigation) && |
743 ServiceWorkerUtils::IsBrowserAssignedProviderId(provider_id)) { | |
744 // PlzNavigate | |
745 // Retrieve the provider host previously created for navigation requests. | |
746 auto result = GetContext()->GetNavigationHandleCores().find(provider_id); | |
747 if (result != GetContext()->GetNavigationHandleCores().end()) | |
748 provider_host = result->second->RetrievePreCreatedHost(); | |
749 if (provider_host == nullptr) { | |
750 bad_message::ReceivedBadMessage( | |
751 this, bad_message::SWDH_PROVIDER_CREATED_NO_HOST); | |
752 return; | |
753 } | |
754 DCHECK_EQ(SERVICE_WORKER_PROVIDER_FOR_WINDOW, provider_type); | |
755 provider_host->CompleteNavigationInitialized(render_process_id_, route_id, | |
756 this); | |
757 } else { | |
758 if (ServiceWorkerUtils::IsBrowserAssignedProviderId(provider_id)) { | |
759 bad_message::ReceivedBadMessage( | |
760 this, bad_message::SWDH_PROVIDER_CREATED_NO_HOST); | |
761 return; | |
762 } | |
763 provider_host = | |
764 scoped_ptr<ServiceWorkerProviderHost>(new ServiceWorkerProviderHost( | |
765 render_process_id_, route_id, provider_id, provider_type, | |
766 GetContext()->AsWeakPtr(), this)); | |
767 } | |
kinuko
2015/10/20 14:46:07
Since this logic has bloated quite a bit I feel it
michaeln
2015/10/20 22:12:53
we're in a sw specific class, do you mean to move
kinuko
2015/10/23 02:37:45
Sorry, I was going to put this comment for the cha
| |
740 GetContext()->AddProviderHost(provider_host.Pass()); | 768 GetContext()->AddProviderHost(provider_host.Pass()); |
741 } | 769 } |
742 | 770 |
743 void ServiceWorkerDispatcherHost::OnProviderDestroyed(int provider_id) { | 771 void ServiceWorkerDispatcherHost::OnProviderDestroyed(int provider_id) { |
744 TRACE_EVENT0("ServiceWorker", | 772 TRACE_EVENT0("ServiceWorker", |
745 "ServiceWorkerDispatcherHost::OnProviderDestroyed"); | 773 "ServiceWorkerDispatcherHost::OnProviderDestroyed"); |
746 if (!GetContext()) | 774 if (!GetContext()) |
747 return; | 775 return; |
748 if (!GetContext()->GetProviderHost(render_process_id_, provider_id)) { | 776 if (!GetContext()->GetProviderHost(render_process_id_, provider_id)) { |
749 bad_message::ReceivedBadMessage( | 777 bad_message::ReceivedBadMessage( |
(...skipping 542 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1292 if (!handle) { | 1320 if (!handle) { |
1293 bad_message::ReceivedBadMessage(this, | 1321 bad_message::ReceivedBadMessage(this, |
1294 bad_message::SWDH_TERMINATE_BAD_HANDLE); | 1322 bad_message::SWDH_TERMINATE_BAD_HANDLE); |
1295 return; | 1323 return; |
1296 } | 1324 } |
1297 handle->version()->StopWorker( | 1325 handle->version()->StopWorker( |
1298 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); | 1326 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); |
1299 } | 1327 } |
1300 | 1328 |
1301 } // namespace content | 1329 } // namespace content |
OLD | NEW |