Add histograms for network activity, and total/cumulative

chrome/browser/net/cache_stats.cc

Index: chrome/browser/net/cache_stats.cc
===================================================================
--- chrome/browser/net/cache_stats.cc	(revision 152373)
+++ chrome/browser/net/cache_stats.cc	(working copy)
@@ -1,350 +0,0 @@
-// Copyright (c) 2012 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 "chrome/browser/net/cache_stats.h"
-
-#include "base/metrics/histogram.h"
-#include "base/stl_util.h"
-#include "base/string_number_conversions.h"
-#include "base/timer.h"
-#include "chrome/browser/browser_process.h"
-#include "chrome/browser/io_thread.h"
-#include "chrome/browser/profiles/profile.h"
-#include "chrome/browser/ui/tab_contents/tab_contents.h"
-#include "content/public/browser/browser_thread.h"
-#include "content/public/browser/render_process_host.h"
-#include "content/public/browser/render_view_host.h"
-#include "content/public/browser/resource_request_info.h"
-#include "content/public/browser/web_contents.h"
-#include "net/url_request/url_request.h"
-
-using content::BrowserThread;
-using content::RenderViewHost;
-using content::ResourceRequestInfo;
-
-#if defined(COMPILER_GCC)
-
-namespace BASE_HASH_NAMESPACE {
-template <>
-struct hash<const net::URLRequest*> {
-  std::size_t operator()(const net::URLRequest* value) const {
-    return reinterpret_cast<std::size_t>(value);
-  }
-};
-}
-
-#endif
-
-namespace {
-
-bool GetRenderView(const net::URLRequest& request,
-                   int* process_id, int* route_id) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  const ResourceRequestInfo* info = ResourceRequestInfo::ForRequest(&request);
-  if (!info)
-    return false;
-  return info->GetAssociatedRenderView(process_id, route_id);
-}
-
-void CallCacheStatsTabEventOnIOThread(
-    std::pair<int, int> render_view_id,
-    chrome_browser_net::CacheStats::TabEvent event,
-    IOThread* io_thread) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  if (io_thread)
-    io_thread->globals()->cache_stats->OnTabEvent(render_view_id, event);
-}
-
-// Times after a load has started at which stats are collected.
-const int kStatsCollectionTimesMs[] = {
-  500,
-  1000,
-  2000,
-  3000,
-  4000,
-  5000,
-  7500,
-  10000,
-  15000,
-  20000
-};
-
-static int kTabLoadStatsAutoCleanupTimeoutSeconds = 30;
-
-}  // namespace
-
-namespace chrome_browser_net {
-
-// Helper struct keeping stats about the page load progress & cache usage
-// stats during the pageload so far for a given RenderView, identified
-// by a pair of process id and route id.
-struct CacheStats::TabLoadStats {
-  TabLoadStats(std::pair<int, int> render_view_id, CacheStats* owner)
-      : render_view_id(render_view_id),
-        num_active(0),
-        spinner_started(false),
-        next_timer_index(0),
-        timer(false, false) {
-    // Initialize the timer to do an automatic cleanup.  If a pageload is
-    // started for the TabLoadStats within that timeframe, CacheStats
-    // will start using the timer, thereby cancelling the cleanup.
-    // Once CacheStats starts the timer, the object is guaranteed to be
-    // destroyed eventually, so there is no more need for automatic cleanup at
-    // that point.
-    timer.Start(FROM_HERE,
-                base::TimeDelta::FromSeconds(
-                    kTabLoadStatsAutoCleanupTimeoutSeconds),
-                base::Bind(&CacheStats::RemoveTabLoadStats,
-                           base::Unretained(owner),
-                           render_view_id));
-  }
-
-  std::pair<int, int> render_view_id;
-  int num_active;
-  bool spinner_started;
-  base::TimeTicks load_start_time;
-  base::TimeTicks cache_start_time;
-  base::TimeDelta cache_total_time;
-  int next_timer_index;
-  base::Timer timer;
-  // URLRequest's for which there are outstanding cache transactions.
-  base::hash_set<const net::URLRequest*> active_requests;
-};
-
-CacheStatsTabHelper::CacheStatsTabHelper(TabContents* tab)
-    : content::WebContentsObserver(tab->web_contents()),
-      cache_stats_(NULL) {
-  is_otr_profile_ = tab->profile()->IsOffTheRecord();
-}
-
-CacheStatsTabHelper::~CacheStatsTabHelper() {
-}
-
-void CacheStatsTabHelper::DidStartProvisionalLoadForFrame(
-    int64 frame_id,
-    bool is_main_frame,
-    const GURL& validated_url,
-    bool is_error_page,
-    content::RenderViewHost* render_view_host) {
-  if (!is_main_frame)
-    return;
-  if (!validated_url.SchemeIs("http"))
-    return;
-  NotifyCacheStats(CacheStats::SPINNER_START, render_view_host);
-}
-
-void CacheStatsTabHelper::DidStopLoading(RenderViewHost* render_view_host) {
-  NotifyCacheStats(CacheStats::SPINNER_STOP, render_view_host);
-}
-
-void CacheStatsTabHelper::NotifyCacheStats(
-    CacheStats::TabEvent event,
-    RenderViewHost* render_view_host) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  if (is_otr_profile_)
-    return;
-  int process_id = render_view_host->GetProcess()->GetID();
-  int route_id = render_view_host->GetRoutingID();
-  BrowserThread::PostTask(
-      BrowserThread::IO, FROM_HERE,
-      base::Bind(&CallCacheStatsTabEventOnIOThread,
-                 std::pair<int, int>(process_id, route_id),
-                 event,
-                 base::Unretained(g_browser_process->io_thread())));
-}
-
-CacheStats::CacheStats() {
-  for (int i = 0;
-       i < static_cast<int>(arraysize(kStatsCollectionTimesMs));
-       i++) {
-    final_histograms_.push_back(
-        base::LinearHistogram::FactoryGet(
-            "CacheStats.FractionCacheUseFinalPLT_" +
-            base::IntToString(kStatsCollectionTimesMs[i]),
-            0, 101, 102, base::Histogram::kUmaTargetedHistogramFlag));
-    intermediate_histograms_.push_back(
-        base::LinearHistogram::FactoryGet(
-            "CacheStats.FractionCacheUseIntermediatePLT_" +
-            base::IntToString(kStatsCollectionTimesMs[i]),
-            0, 101, 102, base::Histogram::kUmaTargetedHistogramFlag));
-  }
-  DCHECK_EQ(final_histograms_.size(), arraysize(kStatsCollectionTimesMs));
-  DCHECK_EQ(intermediate_histograms_.size(),
-            arraysize(kStatsCollectionTimesMs));
-}
-
-CacheStats::~CacheStats() {
-  STLDeleteValues(&tab_load_stats_);
-}
-
-CacheStats::TabLoadStats* CacheStats::GetTabLoadStats(
-    std::pair<int, int> render_view_id) {
-  TabLoadStatsMap::const_iterator it = tab_load_stats_.find(render_view_id);
-  if (it != tab_load_stats_.end())
-    return it->second;
-  TabLoadStats* new_tab_load_stats = new TabLoadStats(render_view_id, this);
-  tab_load_stats_[render_view_id] = new_tab_load_stats;
-  return new_tab_load_stats;
-}
-
-void CacheStats::RemoveTabLoadStats(std::pair<int, int> render_view_id) {
-  TabLoadStatsMap::iterator it = tab_load_stats_.find(render_view_id);
-  if (it != tab_load_stats_.end()) {
-    delete it->second;
-    tab_load_stats_.erase(it);
-  }
-}
-
-void CacheStats::OnCacheWaitStateChange(
-    const net::URLRequest& request,
-    net::NetworkDelegate::CacheWaitState state) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  if (main_request_contexts_.count(request.context()) < 1)
-    return;
-  int process_id, route_id;
-  if (!GetRenderView(request, &process_id, &route_id))
-    return;
-  TabLoadStats* stats =
-      GetTabLoadStats(std::pair<int, int>(process_id, route_id));
-  bool newly_started = false;
-  bool newly_finished = false;
-  switch (state) {
-    case net::NetworkDelegate::CACHE_WAIT_STATE_START:
-      DCHECK(stats->active_requests.count(&request) == 0);
-      newly_started = true;
-      stats->active_requests.insert(&request);
-      break;
-    case net::NetworkDelegate::CACHE_WAIT_STATE_FINISH:
-      if (stats->active_requests.count(&request) > 0) {
-        stats->active_requests.erase(&request);
-        newly_finished = true;
-      }
-      break;
-    case net::NetworkDelegate::CACHE_WAIT_STATE_RESET:
-      if (stats->active_requests.count(&request) > 0) {
-        stats->active_requests.erase(&request);
-        newly_finished = true;
-      }
-      break;
-  }
-  DCHECK_GE(stats->num_active, 0);
-  if (newly_started) {
-    DCHECK(!newly_finished);
-    if (stats->num_active == 0) {
-      stats->cache_start_time = base::TimeTicks::Now();
-    }
-    stats->num_active++;
-  }
-  if (newly_finished) {
-    DCHECK(!newly_started);
-    if (stats->num_active == 1) {
-      stats->cache_total_time +=
-          base::TimeTicks::Now() - stats->cache_start_time;
-    }
-    stats->num_active--;
-  }
-  DCHECK_GE(stats->num_active, 0);
-}
-
-void CacheStats::OnTabEvent(std::pair<int, int> render_view_id,
-                            TabEvent event) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  TabLoadStats* stats = GetTabLoadStats(render_view_id);
-  if (event == SPINNER_START) {
-    stats->spinner_started = true;
-    stats->cache_total_time = base::TimeDelta();
-    stats->cache_start_time = base::TimeTicks::Now();
-    stats->load_start_time = base::TimeTicks::Now();
-    stats->next_timer_index = 0;
-    ScheduleTimer(stats);
-  } else {
-    DCHECK_EQ(event, SPINNER_STOP);
-    if (stats->spinner_started) {
-      stats->spinner_started = false;
-      base::TimeDelta load_time =
-          base::TimeTicks::Now() - stats->load_start_time;
-      if (stats->num_active > 1)
-        stats->cache_total_time +=
-            base::TimeTicks::Now() - stats->cache_start_time;
-      RecordCacheFractionHistogram(load_time, stats->cache_total_time, true,
-                                   stats->next_timer_index);
-    }
-    RemoveTabLoadStats(render_view_id);
-  }
-}
-
-void CacheStats::ScheduleTimer(TabLoadStats* stats) {
-  int timer_index = stats->next_timer_index;
-  DCHECK(timer_index >= 0 &&
-         timer_index < static_cast<int>(arraysize(kStatsCollectionTimesMs)));
-  base::TimeDelta delta =
-      base::TimeDelta::FromMilliseconds(kStatsCollectionTimesMs[timer_index]);
-  delta -= base::TimeTicks::Now() - stats->load_start_time;
-
-  // If the ScheduleTimer call was delayed significantly, like when one's using
-  // a debugger, don't try to start the timer with a negative time.
-  if (delta < base::TimeDelta()) {
-    RemoveTabLoadStats(stats->render_view_id);
-    return;
-  }
-
-  stats->timer.Start(FROM_HERE,
-                     delta,
-                     base::Bind(&CacheStats::TimerCallback,
-                                base::Unretained(this),
-                                base::Unretained(stats)));
-}
-
-void CacheStats::TimerCallback(TabLoadStats* stats) {
-  DCHECK(stats->spinner_started);
-  base::TimeDelta load_time = base::TimeTicks::Now() - stats->load_start_time;
-  base::TimeDelta cache_time = stats->cache_total_time;
-  if (stats->num_active > 1)
-    cache_time += base::TimeTicks::Now() - stats->cache_start_time;
-  RecordCacheFractionHistogram(load_time, cache_time, false,
-                               stats->next_timer_index);
-  stats->next_timer_index++;
-  if (stats->next_timer_index <
-      static_cast<int>(arraysize(kStatsCollectionTimesMs))) {
-    ScheduleTimer(stats);
-  } else {
-    RemoveTabLoadStats(stats->render_view_id);
-  }
-}
-
-void CacheStats::RecordCacheFractionHistogram(base::TimeDelta elapsed,
-                                              base::TimeDelta cache_time,
-                                              bool is_load_done,
-                                              int timer_index) {
-  DCHECK(timer_index >= 0 &&
-         timer_index < static_cast<int>(arraysize(kStatsCollectionTimesMs)));
-
-  if (elapsed.InMilliseconds() <= 0)
-    return;
-
-  int64 cache_fraction_percentage =
-      100 * cache_time.InMilliseconds() / elapsed.InMilliseconds();
-
-  DCHECK(cache_fraction_percentage >= 0 && cache_fraction_percentage <= 100);
-
-  if (is_load_done) {
-    final_histograms_[timer_index]->Add(cache_fraction_percentage);
-  } else {
-    intermediate_histograms_[timer_index]->Add(cache_fraction_percentage);
-  }
-}
-
-void CacheStats::RegisterURLRequestContext(
-    const net::URLRequestContext* context,
-    ChromeURLRequestContext::ContextType type) {
-  if (type == ChromeURLRequestContext::CONTEXT_TYPE_MAIN)
-    main_request_contexts_.insert(context);
-}
-
-void CacheStats::UnregisterURLRequestContext(
-    const net::URLRequestContext* context) {
-  main_request_contexts_.erase(context);
-}
-
-}  // namespace chrome_browser_net