#include "base/metrics/histogram.h"
#include <inttypes.h>
#include <limits.h>
#include <math.h>
#include <algorithm>
#include <atomic>
#include <memory>
#include <string>
#include <string_view>
#include <utility>
#include "base/compiler_specific.h"
#include "base/debug/alias.h"
#include "base/debug/crash_logging.h"
#include "base/debug/dump_without_crashing.h"
#include "base/logging.h"
#include "base/memory/ptr_util.h"
#include "base/memory/raw_ptr.h"
#include "base/memory/raw_ref.h"
#include "base/metrics/dummy_histogram.h"
#include "base/metrics/histogram_functions.h"
#include "base/metrics/metrics_hashes.h"
#include "base/metrics/persistent_histogram_allocator.h"
#include "base/metrics/persistent_memory_allocator.h"
#include "base/metrics/sample_vector.h"
#include "base/metrics/statistics_recorder.h"
#include "base/notreached.h"
#include "base/pickle.h"
#include "base/strings/string_util.h"
#include "base/strings/utf_string_conversions.h"
#include "base/synchronization/lock.h"
#include "base/values.h"
#include "build/build_config.h"
namespace base {
namespace {
bool ReadHistogramArguments(PickleIterator* iter,
std::string* histogram_name,
int* flags,
int* declared_min,
int* declared_max,
size_t* bucket_count,
uint32_t* range_checksum) {
uint32_t bucket_count_u32;
if (!iter->ReadString(histogram_name) || !iter->ReadInt(flags) ||
!iter->ReadInt(declared_min) || !iter->ReadInt(declared_max) ||
!iter->ReadUInt32(&bucket_count_u32) ||
!iter->ReadUInt32(range_checksum)) {
DLOG(ERROR) << "Pickle error decoding Histogram: " << *histogram_name;
return false;
}
*bucket_count = bucket_count_u32;
if (*declared_max <= 0 || *declared_min <= 0 ||
*declared_max < *declared_min ||
INT_MAX / sizeof(HistogramBase::Count32) <= *bucket_count ||
*bucket_count < 2) {
DLOG(ERROR) << "Values error decoding Histogram: " << histogram_name;
return false;
}
*flags &= ~HistogramBase::kIPCSerializationSourceFlag;
return true;
}
bool ValidateRangeChecksum(const HistogramBase& histogram,
uint32_t range_checksum) {
if (histogram.GetHistogramType() == DUMMY_HISTOGRAM) {
return true;
}
const Histogram& casted_histogram = static_cast<const Histogram&>(histogram);
return casted_histogram.bucket_ranges()->checksum() == range_checksum;
}
}
typedef HistogramBase::Count32 Count32;
typedef HistogramBase::Sample32 Sample32;
class Histogram::Factory {
public:
Factory(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags)
: Factory(name, HISTOGRAM, minimum, maximum, bucket_count, flags) {}
Factory(const Factory&) = delete;
Factory& operator=(const Factory&) = delete;
HistogramBase* Build();
protected:
Factory(std::string_view name,
HistogramType histogram_type,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags)
: name_(name),
histogram_type_(histogram_type),
minimum_(minimum),
maximum_(maximum),
bucket_count_(bucket_count),
flags_(flags) {}
virtual BucketRanges* CreateRanges() {
BucketRanges* ranges = new BucketRanges(bucket_count_ + 1);
Histogram::InitializeBucketRanges(minimum_, maximum_, ranges);
return ranges;
}
virtual std::unique_ptr<HistogramBase> HeapAlloc(const BucketRanges* ranges) {
return WrapUnique(new Histogram(GetPermanentName(name_), ranges));
}
virtual void FillHistogram(HistogramBase* histogram) {}
const std::string_view name_;
const HistogramType histogram_type_;
Sample32 minimum_;
Sample32 maximum_;
size_t bucket_count_;
int32_t flags_;
};
HistogramBase* Histogram::Factory::Build() {
uint64_t name_hash = HashMetricName(name_);
HistogramBase* histogram =
StatisticsRecorder::FindHistogram(name_hash, name_);
if (!histogram) {
bool should_record = StatisticsRecorder::ShouldRecordHistogram(
ParseMetricHashTo32Bits(name_hash));
if (!should_record) {
return DummyHistogram::GetInstance();
}
const BucketRanges* created_ranges = CreateRanges();
const BucketRanges* registered_ranges =
StatisticsRecorder::RegisterOrDeleteDuplicateRanges(created_ranges);
if (bucket_count_ == 0) {
bucket_count_ = registered_ranges->bucket_count();
minimum_ = registered_ranges->range(1);
maximum_ = registered_ranges->range(bucket_count_ - 1);
}
DCHECK_EQ(minimum_, registered_ranges->range(1));
DCHECK_EQ(maximum_, registered_ranges->range(bucket_count_ - 1));
PersistentHistogramAllocator::Reference histogram_ref = 0;
std::unique_ptr<HistogramBase> tentative_histogram;
PersistentHistogramAllocator* allocator = GlobalHistogramAllocator::Get();
if (allocator) {
tentative_histogram = allocator->AllocateHistogram(
histogram_type_, name_, name_hash, minimum_, maximum_,
registered_ranges, flags_, &histogram_ref);
}
if (!tentative_histogram) {
DCHECK(!histogram_ref);
flags_ &= ~HistogramBase::kIsPersistent;
tentative_histogram = HeapAlloc(registered_ranges);
tentative_histogram->SetFlags(flags_);
}
FillHistogram(tentative_histogram.get());
const void* tentative_histogram_ptr = tentative_histogram.get();
histogram = StatisticsRecorder::RegisterOrDeleteDuplicate(
tentative_histogram.release());
if (histogram_ref) {
allocator->FinalizeHistogram(histogram_ref,
histogram == tentative_histogram_ptr);
}
}
if (histogram_type_ != histogram->GetHistogramType() ||
(bucket_count_ != 0 && !histogram->HasConstructionArguments(
minimum_, maximum_, bucket_count_))) {
UmaHistogramSparse("Histogram.MismatchedConstructionArguments",
static_cast<Sample32>(name_hash));
DLOG(ERROR) << "Histogram " << name_
<< " has mismatched construction arguments";
return DummyHistogram::GetInstance();
}
return histogram;
}
HistogramBase* Histogram::FactoryGet(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryTimeGet(std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryMicrosecondsTimeGet(std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryMicrosecondsTimeGetInternal(name, minimum, maximum,
bucket_count, flags);
}
HistogramBase* Histogram::FactoryGet(const std::string& name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryTimeGet(const std::string& name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryMicrosecondsTimeGet(const std::string& name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryMicrosecondsTimeGetInternal(name, minimum, maximum,
bucket_count, flags);
}
HistogramBase* Histogram::FactoryGet(const char* name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryTimeGet(const char* name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* Histogram::FactoryMicrosecondsTimeGet(const char* name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryMicrosecondsTimeGetInternal(name, minimum, maximum,
bucket_count, flags);
}
std::unique_ptr<HistogramBase> Histogram::PersistentCreate(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta) {
return WrapUnique(new Histogram(durable_name, ranges, counts, logged_counts,
meta, logged_meta));
}
void Histogram::InitializeBucketRanges(Sample32 minimum,
Sample32 maximum,
BucketRanges* ranges) {
double log_max = log(static_cast<double>(maximum));
double log_ratio;
double log_next;
size_t bucket_index = 1;
Sample32 current = minimum;
ranges->set_range(bucket_index, current);
size_t bucket_count = ranges->bucket_count();
while (bucket_count > ++bucket_index) {
double log_current;
log_current = log(static_cast<double>(current));
debug::Alias(&log_current);
log_ratio = (log_max - log_current) / (bucket_count - bucket_index);
log_next = log_current + log_ratio;
Sample32 next;
next = static_cast<int>(std::round(exp(log_next)));
if (next > current) {
current = next;
} else {
++current;
}
ranges->set_range(bucket_index, current);
}
ranges->set_range(ranges->bucket_count(), HistogramBase::kSampleType_MAX);
ranges->ResetChecksum();
}
const int Histogram::kCommonRaceBasedCountMismatch = 5;
uint32_t Histogram::FindCorruption(const HistogramSamples& samples) const {
uint32_t inconsistencies = NO_INCONSISTENCIES;
Sample32 previous_range = -1;
for (size_t index = 0; index < bucket_count(); ++index) {
int new_range = ranges(index);
if (previous_range >= new_range) {
inconsistencies |= BUCKET_ORDER_ERROR;
}
previous_range = new_range;
}
if (!bucket_ranges()->HasValidChecksum()) {
inconsistencies |= RANGE_CHECKSUM_ERROR;
}
int64_t delta64 = samples.redundant_count() - samples.TotalCount();
if (delta64 != 0) {
int delta = static_cast<int>(delta64);
if (delta != delta64) {
delta = INT_MAX;
}
if (delta > 0) {
if (delta > kCommonRaceBasedCountMismatch) {
inconsistencies |= COUNT_HIGH_ERROR;
}
} else {
DCHECK_GT(0, delta);
if (-delta > kCommonRaceBasedCountMismatch) {
inconsistencies |= COUNT_LOW_ERROR;
}
}
}
return inconsistencies;
}
const BucketRanges* Histogram::bucket_ranges() const {
return unlogged_samples_->bucket_ranges();
}
Sample32 Histogram::declared_min() const {
const BucketRanges* ranges = bucket_ranges();
if (ranges->bucket_count() < 2) {
return -1;
}
return ranges->range(1);
}
Sample32 Histogram::declared_max() const {
const BucketRanges* ranges = bucket_ranges();
if (ranges->bucket_count() < 2) {
return -1;
}
return ranges->range(ranges->bucket_count() - 1);
}
Sample32 Histogram::ranges(size_t i) const {
return bucket_ranges()->range(i);
}
size_t Histogram::bucket_count() const {
return bucket_ranges()->bucket_count();
}
bool Histogram::InspectConstructionArguments(std::string_view name,
Sample32* minimum,
Sample32* maximum,
size_t* bucket_count) {
bool check_okay = true;
if (*minimum > *maximum) {
DLOG(ERROR) << "Histogram: " << name << " has swapped minimum/maximum";
check_okay = false;
std::swap(*minimum, *maximum);
}
if (*minimum < 1) {
*minimum = 1;
if (*maximum < 1) {
*maximum = 1;
}
}
if (*maximum >= kSampleType_MAX) {
DLOG(ERROR) << "Histogram: " << name << " has bad maximum: " << *maximum;
*maximum = kSampleType_MAX - 1;
}
if (*bucket_count > kBucketCount_MAX) {
UmaHistogramSparse("Histogram.TooManyBuckets.1000",
static_cast<Sample32>(HashMetricName(name)));
if (!StartsWith(name, "Blink.UseCounter")) {
DLOG(ERROR) << "Histogram: " << name
<< " has bad bucket_count: " << *bucket_count << " (limit "
<< kBucketCount_MAX << ")";
*bucket_count = 102;
check_okay = false;
}
}
if (*maximum == *minimum) {
check_okay = false;
*maximum = *minimum + 1;
}
if (*bucket_count < 3) {
check_okay = false;
*bucket_count = 3;
}
const size_t max_buckets = static_cast<size_t>(*maximum - *minimum + 2);
if (*bucket_count > max_buckets) {
check_okay = false;
*bucket_count = max_buckets;
}
if (!check_okay) {
UmaHistogramSparse("Histogram.BadConstructionArguments",
static_cast<Sample32>(HashMetricName(name)));
}
return check_okay;
}
uint64_t Histogram::name_hash() const {
return unlogged_samples_->id();
}
HistogramType Histogram::GetHistogramType() const {
return HISTOGRAM;
}
bool Histogram::HasConstructionArguments(Sample32 expected_minimum,
Sample32 expected_maximum,
size_t expected_bucket_count) const {
return (expected_bucket_count == bucket_count() &&
expected_minimum == declared_min() &&
expected_maximum == declared_max());
}
void Histogram::Add(int value) {
AddCount(value, 1);
}
void Histogram::AddCount(int value, int count) {
DCHECK_EQ(0, ranges(0));
DCHECK_EQ(kSampleType_MAX, ranges(bucket_count()));
if (value > kSampleType_MAX - 1) {
value = kSampleType_MAX - 1;
}
if (value < 0) {
value = 0;
}
if (count <= 0) {
NOTREACHED();
}
unlogged_samples_->Accumulate(value, count);
if (StatisticsRecorder::have_active_callbacks()) [[unlikely]] {
FindAndRunCallbacks(value);
}
}
std::unique_ptr<HistogramSamples> Histogram::SnapshotSamples() const {
return SnapshotAllSamples();
}
std::unique_ptr<HistogramSamples> Histogram::SnapshotUnloggedSamples() const {
return SnapshotUnloggedSamplesImpl();
}
void Histogram::MarkSamplesAsLogged(const HistogramSamples& samples) {
#if DCHECK_IS_ON()
DCHECK(!final_delta_created_);
#endif
unlogged_samples_->Subtract(samples);
logged_samples_->Add(samples);
}
std::unique_ptr<HistogramSamples> Histogram::SnapshotDelta() {
#if DCHECK_IS_ON()
DCHECK(!final_delta_created_);
#endif
std::unique_ptr<HistogramSamples> snapshot =
std::make_unique<SampleVector>(unlogged_samples_->id(), bucket_ranges());
snapshot->Extract(*unlogged_samples_);
logged_samples_->Add(*snapshot);
return snapshot;
}
std::unique_ptr<HistogramSamples> Histogram::SnapshotFinalDelta() const {
#if DCHECK_IS_ON()
DCHECK(!final_delta_created_);
final_delta_created_ = true;
#endif
return SnapshotUnloggedSamples();
}
bool Histogram::AddSamples(const HistogramSamples& samples) {
return unlogged_samples_->Add(samples);
}
bool Histogram::AddSamplesFromPickle(PickleIterator* iter) {
return unlogged_samples_->AddFromPickle(iter);
}
base::Value::Dict Histogram::ToGraphDict() const {
std::unique_ptr<SampleVector> snapshot = SnapshotAllSamples();
return snapshot->ToGraphDict(histogram_name(), flags());
}
void Histogram::SerializeInfoImpl(Pickle* pickle) const {
DCHECK(bucket_ranges()->HasValidChecksum());
pickle->WriteString(histogram_name());
pickle->WriteInt(flags());
pickle->WriteInt(declared_min());
pickle->WriteInt(declared_max());
pickle->WriteUInt32(static_cast<uint32_t>(bucket_count()));
pickle->WriteUInt32(bucket_ranges()->checksum());
}
Histogram::Histogram(DurableStringView durable_name, const BucketRanges* ranges)
: HistogramBase(durable_name) {
DCHECK(ranges) << histogram_name();
unlogged_samples_ =
std::make_unique<SampleVector>(HashMetricName(histogram_name()), ranges);
logged_samples_ =
std::make_unique<SampleVector>(unlogged_samples_->id(), ranges);
}
Histogram::Histogram(DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta)
: HistogramBase(durable_name) {
const auto name = histogram_name();
const auto id = HashMetricName(name);
DCHECK(ranges) << name;
unlogged_samples_ =
std::make_unique<PersistentSampleVector>(name, id, ranges, meta, counts);
logged_samples_ = std::make_unique<PersistentSampleVector>(
name, id, ranges, logged_meta, logged_counts);
}
Histogram::~Histogram() = default;
std::string Histogram::GetAsciiBucketRange(size_t i) const {
return GetSimpleAsciiBucketRange(ranges(i));
}
HistogramBase* Histogram::DeserializeInfoImpl(PickleIterator* iter) {
std::string histogram_name;
int flags;
int declared_min;
int declared_max;
size_t bucket_count;
uint32_t range_checksum;
if (!ReadHistogramArguments(iter, &histogram_name, &flags, &declared_min,
&declared_max, &bucket_count, &range_checksum)) {
return nullptr;
}
HistogramBase* histogram = Histogram::FactoryGet(
histogram_name, declared_min, declared_max, bucket_count, flags);
if (!histogram) {
return nullptr;
}
if (!ValidateRangeChecksum(*histogram, range_checksum)) {
return nullptr;
}
return histogram;
}
HistogramBase* Histogram::FactoryGetInternal(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
bool valid_arguments =
InspectConstructionArguments(name, &minimum, &maximum, &bucket_count);
if (!valid_arguments) {
SCOPED_CRASH_KEY_STRING32("BadHistogramArgs", "name", std::string(name));
base::debug::DumpWithoutCrashing();
DLOG(ERROR) << "Histogram " << name << " dropped for invalid parameters.";
return DummyHistogram::GetInstance();
}
return Factory(name, minimum, maximum, bucket_count, flags).Build();
}
HistogramBase* Histogram::FactoryTimeGetInternal(std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
DCHECK_LT(minimum.InMilliseconds(), std::numeric_limits<Sample32>::max());
DCHECK_LT(maximum.InMilliseconds(), std::numeric_limits<Sample32>::max());
return FactoryGetInternal(name, static_cast<Sample32>(minimum.InMilliseconds()),
static_cast<Sample32>(maximum.InMilliseconds()),
bucket_count, flags);
}
HistogramBase* Histogram::FactoryMicrosecondsTimeGetInternal(
std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
DCHECK_LT(minimum.InMicroseconds(), std::numeric_limits<Sample32>::max());
DCHECK_LT(maximum.InMicroseconds(), std::numeric_limits<Sample32>::max());
return FactoryGetInternal(name, static_cast<Sample32>(minimum.InMicroseconds()),
static_cast<Sample32>(maximum.InMicroseconds()),
bucket_count, flags);
}
std::unique_ptr<SampleVector> Histogram::SnapshotAllSamples() const {
std::unique_ptr<SampleVector> samples = SnapshotUnloggedSamplesImpl();
samples->Add(*logged_samples_);
return samples;
}
std::unique_ptr<SampleVector> Histogram::SnapshotUnloggedSamplesImpl() const {
std::unique_ptr<SampleVector> samples(
new SampleVector(unlogged_samples_->id(), bucket_ranges()));
samples->Add(*unlogged_samples_);
return samples;
}
Value::Dict Histogram::GetParameters() const {
Value::Dict params;
params.Set("type", HistogramTypeToString(GetHistogramType()));
params.Set("min", declared_min());
params.Set("max", declared_max());
params.Set("bucket_count", static_cast<int>(bucket_count()));
return params;
}
class LinearHistogram::Factory : public Histogram::Factory {
public:
Factory(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags,
const DescriptionPair* descriptions)
: Histogram::Factory(name,
LINEAR_HISTOGRAM,
minimum,
maximum,
bucket_count,
flags) {
descriptions_ = descriptions;
}
Factory(const Factory&) = delete;
Factory& operator=(const Factory&) = delete;
protected:
BucketRanges* CreateRanges() override {
BucketRanges* ranges = new BucketRanges(bucket_count_ + 1);
LinearHistogram::InitializeBucketRanges(minimum_, maximum_, ranges);
return ranges;
}
std::unique_ptr<HistogramBase> HeapAlloc(
const BucketRanges* ranges) override {
return WrapUnique(new LinearHistogram(GetPermanentName(name_), ranges));
}
void FillHistogram(HistogramBase* base_histogram) override {
Histogram::Factory::FillHistogram(base_histogram);
if (base_histogram->GetHistogramType() == DUMMY_HISTOGRAM) {
return;
}
LinearHistogram* histogram = static_cast<LinearHistogram*>(base_histogram);
if (descriptions_) {
for (int i = 0; UNSAFE_TODO(descriptions_[i].description); ++i) {
UNSAFE_TODO(histogram->bucket_description_[descriptions_[i].sample] =
descriptions_[i].description);
}
}
}
private:
raw_ptr<const DescriptionPair, AllowPtrArithmetic> descriptions_;
};
LinearHistogram::~LinearHistogram() = default;
HistogramBase* LinearHistogram::FactoryGet(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* LinearHistogram::FactoryTimeGet(std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* LinearHistogram::FactoryGet(const std::string& name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* LinearHistogram::FactoryTimeGet(const std::string& name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* LinearHistogram::FactoryGet(const char* name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetInternal(name, minimum, maximum, bucket_count, flags);
}
HistogramBase* LinearHistogram::FactoryTimeGet(const char* name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
return FactoryTimeGetInternal(name, minimum, maximum, bucket_count, flags);
}
std::unique_ptr<HistogramBase> LinearHistogram::PersistentCreate(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta) {
return WrapUnique(new LinearHistogram(durable_name, ranges, counts,
logged_counts, meta, logged_meta));
}
HistogramBase* LinearHistogram::FactoryGetWithRangeDescription(
std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags,
const DescriptionPair descriptions[]) {
if (maximum == 1 && bucket_count == 2) {
maximum = 2;
bucket_count = 3;
}
bool valid_arguments = Histogram::InspectConstructionArguments(
name, &minimum, &maximum, &bucket_count);
if (!valid_arguments) {
SCOPED_CRASH_KEY_STRING32("BadHistogramArgs", "name", std::string(name));
base::debug::DumpWithoutCrashing();
DLOG(ERROR) << "Histogram " << name << " dropped for invalid parameters.";
return DummyHistogram::GetInstance();
}
return Factory(name, minimum, maximum, bucket_count, flags, descriptions)
.Build();
}
HistogramType LinearHistogram::GetHistogramType() const {
return LINEAR_HISTOGRAM;
}
LinearHistogram::LinearHistogram(DurableStringView durable_name,
const BucketRanges* ranges)
: Histogram(durable_name, ranges) {}
LinearHistogram::LinearHistogram(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta)
: Histogram(durable_name,
ranges,
counts,
logged_counts,
meta,
logged_meta) {}
std::string LinearHistogram::GetAsciiBucketRange(size_t i) const {
int range = ranges(i);
BucketDescriptionMap::const_iterator it = bucket_description_.find(range);
if (it == bucket_description_.end()) {
return Histogram::GetAsciiBucketRange(i);
}
return it->second;
}
void LinearHistogram::InitializeBucketRanges(Sample32 minimum,
Sample32 maximum,
BucketRanges* ranges) {
double min = minimum;
double max = maximum;
size_t bucket_count = ranges->bucket_count();
for (size_t i = 1; i < bucket_count; ++i) {
double linear_range =
(min * (bucket_count - 1 - i) + max * (i - 1)) / (bucket_count - 2);
auto range = static_cast<Sample32>(linear_range + 0.5);
ranges->set_range(i, range);
}
ranges->set_range(ranges->bucket_count(), HistogramBase::kSampleType_MAX);
ranges->ResetChecksum();
}
HistogramBase* LinearHistogram::FactoryGetInternal(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t flags) {
return FactoryGetWithRangeDescription(name, minimum, maximum, bucket_count,
flags, nullptr);
}
HistogramBase* LinearHistogram::FactoryTimeGetInternal(std::string_view name,
TimeDelta minimum,
TimeDelta maximum,
size_t bucket_count,
int32_t flags) {
DCHECK_LT(minimum.InMilliseconds(), std::numeric_limits<Sample32>::max());
DCHECK_LT(maximum.InMilliseconds(), std::numeric_limits<Sample32>::max());
return FactoryGetInternal(name, static_cast<Sample32>(minimum.InMilliseconds()),
static_cast<Sample32>(maximum.InMilliseconds()),
bucket_count, flags);
}
HistogramBase* LinearHistogram::DeserializeInfoImpl(PickleIterator* iter) {
std::string histogram_name;
int flags;
int declared_min;
int declared_max;
size_t bucket_count;
uint32_t range_checksum;
if (!ReadHistogramArguments(iter, &histogram_name, &flags, &declared_min,
&declared_max, &bucket_count, &range_checksum)) {
return nullptr;
}
HistogramBase* histogram = LinearHistogram::FactoryGet(
histogram_name, declared_min, declared_max, bucket_count, flags);
if (!histogram) {
return nullptr;
}
if (!ValidateRangeChecksum(*histogram, range_checksum)) {
return nullptr;
}
return histogram;
}
ScaledLinearHistogram::ScaledLinearHistogram(std::string_view name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t scale,
int32_t flags)
: histogram_(LinearHistogram::FactoryGet(name,
minimum,
maximum,
bucket_count,
flags)),
scale_(scale) {
DCHECK(histogram_);
DCHECK_LT(1, scale);
DCHECK_EQ(1, minimum);
CHECK_EQ(static_cast<Sample32>(bucket_count), maximum - minimum + 2)
<< " ScaledLinearHistogram requires buckets of size 1";
if (histogram_->GetHistogramType() == DUMMY_HISTOGRAM) {
return;
}
DCHECK_EQ(histogram_->GetHistogramType(), LINEAR_HISTOGRAM);
LinearHistogram* histogram = static_cast<LinearHistogram*>(histogram_);
remainders_.resize(histogram->bucket_count(), 0);
}
ScaledLinearHistogram::ScaledLinearHistogram(const std::string& name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t scale,
int32_t flags)
: ScaledLinearHistogram(std::string_view(name),
minimum,
maximum,
bucket_count,
scale,
flags) {}
ScaledLinearHistogram::ScaledLinearHistogram(const char* name,
Sample32 minimum,
Sample32 maximum,
size_t bucket_count,
int32_t scale,
int32_t flags)
: ScaledLinearHistogram(std::string_view(name),
minimum,
maximum,
bucket_count,
scale,
flags) {}
ScaledLinearHistogram::~ScaledLinearHistogram() = default;
void ScaledLinearHistogram::AddScaledCount(Sample32 value, int64_t count) {
if (histogram_->GetHistogramType() == DUMMY_HISTOGRAM) {
return;
}
if (count == 0) {
return;
}
if (count < 0) {
DUMP_WILL_BE_NOTREACHED();
return;
}
DCHECK_EQ(histogram_->GetHistogramType(), LINEAR_HISTOGRAM);
LinearHistogram* histogram = static_cast<LinearHistogram*>(histogram_);
const auto max_value = static_cast<Sample32>(histogram->bucket_count() - 1);
value = std::clamp(value, 0, max_value);
int64_t scaled_count = count / scale_;
subtle::Atomic32 remainder = static_cast<int>(count - scaled_count * scale_);
if (remainder > 0) {
remainder = subtle::NoBarrier_AtomicIncrement(
&remainders_[static_cast<size_t>(value)], remainder);
if (remainder >= scale_ / 2) {
scaled_count += 1;
subtle::NoBarrier_AtomicIncrement(
&remainders_[static_cast<size_t>(value)], -scale_);
}
}
if (scaled_count > 0) {
int capped_scaled_count = scaled_count > std::numeric_limits<int>::max()
? std::numeric_limits<int>::max()
: static_cast<int>(scaled_count);
histogram->AddCount(value, capped_scaled_count);
}
}
class BooleanHistogram::Factory : public Histogram::Factory {
public:
Factory(std::string_view name, int32_t flags)
: Histogram::Factory(name, BOOLEAN_HISTOGRAM, 1, 2, 3, flags) {}
Factory(const Factory&) = delete;
Factory& operator=(const Factory&) = delete;
protected:
BucketRanges* CreateRanges() override {
BucketRanges* ranges = new BucketRanges(3 + 1);
LinearHistogram::InitializeBucketRanges(1, 2, ranges);
return ranges;
}
std::unique_ptr<HistogramBase> HeapAlloc(
const BucketRanges* ranges) override {
return WrapUnique(new BooleanHistogram(GetPermanentName(name_), ranges));
}
};
HistogramBase* BooleanHistogram::FactoryGet(std::string_view name,
int32_t flags) {
return FactoryGetInternal(name, flags);
}
HistogramBase* BooleanHistogram::FactoryGet(const std::string& name,
int32_t flags) {
return FactoryGetInternal(name, flags);
}
HistogramBase* BooleanHistogram::FactoryGet(const char* name, int32_t flags) {
return FactoryGetInternal(name, flags);
}
std::unique_ptr<HistogramBase> BooleanHistogram::PersistentCreate(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta) {
return WrapUnique(new BooleanHistogram(durable_name, ranges, counts,
logged_counts, meta, logged_meta));
}
HistogramType BooleanHistogram::GetHistogramType() const {
return BOOLEAN_HISTOGRAM;
}
HistogramBase* BooleanHistogram::FactoryGetInternal(std::string_view name,
int32_t flags) {
return Factory(name, flags).Build();
}
BooleanHistogram::BooleanHistogram(DurableStringView durable_name,
const BucketRanges* ranges)
: LinearHistogram(durable_name, ranges) {}
BooleanHistogram::BooleanHistogram(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta)
: LinearHistogram(durable_name,
ranges,
counts,
logged_counts,
meta,
logged_meta) {}
HistogramBase* BooleanHistogram::DeserializeInfoImpl(PickleIterator* iter) {
std::string histogram_name;
int flags;
int declared_min;
int declared_max;
size_t bucket_count;
uint32_t range_checksum;
if (!ReadHistogramArguments(iter, &histogram_name, &flags, &declared_min,
&declared_max, &bucket_count, &range_checksum)) {
return nullptr;
}
HistogramBase* histogram =
BooleanHistogram::FactoryGet(histogram_name, flags);
if (!histogram) {
return nullptr;
}
if (!ValidateRangeChecksum(*histogram, range_checksum)) {
return nullptr;
}
return histogram;
}
class CustomHistogram::Factory : public Histogram::Factory {
public:
Factory(std::string_view name,
const std::vector<Sample32>* custom_ranges,
int32_t flags)
: Histogram::Factory(name, CUSTOM_HISTOGRAM, 0, 0, 0, flags) {
custom_ranges_ = custom_ranges;
}
Factory(const Factory&) = delete;
Factory& operator=(const Factory&) = delete;
protected:
BucketRanges* CreateRanges() override {
std::vector<int> ranges = *custom_ranges_;
ranges.push_back(0);
ranges.push_back(HistogramBase::kSampleType_MAX);
std::ranges::sort(ranges);
auto removed = std::ranges::unique(ranges);
ranges.erase(removed.begin(), removed.end());
BucketRanges* bucket_ranges = new BucketRanges(ranges.size());
for (size_t i = 0; i < ranges.size(); i++) {
bucket_ranges->set_range(i, ranges[i]);
}
bucket_ranges->ResetChecksum();
return bucket_ranges;
}
std::unique_ptr<HistogramBase> HeapAlloc(
const BucketRanges* ranges) override {
return WrapUnique(new CustomHistogram(GetPermanentName(name_), ranges));
}
private:
raw_ptr<const std::vector<Sample32>> custom_ranges_;
};
HistogramBase* CustomHistogram::FactoryGet(
std::string_view name,
const std::vector<Sample32>& custom_ranges,
int32_t flags) {
return FactoryGetInternal(name, custom_ranges, flags);
}
HistogramBase* CustomHistogram::FactoryGet(
const std::string& name,
const std::vector<Sample32>& custom_ranges,
int32_t flags) {
return FactoryGetInternal(name, custom_ranges, flags);
}
HistogramBase* CustomHistogram::FactoryGet(
const char* name,
const std::vector<Sample32>& custom_ranges,
int32_t flags) {
return FactoryGetInternal(name, custom_ranges, flags);
}
std::unique_ptr<HistogramBase> CustomHistogram::PersistentCreate(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta) {
return WrapUnique(new CustomHistogram(durable_name, ranges, counts,
logged_counts, meta, logged_meta));
}
HistogramType CustomHistogram::GetHistogramType() const {
return CUSTOM_HISTOGRAM;
}
std::vector<Sample32> CustomHistogram::ArrayToCustomEnumRanges(
base::span<const Sample32> values) {
std::vector<Sample32> all_values;
for (Sample32 value : values) {
all_values.push_back(value);
all_values.push_back(value + 1);
}
return all_values;
}
CustomHistogram::CustomHistogram(DurableStringView durable_name,
const BucketRanges* ranges)
: Histogram(durable_name, ranges) {}
CustomHistogram::CustomHistogram(
DurableStringView durable_name,
const BucketRanges* ranges,
const DelayedPersistentAllocation& counts,
const DelayedPersistentAllocation& logged_counts,
HistogramSamples::Metadata* meta,
HistogramSamples::Metadata* logged_meta)
: Histogram(durable_name,
ranges,
counts,
logged_counts,
meta,
logged_meta) {}
void CustomHistogram::SerializeInfoImpl(Pickle* pickle) const {
Histogram::SerializeInfoImpl(pickle);
for (size_t i = 1; i < bucket_ranges()->bucket_count(); ++i) {
pickle->WriteInt(bucket_ranges()->range(i));
}
}
HistogramBase* CustomHistogram::DeserializeInfoImpl(PickleIterator* iter) {
std::string histogram_name;
int flags;
int declared_min;
int declared_max;
size_t bucket_count;
uint32_t range_checksum;
if (!ReadHistogramArguments(iter, &histogram_name, &flags, &declared_min,
&declared_max, &bucket_count, &range_checksum)) {
return nullptr;
}
std::vector<Sample32> sample_ranges(bucket_count - 1);
for (Sample32& sample : sample_ranges) {
if (!iter->ReadInt(&sample)) {
return nullptr;
}
}
HistogramBase* histogram =
CustomHistogram::FactoryGet(histogram_name, sample_ranges, flags);
if (!histogram) {
return nullptr;
}
if (!ValidateRangeChecksum(*histogram, range_checksum)) {
return nullptr;
}
return histogram;
}
HistogramBase* CustomHistogram::FactoryGetInternal(
std::string_view name,
const std::vector<Sample32>& custom_ranges,
int32_t flags) {
CHECK(ValidateCustomRanges(custom_ranges));
return Factory(name, &custom_ranges, flags).Build();
}
bool CustomHistogram::ValidateCustomRanges(
const std::vector<Sample32>& custom_ranges) {
bool has_valid_range = false;
for (Sample32 sample : custom_ranges) {
if (sample < 0 || sample > HistogramBase::kSampleType_MAX - 1) {
return false;
}
if (sample != 0) {
has_valid_range = true;
}
}
return has_valid_range;
}
namespace internal {
namespace {
constinit std::atomic<const std::atomic<TimeTicks>*> g_last_foreground_time_ref;
}
void SetSharedLastForegroundTimeForMetrics(
const std::atomic<TimeTicks>* last_foreground_time_ref) {
g_last_foreground_time_ref.store(last_foreground_time_ref,
std::memory_order_release);
}
const std::atomic<TimeTicks>*
GetSharedLastForegroundTimeForMetricsForTesting() {
return g_last_foreground_time_ref.load(std::memory_order_acquire);
}
bool OverlapsBestEffortRange(TimeTicks sample_time, TimeDelta sample_interval) {
auto last_foreground_time_ref =
g_last_foreground_time_ref.load(std::memory_order_acquire);
if (!last_foreground_time_ref) {
return false;
}
auto last_foreground_time =
last_foreground_time_ref->load(std::memory_order_relaxed);
return last_foreground_time.is_null() ||
(sample_time - sample_interval) < last_foreground_time;
}
}
}