Index: content/browser/service_worker/service_worker_provider_host.cc |
diff --git a/content/browser/service_worker/service_worker_provider_host.cc b/content/browser/service_worker/service_worker_provider_host.cc |
index ae8dcdbda8248bf5690765cfa3e0b635b02e62b8..5de525ed8bfb4792d6524130978924009f09fb2a 100644 |
--- a/content/browser/service_worker/service_worker_provider_host.cc |
+++ b/content/browser/service_worker/service_worker_provider_host.cc |
@@ -19,7 +19,6 @@ |
#include "content/browser/service_worker/service_worker_handle.h" |
#include "content/browser/service_worker/service_worker_registration_handle.h" |
#include "content/browser/service_worker/service_worker_version.h" |
-#include "content/browser/url_loader_factory_getter.h" |
#include "content/common/resource_request_body_impl.h" |
#include "content/common/service_worker/service_worker_messages.h" |
#include "content/common/service_worker/service_worker_types.h" |
@@ -32,7 +31,6 @@ |
#include "content/public/common/origin_util.h" |
#include "mojo/public/cpp/bindings/strong_associated_binding.h" |
#include "net/base/url_util.h" |
-#include "storage/browser/blob/blob_storage_context.h" |
namespace content { |
@@ -100,155 +98,6 @@ void RemoveProviderHost(base::WeakPtr<ServiceWorkerContextCore> context, |
context->RemoveProviderHost(process_id, provider_id); |
} |
-// Used by a Service Worker for script loading (for all script loading for now, |
-// but to be used only during installation once script streaming lands). |
-// For now this is just a proxy loader for the network loader. |
-// Eventually this should replace the existing URLRequestJob-based request |
-// interception for script loading, namely ServiceWorkerWriteToCacheJob. |
-// TODO(kinuko): Implement this. Hook up the existing code in |
-// ServiceWorkerContextRequestHandler. |
-class ScriptURLLoader : public mojom::URLLoader, public mojom::URLLoaderClient { |
- public: |
- ScriptURLLoader( |
- int32_t routing_id, |
- int32_t request_id, |
- uint32_t options, |
- const ResourceRequest& resource_request, |
- mojom::URLLoaderClientPtr client, |
- base::WeakPtr<ServiceWorkerContextCore> context, |
- base::WeakPtr<ServiceWorkerProviderHost> provider_host, |
- base::WeakPtr<storage::BlobStorageContext> blob_storage_context, |
- scoped_refptr<URLLoaderFactoryGetter> loader_factory_getter, |
- const net::MutableNetworkTrafficAnnotationTag& traffic_annotation) |
- : network_client_binding_(this), |
- forwarding_client_(std::move(client)), |
- provider_host_(provider_host) { |
- mojom::URLLoaderClientPtr network_client; |
- network_client_binding_.Bind(mojo::MakeRequest(&network_client)); |
- loader_factory_getter->GetNetworkFactory()->get()->CreateLoaderAndStart( |
- mojo::MakeRequest(&network_loader_), routing_id, request_id, options, |
- resource_request, std::move(network_client), traffic_annotation); |
- } |
- ~ScriptURLLoader() override {} |
- |
- // mojom::URLLoader: |
- void FollowRedirect() override { network_loader_->FollowRedirect(); } |
- void SetPriority(net::RequestPriority priority, |
- int32_t intra_priority_value) override { |
- network_loader_->SetPriority(priority, intra_priority_value); |
- } |
- |
- // mojom::URLLoaderClient for simply proxying network: |
- void OnReceiveResponse( |
- const ResourceResponseHead& response_head, |
- const base::Optional<net::SSLInfo>& ssl_info, |
- mojom::DownloadedTempFilePtr downloaded_file) override { |
- if (provider_host_) { |
- // We don't have complete info here, but fill in what we have now. |
- // At least we need headers and SSL info. |
- net::HttpResponseInfo response_info; |
- response_info.headers = response_head.headers; |
- if (ssl_info.has_value()) |
- response_info.ssl_info = *ssl_info; |
- response_info.was_fetched_via_spdy = response_head.was_fetched_via_spdy; |
- response_info.was_alpn_negotiated = response_head.was_alpn_negotiated; |
- response_info.alpn_negotiated_protocol = |
- response_head.alpn_negotiated_protocol; |
- response_info.connection_info = response_head.connection_info; |
- response_info.socket_address = response_head.socket_address; |
- |
- DCHECK(provider_host_->IsHostToRunningServiceWorker()); |
- provider_host_->running_hosted_version()->SetMainScriptHttpResponseInfo( |
- response_info); |
- } |
- forwarding_client_->OnReceiveResponse(response_head, ssl_info, |
- std::move(downloaded_file)); |
- } |
- void OnReceiveRedirect(const net::RedirectInfo& redirect_info, |
- const ResourceResponseHead& response_head) override { |
- forwarding_client_->OnReceiveRedirect(redirect_info, response_head); |
- } |
- void OnDataDownloaded(int64_t data_len, int64_t encoded_data_len) override { |
- forwarding_client_->OnDataDownloaded(data_len, encoded_data_len); |
- } |
- void OnUploadProgress(int64_t current_position, |
- int64_t total_size, |
- OnUploadProgressCallback ack_callback) override { |
- forwarding_client_->OnUploadProgress(current_position, total_size, |
- std::move(ack_callback)); |
- } |
- void OnReceiveCachedMetadata(const std::vector<uint8_t>& data) override { |
- forwarding_client_->OnReceiveCachedMetadata(data); |
- } |
- void OnTransferSizeUpdated(int32_t transfer_size_diff) override { |
- forwarding_client_->OnTransferSizeUpdated(transfer_size_diff); |
- } |
- void OnStartLoadingResponseBody( |
- mojo::ScopedDataPipeConsumerHandle body) override { |
- forwarding_client_->OnStartLoadingResponseBody(std::move(body)); |
- } |
- void OnComplete(const ResourceRequestCompletionStatus& status) override { |
- forwarding_client_->OnComplete(status); |
- } |
- |
- private: |
- mojom::URLLoaderAssociatedPtr network_loader_; |
- mojo::Binding<mojom::URLLoaderClient> network_client_binding_; |
- mojom::URLLoaderClientPtr forwarding_client_; |
- base::WeakPtr<ServiceWorkerProviderHost> provider_host_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ScriptURLLoader); |
-}; |
- |
-// Created per one controller worker for script loading (only during |
-// installation, eventually). This is kept alive while |
-// ServiceWorkerNetworkProvider in the renderer process is alive. |
-// Used only when IsServicificationEnabled is true. |
-class ScriptURLLoaderFactory : public mojom::URLLoaderFactory { |
- public: |
- ScriptURLLoaderFactory( |
- base::WeakPtr<ServiceWorkerContextCore> context, |
- base::WeakPtr<ServiceWorkerProviderHost> provider_host, |
- base::WeakPtr<storage::BlobStorageContext> blob_storage_context, |
- scoped_refptr<URLLoaderFactoryGetter> loader_factory_getter) |
- : context_(context), |
- provider_host_(provider_host), |
- blob_storage_context_(blob_storage_context), |
- loader_factory_getter_(loader_factory_getter) {} |
- ~ScriptURLLoaderFactory() override {} |
- |
- // mojom::URLLoaderFactory: |
- void CreateLoaderAndStart(mojom::URLLoaderAssociatedRequest request, |
- int32_t routing_id, |
- int32_t request_id, |
- uint32_t options, |
- const ResourceRequest& resource_request, |
- mojom::URLLoaderClientPtr client, |
- const net::MutableNetworkTrafficAnnotationTag& |
- traffic_annotation) override { |
- mojo::MakeStrongAssociatedBinding( |
- base::MakeUnique<ScriptURLLoader>( |
- routing_id, request_id, options, resource_request, |
- std::move(client), context_, provider_host_, blob_storage_context_, |
- loader_factory_getter_, traffic_annotation), |
- std::move(request)); |
- } |
- |
- void SyncLoad(int32_t routing_id, |
- int32_t request_id, |
- const ResourceRequest& request, |
- SyncLoadCallback callback) override { |
- NOTREACHED(); |
- } |
- |
- private: |
- base::WeakPtr<ServiceWorkerContextCore> context_; |
- base::WeakPtr<ServiceWorkerProviderHost> provider_host_; |
- base::WeakPtr<storage::BlobStorageContext> blob_storage_context_; |
- scoped_refptr<URLLoaderFactoryGetter> loader_factory_getter_; |
- DISALLOW_COPY_AND_ASSIGN(ScriptURLLoaderFactory); |
-}; |
- |
} // anonymous namespace |
ServiceWorkerProviderHost::OneShotGetReadyCallback::OneShotGetReadyCallback( |
@@ -730,7 +579,6 @@ bool ServiceWorkerProviderHost::GetRegistrationForReady( |
std::unique_ptr<ServiceWorkerProviderHost> |
ServiceWorkerProviderHost::PrepareForCrossSiteTransfer() { |
DCHECK(!IsBrowserSideNavigationEnabled()); |
- DCHECK(!ServiceWorkerUtils::IsServicificationEnabled()); |
DCHECK_NE(ChildProcessHost::kInvalidUniqueID, render_process_id_); |
DCHECK_NE(MSG_ROUTING_NONE, info_.route_id); |
DCHECK_EQ(kDocumentMainThreadId, render_thread_id_); |
@@ -764,7 +612,6 @@ ServiceWorkerProviderHost::PrepareForCrossSiteTransfer() { |
void ServiceWorkerProviderHost::CompleteCrossSiteTransfer( |
ServiceWorkerProviderHost* provisional_host) { |
DCHECK(!IsBrowserSideNavigationEnabled()); |
- DCHECK(!ServiceWorkerUtils::IsServicificationEnabled()); |
DCHECK_EQ(ChildProcessHost::kInvalidUniqueID, render_process_id_); |
DCHECK_NE(ChildProcessHost::kInvalidUniqueID, provisional_host->process_id()); |
DCHECK_NE(MSG_ROUTING_NONE, provisional_host->frame_id()); |
@@ -862,18 +709,6 @@ ServiceWorkerProviderHost::CompleteStartWorkerPreparation( |
provider_info->attributes = std::move(attrs); |
provider_info->registration = std::move(info); |
provider_info->client_request = mojo::MakeRequest(&provider_); |
- |
- mojom::URLLoaderFactoryAssociatedPtrInfo loader_factory_ptr_info; |
- if (ServiceWorkerUtils::IsServicificationEnabled()) { |
- mojo::MakeStrongAssociatedBinding( |
- base::MakeUnique<ScriptURLLoaderFactory>( |
- context_, AsWeakPtr(), context_->blob_storage_context(), |
- context_->loader_factory_getter()), |
- mojo::MakeRequest(&loader_factory_ptr_info)); |
- provider_info->script_loader_factory_ptr_info = |
- std::move(loader_factory_ptr_info); |
- } |
- |
binding_.Bind(mojo::MakeRequest(&provider_info->host_ptr_info)); |
binding_.set_connection_error_handler( |
base::Bind(&RemoveProviderHost, context_, process_id, provider_id())); |