OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/data_reduction_proxy/browser/data_reduction_proxy_metrics.h
" | 5 #include "components/data_reduction_proxy/browser/data_reduction_proxy_metrics.h
" |
6 | 6 |
7 #include "base/metrics/histogram.h" | 7 #include "base/metrics/histogram.h" |
8 #include "base/prefs/pref_service.h" | 8 #include "base/prefs/pref_service.h" |
9 #include "base/prefs/scoped_user_pref_update.h" | 9 #include "base/prefs/scoped_user_pref_update.h" |
10 #include "base/strings/string_number_conversions.h" | 10 #include "base/strings/string_number_conversions.h" |
11 #include "base/strings/string_util.h" | 11 #include "base/strings/string_util.h" |
12 #include "components/data_reduction_proxy/browser/data_reduction_proxy_settings.
h" | 12 #include "components/data_reduction_proxy/browser/data_reduction_proxy_settings.
h" |
13 #include "components/data_reduction_proxy/common/data_reduction_proxy_pref_names
.h" | 13 #include "components/data_reduction_proxy/common/data_reduction_proxy_pref_names
.h" |
14 #include "net/base/host_port_pair.h" | 14 #include "net/base/host_port_pair.h" |
15 #include "net/http/http_response_headers.h" | 15 #include "net/http/http_response_headers.h" |
16 #include "net/proxy/proxy_retry_info.h" | 16 #include "net/proxy/proxy_retry_info.h" |
17 #include "net/proxy/proxy_service.h" | 17 #include "net/proxy/proxy_service.h" |
18 #include "net/url_request/url_request_context.h" | 18 #include "net/url_request/url_request_context.h" |
19 | 19 |
20 namespace data_reduction_proxy { | 20 namespace data_reduction_proxy { |
21 | 21 |
22 namespace { | 22 namespace { |
23 | 23 |
24 // A bypass delay more than this is treated as a long delay. | 24 // A bypass delay more than this is treated as a long delay. |
25 const int kLongBypassDelayInSeconds = 30 * 60; | 25 const int kLongBypassDelayInSeconds = 30 * 60; |
26 | 26 |
| 27 #if defined(OS_ANDROID) || defined(OS_IOS) |
| 28 |
27 // Increments an int64, stored as a string, in a ListPref at the specified | 29 // Increments an int64, stored as a string, in a ListPref at the specified |
28 // index. The value must already exist and be a string representation of a | 30 // index. The value must already exist and be a string representation of a |
29 // number. | 31 // number. |
30 void AddInt64ToListPref(size_t index, | 32 void AddInt64ToListPref(size_t index, |
31 int64 length, | 33 int64 length, |
32 base::ListValue* list_update) { | 34 base::ListValue* list_update) { |
33 int64 value = 0; | 35 int64 value = 0; |
34 std::string old_string_value; | 36 std::string old_string_value; |
35 bool rv = list_update->GetString(index, &old_string_value); | 37 bool rv = list_update->GetString(index, &old_string_value); |
36 DCHECK(rv); | 38 DCHECK(rv); |
(...skipping 252 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
289 } | 291 } |
290 int64 GetReceivedListPrefValue(size_t index) { | 292 int64 GetReceivedListPrefValue(size_t index) { |
291 return received_.GetListPrefValue(index); | 293 return received_.GetListPrefValue(index); |
292 } | 294 } |
293 | 295 |
294 private: | 296 private: |
295 DailyContentLengthUpdate original_; | 297 DailyContentLengthUpdate original_; |
296 DailyContentLengthUpdate received_; | 298 DailyContentLengthUpdate received_; |
297 }; | 299 }; |
298 | 300 |
| 301 #endif // defined(OS_ANDROID) || defined(OS_IOS) |
| 302 |
299 // Returns true if the request is bypassed by all configured data reduction | 303 // Returns true if the request is bypassed by all configured data reduction |
300 // proxies. It returns the bypass delay in delay_seconds (if not NULL). If | 304 // proxies. It returns the bypass delay in delay_seconds (if not NULL). If |
301 // the request is bypassed by more than one proxy, delay_seconds returns | 305 // the request is bypassed by more than one proxy, delay_seconds returns |
302 // shortest delay. | 306 // shortest delay. |
303 bool IsBypassRequest(const net::URLRequest* request, int64* delay_seconds) { | 307 bool IsBypassRequest(const net::URLRequest* request, int64* delay_seconds) { |
| 308 #if defined(OS_ANDROID) || defined(OS_IOS) |
304 DataReductionProxySettings::DataReductionProxyList proxies = | 309 DataReductionProxySettings::DataReductionProxyList proxies = |
305 DataReductionProxySettings::GetDataReductionProxies(); | 310 DataReductionProxySettings::GetDataReductionProxies(); |
306 if (proxies.size() == 0) | 311 if (proxies.size() == 0) |
307 return false; | 312 return false; |
308 | 313 |
309 if (request == NULL || request->context() == NULL || | 314 if (request == NULL || request->context() == NULL || |
310 request->context()->proxy_service() == NULL) { | 315 request->context()->proxy_service() == NULL) { |
311 return false; | 316 return false; |
312 } | 317 } |
313 | 318 |
(...skipping 14 matching lines...) Expand all Loading... |
328 if (found == retry_map.end()) | 333 if (found == retry_map.end()) |
329 return false; | 334 return false; |
330 if (shortest_delay == 0 || | 335 if (shortest_delay == 0 || |
331 shortest_delay > found->second.current_delay.InSeconds()) { | 336 shortest_delay > found->second.current_delay.InSeconds()) { |
332 shortest_delay = found->second.current_delay.InSeconds(); | 337 shortest_delay = found->second.current_delay.InSeconds(); |
333 } | 338 } |
334 } | 339 } |
335 if (delay_seconds != NULL) | 340 if (delay_seconds != NULL) |
336 *delay_seconds = shortest_delay; | 341 *delay_seconds = shortest_delay; |
337 return true; | 342 return true; |
| 343 #else |
| 344 return false; |
| 345 #endif // defined(OS_ANDROID) || defined(OS_IOS) |
338 } | 346 } |
339 | 347 |
340 } // namespace | 348 } // namespace |
341 | 349 |
342 DataReductionProxyRequestType GetDataReductionProxyRequestType( | 350 DataReductionProxyRequestType GetDataReductionProxyRequestType( |
343 const net::URLRequest* request) { | 351 const net::URLRequest* request) { |
344 if (request->url().SchemeIs("https")) | 352 if (request->url().SchemeIs("https")) |
345 return HTTPS; | 353 return HTTPS; |
346 if (!request->url().SchemeIs("http")) { | 354 if (!request->url().SchemeIs("http")) { |
347 NOTREACHED(); | 355 NOTREACHED(); |
348 return UNKNOWN_TYPE; | 356 return UNKNOWN_TYPE; |
349 } | 357 } |
350 int64 bypass_delay = 0; | 358 int64 bypass_delay = 0; |
351 if (IsBypassRequest(request, &bypass_delay)) { | 359 if (IsBypassRequest(request, &bypass_delay)) { |
352 return (bypass_delay > kLongBypassDelayInSeconds) ? | 360 return (bypass_delay > kLongBypassDelayInSeconds) ? |
353 LONG_BYPASS : SHORT_BYPASS; | 361 LONG_BYPASS : SHORT_BYPASS; |
354 } | 362 } |
| 363 #if defined(SPDY_PROXY_AUTH_ORIGIN) |
355 if (request->response_info().headers && | 364 if (request->response_info().headers && |
356 request->response_info().headers->IsDataReductionProxyResponse()) { | 365 request->response_info().headers->IsDataReductionProxyResponse()) { |
357 return VIA_DATA_REDUCTION_PROXY; | 366 return VIA_DATA_REDUCTION_PROXY; |
358 } | 367 } |
| 368 #endif |
359 return UNKNOWN_TYPE; | 369 return UNKNOWN_TYPE; |
360 } | 370 } |
361 | 371 |
362 int64 GetAdjustedOriginalContentLength( | 372 int64 GetAdjustedOriginalContentLength( |
363 DataReductionProxyRequestType request_type, | 373 DataReductionProxyRequestType request_type, |
364 int64 original_content_length, | 374 int64 original_content_length, |
365 int64 received_content_length) { | 375 int64 received_content_length) { |
366 // Since there was no indication of the original content length, presume | 376 // Since there was no indication of the original content length, presume |
367 // it is no different from the number of bytes read. | 377 // it is no different from the number of bytes read. |
368 if (original_content_length == -1 || | 378 if (original_content_length == -1 || |
369 request_type != VIA_DATA_REDUCTION_PROXY) { | 379 request_type != VIA_DATA_REDUCTION_PROXY) { |
370 return received_content_length; | 380 return received_content_length; |
371 } | 381 } |
372 return original_content_length; | 382 return original_content_length; |
373 } | 383 } |
374 | 384 |
| 385 #if defined(OS_ANDROID) || defined(OS_IOS) |
375 void UpdateContentLengthPrefsForDataReductionProxy( | 386 void UpdateContentLengthPrefsForDataReductionProxy( |
376 int received_content_length, | 387 int received_content_length, |
377 int original_content_length, | 388 int original_content_length, |
378 bool with_data_reduction_proxy_enabled, | 389 bool with_data_reduction_proxy_enabled, |
379 DataReductionProxyRequestType request_type, | 390 DataReductionProxyRequestType request_type, |
380 base::Time now, PrefService* prefs) { | 391 base::Time now, PrefService* prefs) { |
381 // TODO(bengr): Remove this check once the underlying cause of | 392 // TODO(bengr): Remove this check once the underlying cause of |
382 // http://crbug.com/287821 is fixed. For now, only continue if the current | 393 // http://crbug.com/287821 is fixed. For now, only continue if the current |
383 // year is reported as being between 1972 and 2970. | 394 // year is reported as being between 1972 and 2970. |
384 base::TimeDelta time_since_unix_epoch = now - base::Time::UnixEpoch(); | 395 base::TimeDelta time_since_unix_epoch = now - base::Time::UnixEpoch(); |
385 const int kMinDaysSinceUnixEpoch = 365 * 2; // 2 years. | 396 const int kMinDaysSinceUnixEpoch = 365 * 2; // 2 years. |
386 const int kMaxDaysSinceUnixEpoch = 365 * 1000; // 1000 years. | 397 const int kMaxDaysSinceUnixEpoch = 365 * 1000; // 1000 years. |
387 if (time_since_unix_epoch.InDays() < kMinDaysSinceUnixEpoch || | 398 if (time_since_unix_epoch.InDays() < kMinDaysSinceUnixEpoch || |
388 time_since_unix_epoch.InDays() > kMaxDaysSinceUnixEpoch) { | 399 time_since_unix_epoch.InDays() > kMaxDaysSinceUnixEpoch) { |
389 return; | 400 return; |
390 } | 401 } |
391 | 402 |
392 // Determine how many days it has been since the last update. | 403 // Determine how many days it has been since the last update. |
393 int64 then_internal = prefs->GetInt64( | 404 int64 then_internal = prefs->GetInt64( |
394 data_reduction_proxy::prefs::kDailyHttpContentLengthLastUpdateDate); | 405 data_reduction_proxy::prefs::kDailyHttpContentLengthLastUpdateDate); |
395 | |
396 #if defined(OS_WIN) | |
397 base::Time then_midnight = base::Time::FromInternalValue(then_internal); | |
398 base::Time midnight = | |
399 base::Time::FromInternalValue( | |
400 (now.ToInternalValue() / base::Time::kMicrosecondsPerDay) * | |
401 base::Time::kMicrosecondsPerDay); | |
402 #else | |
403 // Local midnight could have been shifted due to time zone change. | 406 // Local midnight could have been shifted due to time zone change. |
404 base::Time then_midnight = | 407 base::Time then_midnight = |
405 base::Time::FromInternalValue(then_internal).LocalMidnight(); | 408 base::Time::FromInternalValue(then_internal).LocalMidnight(); |
406 base::Time midnight = now.LocalMidnight(); | 409 base::Time midnight = now.LocalMidnight(); |
407 #endif | |
408 | |
409 int days_since_last_update = (midnight - then_midnight).InDays(); | 410 int days_since_last_update = (midnight - then_midnight).InDays(); |
410 | 411 |
411 // Each day, we calculate the total number of bytes received and the total | 412 // Each day, we calculate the total number of bytes received and the total |
412 // size of all corresponding resources before any data-reducing recompression | 413 // size of all corresponding resources before any data-reducing recompression |
413 // is applied. These values are used to compute the data savings realized | 414 // is applied. These values are used to compute the data savings realized |
414 // by applying our compression techniques. Totals for the last | 415 // by applying our compression techniques. Totals for the last |
415 // |kNumDaysInHistory| days are maintained. | 416 // |kNumDaysInHistory| days are maintained. |
416 DailyDataSavingUpdate total( | 417 DailyDataSavingUpdate total( |
417 data_reduction_proxy::prefs::kDailyHttpOriginalContentLength, | 418 data_reduction_proxy::prefs::kDailyHttpOriginalContentLength, |
418 data_reduction_proxy::prefs::kDailyHttpReceivedContentLength, | 419 data_reduction_proxy::prefs::kDailyHttpReceivedContentLength, |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
503 proxy_enabled.GetReceivedListPrefValue(kNumDaysInHistory - 2), | 504 proxy_enabled.GetReceivedListPrefValue(kNumDaysInHistory - 2), |
504 via_proxy.GetOriginalListPrefValue(kNumDaysInHistory - 2), | 505 via_proxy.GetOriginalListPrefValue(kNumDaysInHistory - 2), |
505 via_proxy.GetReceivedListPrefValue(kNumDaysInHistory - 2), | 506 via_proxy.GetReceivedListPrefValue(kNumDaysInHistory - 2), |
506 https.GetListPrefValue(kNumDaysInHistory - 2), | 507 https.GetListPrefValue(kNumDaysInHistory - 2), |
507 short_bypass.GetListPrefValue(kNumDaysInHistory - 2), | 508 short_bypass.GetListPrefValue(kNumDaysInHistory - 2), |
508 long_bypass.GetListPrefValue(kNumDaysInHistory - 2), | 509 long_bypass.GetListPrefValue(kNumDaysInHistory - 2), |
509 unknown.GetListPrefValue(kNumDaysInHistory - 2)); | 510 unknown.GetListPrefValue(kNumDaysInHistory - 2)); |
510 } | 511 } |
511 } | 512 } |
512 } | 513 } |
| 514 #endif // defined(OS_ANDROID) || defined(OS_IOS) |
513 | 515 |
514 void UpdateContentLengthPrefs( | 516 void UpdateContentLengthPrefs( |
515 int received_content_length, | 517 int received_content_length, |
516 int original_content_length, | 518 int original_content_length, |
517 bool with_data_reduction_proxy_enabled, | 519 bool with_data_reduction_proxy_enabled, |
518 DataReductionProxyRequestType request_type, | 520 DataReductionProxyRequestType request_type, |
519 PrefService* prefs) { | 521 PrefService* prefs) { |
520 int64 total_received = prefs->GetInt64( | 522 int64 total_received = prefs->GetInt64( |
521 data_reduction_proxy::prefs::kHttpReceivedContentLength); | 523 data_reduction_proxy::prefs::kHttpReceivedContentLength); |
522 int64 total_original = prefs->GetInt64( | 524 int64 total_original = prefs->GetInt64( |
523 data_reduction_proxy::prefs::kHttpOriginalContentLength); | 525 data_reduction_proxy::prefs::kHttpOriginalContentLength); |
524 total_received += received_content_length; | 526 total_received += received_content_length; |
525 total_original += original_content_length; | 527 total_original += original_content_length; |
526 prefs->SetInt64(data_reduction_proxy::prefs::kHttpReceivedContentLength, | 528 prefs->SetInt64(data_reduction_proxy::prefs::kHttpReceivedContentLength, |
527 total_received); | 529 total_received); |
528 prefs->SetInt64(data_reduction_proxy::prefs::kHttpOriginalContentLength, | 530 prefs->SetInt64(data_reduction_proxy::prefs::kHttpOriginalContentLength, |
529 total_original); | 531 total_original); |
530 | 532 |
| 533 #if defined(OS_ANDROID) || defined(OS_IOS) |
531 UpdateContentLengthPrefsForDataReductionProxy( | 534 UpdateContentLengthPrefsForDataReductionProxy( |
532 received_content_length, | 535 received_content_length, |
533 original_content_length, | 536 original_content_length, |
534 with_data_reduction_proxy_enabled, | 537 with_data_reduction_proxy_enabled, |
535 request_type, | 538 request_type, |
536 base::Time::Now(), | 539 base::Time::Now(), |
537 prefs); | 540 prefs); |
| 541 #endif // defined(OS_ANDROID) || defined(OS_IOS) |
| 542 |
538 } | 543 } |
539 | 544 |
540 } // namespace data_reduction_proxy | 545 } // namespace data_reduction_proxy |
OLD | NEW |