Chromium Code Reviews| Index: components/data_reduction_proxy/content/browser/data_reduction_proxy_resource_throttle.cc |
| diff --git a/components/data_reduction_proxy/content/browser/data_reduction_proxy_resource_throttle.cc b/components/data_reduction_proxy/content/browser/data_reduction_proxy_resource_throttle.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..a9a450feb9df498ca4e456bbe55c4fa3b30c4011 |
| --- /dev/null |
| +++ b/components/data_reduction_proxy/content/browser/data_reduction_proxy_resource_throttle.cc |
| @@ -0,0 +1,136 @@ |
| +// Copyright 2014 The Chromium Authors. All rights reserved. |
| +// Use of this source code is governed by a BSD-style license that can be |
| +// found in the LICENSE file. |
| + |
| +#include "components/data_reduction_proxy/content/browser/data_reduction_proxy_resource_throttle.h" |
| + |
| +#include "components/data_reduction_proxy/content/browser/data_reduction_proxy_ui_service.h" |
| +#include "components/data_reduction_proxy/core/common/data_reduction_proxy_params.h" |
| +#include "content/public/browser/browser_thread.h" |
| +#include "content/public/browser/resource_controller.h" |
| +#include "content/public/browser/resource_request_info.h" |
| +#include "net/base/load_flags.h" |
| +#include "net/http/http_response_headers.h" |
| +#include "net/url_request/url_request.h" |
| + |
| +namespace data_reduction_proxy { |
| + |
| +namespace { |
| + |
| +const char kResouceThrottleLogName[] = "DataReductionProxyResourceThrottle"; |
| + |
| +} // namespace |
| + |
| +DataReductionProxyResourceThrottle::DataReductionProxyResourceThrottle( |
| + const net::URLRequest* request, |
| + content::ResourceType resource_type, |
| + const DataReductionProxyUIService* ui_service, |
| + const DataReductionProxyParams* params) |
| + : state_(NOT_BYPASSED), |
| + request_(request), |
| + ui_service_(ui_service), |
| + params_(params), |
| + is_subresource_(resource_type != content::RESOURCE_TYPE_MAIN_FRAME) { |
| + DCHECK(request); |
| + DCHECK(ui_service); |
| + DCHECK(params); |
| +} |
| + |
| +DataReductionProxyResourceThrottle::~DataReductionProxyResourceThrottle() { |
| +} |
| + |
| +// Enforces warning when the proxy will not be used for a request because it |
|
bengr
2014/12/31 01:10:21
What does "Enforces warning" mean? Please reword.
megjablon
2014/12/31 02:12:28
Done.
|
| +// isn't configured. |
| +void DataReductionProxyResourceThrottle::WillStartUsingNetwork(bool* defer) { |
| + DCHECK(state_ == NOT_BYPASSED); |
| + if (!params_->AreDataReductionProxiesBypassed(*request_, NULL)) |
| + return; |
| + if (request_->load_flags() & net::LOAD_PREFETCH) { |
| + // Don't prefetch resources that bypass, disallow them. |
| + controller()->Cancel(); |
| + return; |
| + } |
| + // Do not display a blocking page if the data reduction proxy is bypassed by |
|
bengr
2014/12/31 01:10:21
"a blocking page" -> "the interstitial"
"if the da
megjablon
2014/12/31 02:12:28
Done.
|
| + // local rules. |
| + if (params_->IsBypassedByDataReductionProxyLocalRules( |
| + *request_, ui_service_->data_reduction_proxy_config())) { |
| + state_ = LOCAL_BYPASS; |
| + return; |
| + } |
| + DisplayBlockingPage(defer); |
| +} |
| + |
| +// Enforces warning when the data reduction proxy explicitly returns a response |
|
bengr
2014/12/31 01:10:21
Reword "enforces warning" here too.
megjablon
2014/12/31 02:12:28
Done.
|
| +// that triggers a bypass. |
| +void DataReductionProxyResourceThrottle::WillRedirectRequest( |
| + const GURL& new_url, |
| + bool* defer) { |
| + // If we have already shown the interstitial, do not show it again. The |
| + // LOAD_BYPASS_PROXY flag makes it so that we do not resolve proxies. This |
| + // override is used when downloading PAC files. If the request does not have |
| + // the LOAD_BYPASS_PROXY flag, do not show the interstitial. |
| + if (state_ != NOT_BYPASSED || |
| + !(request_->load_flags() & net::LOAD_BYPASS_PROXY)) { |
| + return; |
| + } |
| + DisplayBlockingPage(defer); |
| +} |
| + |
| +// We already checked if the proxy is bypassed by local rules and if the data |
|
bengr
2014/12/31 01:10:21
Rewrite to remove all instances of "we".
Capitaliz
megjablon
2014/12/31 02:12:28
Done.
|
| +// reduction proxy sent an explicit bypass. If the response isn't from the data |
| +// reduction proxy and the scheme type can be proxied by the data reduction |
| +// proxy we have a connection error, display the blocking page. |
| +void DataReductionProxyResourceThrottle::WillProcessResponse(bool* defer) { |
| + if (state_ != NOT_BYPASSED) |
| + return; |
| + if (params_->IsDataReductionProxy(request_->proxy_server(), NULL) || |
| + !DataReductionProxyParams::CanProxyURLScheme(request_->url())) { |
| + return; |
| + } |
| + DisplayBlockingPage(defer); |
| +} |
| + |
| +const char* DataReductionProxyResourceThrottle::GetNameForLogging() const { |
| + return kResouceThrottleLogName; |
|
bengr
2014/12/31 01:10:21
indent -2.
megjablon
2014/12/31 02:12:28
Done.
|
| +} |
| + |
| +// static |
| +void DataReductionProxyResourceThrottle::StartDisplayingBlockingPage( |
| + scoped_refptr<DataReductionProxyUIManager> ui_manager, |
| + const DataReductionProxyUIManager::BypassResource& resource) { |
| + DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
| + ui_manager->DisplayBlockingPage(resource); |
| +} |
| + |
| +void DataReductionProxyResourceThrottle::DisplayBlockingPage(bool* defer) { |
| + const content::ResourceRequestInfo* info = |
| + content::ResourceRequestInfo::ForRequest(request_); |
| + DCHECK(info); |
| + |
| + state_ = REMOTE_BYPASS; |
| + *defer = true; |
| + |
| + DataReductionProxyUIManager::BypassResource resource; |
| + resource.url = request_->url(); |
| + resource.is_subresource = is_subresource_; |
| + resource.callback = base::Bind( |
| + &DataReductionProxyResourceThrottle::OnBlockingPageComplete, AsWeakPtr()); |
| + resource.render_process_host_id = info->GetChildID(); |
| + resource.render_view_id = info->GetRouteID(); |
| + |
| + content::BrowserThread::PostTask( |
| + content::BrowserThread::UI, FROM_HERE, |
| + base::Bind( |
| + &DataReductionProxyResourceThrottle::StartDisplayingBlockingPage, |
| + ui_service_->ui_manager(), resource)); |
| +} |
| + |
| +void DataReductionProxyResourceThrottle::OnBlockingPageComplete(bool proceed) { |
| + state_ = NOT_BYPASSED; |
| + if (proceed) |
| + controller()->Resume(); |
| + else |
| + controller()->Cancel(); |
| +} |
| + |
| +} // namespace data_reduction_proxy |