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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
// Copyright 2013 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 "base/metrics/histogram_delta_serialization.h"
#include "base/logging.h"
#include "base/metrics/histogram_base.h"
#include "base/metrics/histogram_snapshot_manager.h"
#include "base/numerics/safe_conversions.h"
#include "base/pickle.h"
#include "base/values.h"
namespace base {
namespace {
// Create or find existing histogram and add the samples from pickle.
// Silently returns when seeing any data problem in the pickle.
void DeserializeHistogramAndAddSamples(PickleIterator* iter) {
HistogramBase* histogram = DeserializeHistogramInfo(iter);
if (!histogram)
return;
if (histogram->flags() & HistogramBase::kIPCSerializationSourceFlag) {
DVLOG(1) << "Single process mode, histogram observed and not copied: "
<< histogram->histogram_name();
return;
}
histogram->AddSamplesFromPickle(iter);
}
} // namespace
HistogramDeltaSerialization::HistogramDeltaSerialization(
const std::string& caller_name)
: histogram_snapshot_manager_(this),
serialized_deltas_(NULL) {
inconsistencies_histogram_ =
LinearHistogram::FactoryGet(
"Histogram.Inconsistencies" + caller_name, 1,
HistogramBase::NEVER_EXCEEDED_VALUE,
HistogramBase::NEVER_EXCEEDED_VALUE + 1,
HistogramBase::kUmaTargetedHistogramFlag);
inconsistencies_unique_histogram_ =
LinearHistogram::FactoryGet(
"Histogram.Inconsistencies" + caller_name + "Unique", 1,
HistogramBase::NEVER_EXCEEDED_VALUE,
HistogramBase::NEVER_EXCEEDED_VALUE + 1,
HistogramBase::kUmaTargetedHistogramFlag);
inconsistent_snapshot_histogram_ =
Histogram::FactoryGet(
"Histogram.InconsistentSnapshot" + caller_name, 1, 1000000, 50,
HistogramBase::kUmaTargetedHistogramFlag);
}
HistogramDeltaSerialization::~HistogramDeltaSerialization() {
}
void HistogramDeltaSerialization::PrepareAndSerializeDeltas(
std::vector<std::string>* serialized_deltas) {
serialized_deltas_ = serialized_deltas;
// Note: Before serializing, we set the kIPCSerializationSourceFlag for all
// the histograms, so that the receiving process can distinguish them from the
// local histograms.
histogram_snapshot_manager_.PrepareDeltas(
Histogram::kIPCSerializationSourceFlag, Histogram::kNoFlags);
serialized_deltas_ = NULL;
}
// static
void HistogramDeltaSerialization::DeserializeAndAddSamples(
const std::vector<std::string>& serialized_deltas) {
for (std::vector<std::string>::const_iterator it = serialized_deltas.begin();
it != serialized_deltas.end(); ++it) {
Pickle pickle(it->data(), checked_cast<int>(it->size()));
PickleIterator iter(pickle);
DeserializeHistogramAndAddSamples(&iter);
}
}
void HistogramDeltaSerialization::RecordDelta(
const HistogramBase& histogram,
const HistogramSamples& snapshot) {
DCHECK_NE(0, snapshot.TotalCount());
Pickle pickle;
histogram.SerializeInfo(&pickle);
snapshot.Serialize(&pickle);
serialized_deltas_->push_back(
std::string(static_cast<const char*>(pickle.data()), pickle.size()));
}
void HistogramDeltaSerialization::InconsistencyDetected(
HistogramBase::Inconsistency problem) {
inconsistencies_histogram_->Add(problem);
}
void HistogramDeltaSerialization::UniqueInconsistencyDetected(
HistogramBase::Inconsistency problem) {
inconsistencies_unique_histogram_->Add(problem);
}
void HistogramDeltaSerialization::InconsistencyDetectedInLoggedCount(
int amount) {
inconsistent_snapshot_histogram_->Add(std::abs(amount));
}
} // namespace base
|
