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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
// Copyright 2017 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 "components/metrics/single_sample_metrics.h"
#include <memory>
#include <utility>
#include "base/metrics/single_sample_metrics.h"
#include "base/threading/thread_checker.h"
#include "components/metrics/single_sample_metrics_factory_impl.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/self_owned_receiver.h"
namespace metrics {
namespace {
class MojoSingleSampleMetric : public mojom::SingleSampleMetric {
public:
MojoSingleSampleMetric(const std::string& histogram_name,
base::HistogramBase::Sample min,
base::HistogramBase::Sample max,
uint32_t bucket_count,
int32_t flags)
: metric_(histogram_name, min, max, bucket_count, flags) {}
~MojoSingleSampleMetric() override {}
private:
// mojom::SingleSampleMetric:
void SetSample(base::HistogramBase::Sample sample) override {
metric_.SetSample(sample);
}
base::DefaultSingleSampleMetric metric_;
DISALLOW_COPY_AND_ASSIGN(MojoSingleSampleMetric);
};
class MojoSingleSampleMetricsProvider
: public mojom::SingleSampleMetricsProvider {
public:
MojoSingleSampleMetricsProvider() {}
~MojoSingleSampleMetricsProvider() override {
DCHECK(thread_checker_.CalledOnValidThread());
}
private:
// mojom::SingleSampleMetricsProvider:
void AcquireSingleSampleMetric(
const std::string& histogram_name,
base::HistogramBase::Sample min,
base::HistogramBase::Sample max,
uint32_t bucket_count,
int32_t flags,
mojo::PendingReceiver<mojom::SingleSampleMetric> receiver) override {
DCHECK(thread_checker_.CalledOnValidThread());
mojo::MakeSelfOwnedReceiver(
std::make_unique<MojoSingleSampleMetric>(histogram_name, min, max,
bucket_count, flags),
std::move(receiver));
}
// Providers must be created, used on, and destroyed on the same thread.
base::ThreadChecker thread_checker_;
DISALLOW_COPY_AND_ASSIGN(MojoSingleSampleMetricsProvider);
};
} // namespace
// static
void InitializeSingleSampleMetricsFactory(CreateProviderCB create_provider_cb) {
base::SingleSampleMetricsFactory::SetFactory(
std::make_unique<SingleSampleMetricsFactoryImpl>(
std::move(create_provider_cb)));
}
// static
void CreateSingleSampleMetricsProvider(
mojo::PendingReceiver<mojom::SingleSampleMetricsProvider> receiver) {
mojo::MakeSelfOwnedReceiver(
std::make_unique<MojoSingleSampleMetricsProvider>(), std::move(receiver));
}
} // namespace metrics
|
