components/policy/core/common/policy_statistics_collector.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "components/policy/core/common/policy_statistics_collector.h"
   6
   7 #include <algorithm>
   8 #include <string>
   9
  10 #include "base/bind.h"
  11 #include "base/callback.h"
  12 #include "base/location.h"
  13 #include "base/logging.h"
  14 #include "base/metrics/sparse_histogram.h"
  15 #include "base/prefs/pref_registry_simple.h"
  16 #include "base/prefs/pref_service.h"
  17 #include "base/task_runner.h"
  18 #include "components/policy/core/common/policy_pref_names.h"
  19 #include "components/policy/core/common/policy_service.h"
  20
  21 namespace policy {
  22
  23 const int PolicyStatisticsCollector::kStatisticsUpdateRate =
  24     24 * 60 * 60 * 1000;  // 24 hours.
  25
  26 PolicyStatisticsCollector::PolicyStatisticsCollector(
  27     const GetChromePolicyDetailsCallback& get_details,
  28     const Schema& chrome_schema,
  29     PolicyService* policy_service,
  30     PrefService* prefs,
  31     const scoped_refptr<base::TaskRunner>& task_runner)
  32     : get_details_(get_details),
  33       chrome_schema_(chrome_schema),
  34       policy_service_(policy_service),
  35       prefs_(prefs),
  36       task_runner_(task_runner) {
  37 }
  38
  39 PolicyStatisticsCollector::~PolicyStatisticsCollector() {
  40 }
  41
  42 void PolicyStatisticsCollector::Initialize() {
  43   using base::Time;
  44   using base::TimeDelta;
  45
  46   TimeDelta update_rate = TimeDelta::FromMilliseconds(kStatisticsUpdateRate);
  47   Time last_update = Time::FromInternalValue(
  48       prefs_->GetInt64(policy_prefs::kLastPolicyStatisticsUpdate));
  49   TimeDelta delay = std::max(Time::Now() - last_update, TimeDelta::FromDays(0));
  50   if (delay >= update_rate)
  51     CollectStatistics();
  52   else
  53     ScheduleUpdate(update_rate - delay);
  54 }
  55
  56 // static
  57 void PolicyStatisticsCollector::RegisterPrefs(PrefRegistrySimple* registry) {
  58   registry->RegisterInt64Pref(policy_prefs::kLastPolicyStatisticsUpdate, 0);
  59 }
  60
  61 void PolicyStatisticsCollector::RecordPolicyUse(int id) {
  62   UMA_HISTOGRAM_SPARSE_SLOWLY("Enterprise.Policies", id);
  63 }
  64
  65 void PolicyStatisticsCollector::CollectStatistics() {
  66   const PolicyMap& policies = policy_service_->GetPolicies(
  67       PolicyNamespace(POLICY_DOMAIN_CHROME, std::string()));
  68
  69   // Collect statistics.
  70   for (Schema::Iterator it(chrome_schema_.GetPropertiesIterator());
  71        !it.IsAtEnd(); it.Advance()) {
  72     if (policies.Get(it.key())) {
  73       const PolicyDetails* details = get_details_.Run(it.key());
  74       if (details)
  75         RecordPolicyUse(details->id);
  76       else
  77         NOTREACHED();
  78     }
  79   }
  80
  81   // Take care of next update.
  82   prefs_->SetInt64(policy_prefs::kLastPolicyStatisticsUpdate,
  83                    base::Time::Now().ToInternalValue());
  84   ScheduleUpdate(base::TimeDelta::FromMilliseconds(kStatisticsUpdateRate));
  85 }
  86
  87 void PolicyStatisticsCollector::ScheduleUpdate(base::TimeDelta delay) {
  88   update_callback_.Reset(base::Bind(
  89       &PolicyStatisticsCollector::CollectStatistics,
  90       base::Unretained(this)));
  91   task_runner_->PostDelayedTask(FROM_HERE, update_callback_.callback(), delay);
  92 }
  93
  94 }  // namespace policy