OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "chrome/browser/policy/device_management_service.h" | 5 #include "chrome/browser/policy/device_management_service.h" |
6 | 6 |
7 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
8 #include "base/message_loop_proxy.h" | 8 #include "base/message_loop_proxy.h" |
9 #include "chrome/browser/browser_process.h" | 9 #include "chrome/browser/browser_process.h" |
10 #include "chrome/browser/net/chrome_net_log.h" | 10 #include "chrome/browser/net/chrome_net_log.h" |
11 #include "chrome/browser/policy/device_management_backend.h" | 11 #include "chrome/browser/policy/device_management_backend.h" |
12 #include "chrome/browser/policy/device_management_backend_impl.h" | 12 #include "chrome/browser/policy/device_management_backend_impl.h" |
13 #include "content/browser/browser_thread.h" | 13 #include "content/browser/browser_thread.h" |
14 #include "net/base/cookie_monster.h" | 14 #include "net/base/cookie_monster.h" |
15 #include "net/base/host_resolver.h" | 15 #include "net/base/host_resolver.h" |
16 #include "net/base/load_flags.h" | 16 #include "net/base/load_flags.h" |
17 #include "net/base/net_errors.h" | 17 #include "net/base/net_errors.h" |
18 #include "net/base/ssl_config_service_defaults.h" | 18 #include "net/base/ssl_config_service_defaults.h" |
19 #include "net/http/http_network_layer.h" | 19 #include "net/http/http_network_layer.h" |
| 20 #include "net/http/http_response_headers.h" |
20 #include "net/proxy/proxy_service.h" | 21 #include "net/proxy/proxy_service.h" |
21 #include "net/url_request/url_request_context.h" | 22 #include "net/url_request/url_request_context.h" |
22 #include "net/url_request/url_request_context_getter.h" | 23 #include "net/url_request/url_request_context_getter.h" |
23 #include "net/url_request/url_request_status.h" | 24 #include "net/url_request/url_request_status.h" |
24 #include "webkit/glue/webkit_glue.h" | 25 #include "webkit/glue/webkit_glue.h" |
25 | 26 |
26 namespace policy { | 27 namespace policy { |
27 | 28 |
28 namespace { | 29 namespace { |
29 | 30 |
| 31 bool IsProxyError(const net::URLRequestStatus status) { |
| 32 switch (status.error()) { |
| 33 case net::ERR_PROXY_CONNECTION_FAILED: |
| 34 case net::ERR_TUNNEL_CONNECTION_FAILED: |
| 35 case net::ERR_PROXY_AUTH_UNSUPPORTED: |
| 36 case net::ERR_HTTPS_PROXY_TUNNEL_RESPONSE: |
| 37 case net::ERR_MANDATORY_PROXY_CONFIGURATION_FAILED: |
| 38 case net::ERR_PROXY_CERTIFICATE_INVALID: |
| 39 case net::ERR_SOCKS_CONNECTION_FAILED: |
| 40 case net::ERR_SOCKS_CONNECTION_HOST_UNREACHABLE: |
| 41 return true; |
| 42 } |
| 43 return false; |
| 44 } |
| 45 |
| 46 bool IsProtobufMimeType(const URLFetcher* source) { |
| 47 return source->response_headers()->HasHeaderValue( |
| 48 "content-type", "application/x-protobuffer"); |
| 49 } |
| 50 |
30 // Custom request context implementation that allows to override the user agent, | 51 // Custom request context implementation that allows to override the user agent, |
31 // amongst others. Wraps a baseline request context from which we reuse the | 52 // amongst others. Wraps a baseline request context from which we reuse the |
32 // networking components. | 53 // networking components. |
33 class DeviceManagementRequestContext : public net::URLRequestContext { | 54 class DeviceManagementRequestContext : public net::URLRequestContext { |
34 public: | 55 public: |
35 explicit DeviceManagementRequestContext(net::URLRequestContext* base_context); | 56 explicit DeviceManagementRequestContext(net::URLRequestContext* base_context); |
36 virtual ~DeviceManagementRequestContext(); | 57 virtual ~DeviceManagementRequestContext(); |
37 | 58 |
38 private: | 59 private: |
39 // Overridden from net::URLRequestContext: | 60 // Overridden from net::URLRequestContext: |
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 const net::ResponseCookies& cookies, | 228 const net::ResponseCookies& cookies, |
208 const std::string& data) { | 229 const std::string& data) { |
209 JobFetcherMap::iterator entry(pending_jobs_.find(source)); | 230 JobFetcherMap::iterator entry(pending_jobs_.find(source)); |
210 if (entry != pending_jobs_.end()) { | 231 if (entry != pending_jobs_.end()) { |
211 DeviceManagementJob* job = entry->second; | 232 DeviceManagementJob* job = entry->second; |
212 pending_jobs_.erase(entry); | 233 pending_jobs_.erase(entry); |
213 | 234 |
214 // Retry the job if it failed due to a broken proxy, by bypassing the | 235 // Retry the job if it failed due to a broken proxy, by bypassing the |
215 // proxy on the next try. Don't retry if this URLFetcher already bypassed | 236 // proxy on the next try. Don't retry if this URLFetcher already bypassed |
216 // the proxy. | 237 // the proxy. |
217 int error = status.error(); | 238 bool retry = false; |
218 if (!status.is_success() && | 239 if ((source->load_flags() & net::LOAD_BYPASS_PROXY) == 0) { |
219 ((source->load_flags() & net::LOAD_BYPASS_PROXY) == 0) && | 240 if (!status.is_success() && IsProxyError(status)) { |
220 (error == net::ERR_PROXY_CONNECTION_FAILED || | 241 LOG(WARNING) << "Proxy failed while contacting dmserver."; |
221 error == net::ERR_TUNNEL_CONNECTION_FAILED || | 242 retry = true; |
222 error == net::ERR_PROXY_AUTH_UNSUPPORTED || | 243 } else if (status.is_success() && |
223 error == net::ERR_HTTPS_PROXY_TUNNEL_RESPONSE || | 244 source->was_fetched_via_proxy() && |
224 error == net::ERR_MANDATORY_PROXY_CONFIGURATION_FAILED || | 245 !IsProtobufMimeType(source)) { |
225 error == net::ERR_PROXY_CERTIFICATE_INVALID || | 246 // The proxy server can be misconfigured but pointing to an existing |
226 error == net::ERR_SOCKS_CONNECTION_FAILED || | 247 // server that replies to requests. Try to recover if a successful |
227 error == net::ERR_SOCKS_CONNECTION_HOST_UNREACHABLE)) { | 248 // request that went through a proxy returns an unexpected mime type. |
228 LOG(WARNING) << "Proxy failed while contacting dmserver. Retrying " | 249 LOG(WARNING) << "Got bad mime-type in response from dmserver that was " |
229 << "without using the proxy."; | 250 << "fetched via a proxy."; |
| 251 retry = true; |
| 252 } |
| 253 } |
| 254 |
| 255 if (retry) { |
| 256 LOG(WARNING) << "Retrying dmserver request without using a proxy."; |
230 StartJob(job, true); | 257 StartJob(job, true); |
231 } else { | 258 } else { |
232 job->HandleResponse(status, response_code, cookies, data); | 259 job->HandleResponse(status, response_code, cookies, data); |
233 } | 260 } |
234 } else { | 261 } else { |
235 NOTREACHED() << "Callback from foreign URL fetcher"; | 262 NOTREACHED() << "Callback from foreign URL fetcher"; |
236 } | 263 } |
237 delete source; | 264 delete source; |
238 } | 265 } |
239 | 266 |
240 } // namespace policy | 267 } // namespace policy |
OLD | NEW |