File: metric_rate_controller.cc

package info (click to toggle)
chromium 139.0.7258.127-1
  • links: PTS, VCS
  • area: main
  • in suites:
  • size: 6,122,068 kB
  • sloc: cpp: 35,100,771; ansic: 7,163,530; javascript: 4,103,002; python: 1,436,920; asm: 946,517; xml: 746,709; pascal: 187,653; perl: 88,691; sh: 88,436; objc: 79,953; sql: 51,488; cs: 44,583; fortran: 24,137; makefile: 22,147; tcl: 15,277; php: 13,980; yacc: 8,984; ruby: 7,485; awk: 3,720; lisp: 3,096; lex: 1,327; ada: 727; jsp: 228; sed: 36
file content (61 lines) | stat: -rw-r--r-- 1,915 bytes parent folder | download | duplicates (11)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
// Copyright 2021 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "components/reporting/metrics/metric_rate_controller.h"

#include "base/functional/callback_helpers.h"
#include "base/location.h"
#include "components/reporting/metrics/reporting_settings.h"

namespace reporting {

// static
BASE_FEATURE(kEnableTelemetryTestingRates,
             "EnableTelemetryTestingRates",
             base::FEATURE_DISABLED_BY_DEFAULT);

MetricRateController::MetricRateController(
    base::RepeatingClosure task,
    ReportingSettings* reporting_settings,
    const std::string& rate_setting_path,
    base::TimeDelta default_rate,
    int rate_unit_to_ms)
    : task_(std::move(task)),
      reporting_settings_(reporting_settings),
      rate_setting_path_(rate_setting_path),
      rate_(default_rate),
      default_rate_(default_rate),
      rate_unit_to_ms_(rate_unit_to_ms) {}

MetricRateController::~MetricRateController() = default;

void MetricRateController::Start() {
  bool trusted = reporting_settings_->PrepareTrustedValues(base::DoNothing());
  if (trusted) {
    int current_rate;
    if (reporting_settings_->GetInteger(rate_setting_path_, &current_rate)) {
      rate_ = base::Milliseconds(current_rate * rate_unit_to_ms_);
    }
  }
  // Use default rate if setting rate is too high or if testing flag is enabled
  // to have a higher collection and reporting rate set using the default rate.
  if (rate_ < base::Milliseconds(1) ||
      base::FeatureList::IsEnabled(kEnableTelemetryTestingRates)) {
    if (default_rate_ < base::Milliseconds(1)) {
      return;
    }
    rate_ = default_rate_;
  }
  timer_.Start(FROM_HERE, rate_, this, &MetricRateController::Run);
}

void MetricRateController::Stop() {
  timer_.Stop();
}

void MetricRateController::Run() {
  task_.Run();
  Start();
}
}  // namespace reporting