Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(375)

Side by Side Diff: base/metrics/persistent_histogram_allocator.cc

Issue 1891913002: Support saving browser metrics to disk and reading them during next run. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: addressed review comments by Ilya Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "base/metrics/persistent_histogram_allocator.h" 5 #include "base/metrics/persistent_histogram_allocator.h"
6 6
7 #include <memory> 7 #include <memory>
8 8
9 #include "base/files/important_file_writer.h"
9 #include "base/lazy_instance.h" 10 #include "base/lazy_instance.h"
10 #include "base/logging.h" 11 #include "base/logging.h"
11 #include "base/memory/ptr_util.h" 12 #include "base/memory/ptr_util.h"
12 #include "base/metrics/histogram.h" 13 #include "base/metrics/histogram.h"
13 #include "base/metrics/histogram_base.h" 14 #include "base/metrics/histogram_base.h"
14 #include "base/metrics/histogram_samples.h" 15 #include "base/metrics/histogram_samples.h"
15 #include "base/metrics/persistent_sample_map.h" 16 #include "base/metrics/persistent_sample_map.h"
16 #include "base/metrics/sparse_histogram.h" 17 #include "base/metrics/sparse_histogram.h"
17 #include "base/metrics/statistics_recorder.h" 18 #include "base/metrics/statistics_recorder.h"
18 #include "base/synchronization/lock.h" 19 #include "base/synchronization/lock.h"
(...skipping 20 matching lines...) Expand all
39 kTypeIdCountsArray = 0x53215530 + 1, // SHA1(CountsArray) v1 40 kTypeIdCountsArray = 0x53215530 + 1, // SHA1(CountsArray) v1
40 }; 41 };
41 42
42 // The current globally-active persistent allocator for all new histograms. 43 // The current globally-active persistent allocator for all new histograms.
43 // The object held here will obviously not be destructed at process exit 44 // The object held here will obviously not be destructed at process exit
44 // but that's best since PersistentMemoryAllocator objects (that underlie 45 // but that's best since PersistentMemoryAllocator objects (that underlie
45 // GlobalHistogramAllocator objects) are explicitly forbidden from doing 46 // GlobalHistogramAllocator objects) are explicitly forbidden from doing
46 // anything essential at exit anyway due to the fact that they depend on data 47 // anything essential at exit anyway due to the fact that they depend on data
47 // managed elsewhere and which could be destructed first. 48 // managed elsewhere and which could be destructed first.
48 GlobalHistogramAllocator* g_allocator; 49 GlobalHistogramAllocator* g_allocator;
50 bool g_allocator_enabled;
Ilya Sherman 2016/04/27 20:31:33 Sorry, I'm going to go back to my previous questio
bcwhite 2016/05/02 14:46:47 It would have to be tested by CreateHistogram() wh
Ilya Sherman 2016/05/05 22:22:52 g_allocator_enabled is only accessed internally to
bcwhite 2016/05/06 16:59:27 That would work just fine. The difference would b
49 51
50 // Take an array of range boundaries and create a proper BucketRanges object 52 // Take an array of range boundaries and create a proper BucketRanges object
51 // which is returned to the caller. A return of nullptr indicates that the 53 // which is returned to the caller. A return of nullptr indicates that the
52 // passed boundaries are invalid. 54 // passed boundaries are invalid.
53 std::unique_ptr<BucketRanges> CreateRangesFromData( 55 std::unique_ptr<BucketRanges> CreateRangesFromData(
54 HistogramBase::Sample* ranges_data, 56 HistogramBase::Sample* ranges_data,
55 uint32_t ranges_checksum, 57 uint32_t ranges_checksum,
56 size_t count) { 58 size_t count) {
57 // To avoid racy destruction at shutdown, the following may be leaked. 59 // To avoid racy destruction at shutdown, the following may be leaked.
58 std::unique_ptr<BucketRanges> ranges(new BucketRanges(count)); 60 std::unique_ptr<BucketRanges> ranges(new BucketRanges(count));
(...skipping 585 matching lines...) Expand 10 before | Expand all | Expand 10 after
644 NOTREACHED(); 646 NOTREACHED();
645 return; 647 return;
646 } 648 }
647 649
648 Set(WrapUnique(new GlobalHistogramAllocator( 650 Set(WrapUnique(new GlobalHistogramAllocator(
649 WrapUnique(new SharedPersistentMemoryAllocator( 651 WrapUnique(new SharedPersistentMemoryAllocator(
650 std::move(shm), 0, StringPiece(), /*readonly=*/false))))); 652 std::move(shm), 0, StringPiece(), /*readonly=*/false)))));
651 } 653 }
652 654
653 // static 655 // static
656 void GlobalHistogramAllocator::Enable() {
657 DCHECK(g_allocator);
658 g_allocator_enabled = true;
659 }
660
661 // static
662 void GlobalHistogramAllocator::Disable() {
663 DCHECK(g_allocator);
664 g_allocator_enabled = false;
665 }
666
667 // static
654 void GlobalHistogramAllocator::Set( 668 void GlobalHistogramAllocator::Set(
655 std::unique_ptr<GlobalHistogramAllocator> allocator) { 669 std::unique_ptr<GlobalHistogramAllocator> allocator) {
656 // Releasing or changing an allocator is extremely dangerous because it 670 // Releasing or changing an allocator is extremely dangerous because it
657 // likely has histograms stored within it. If the backing memory is also 671 // likely has histograms stored within it. If the backing memory is also
658 // also released, future accesses to those histograms will seg-fault. 672 // also released, future accesses to those histograms will seg-fault.
659 CHECK(!g_allocator); 673 CHECK(!g_allocator);
660 g_allocator = allocator.release(); 674 g_allocator = allocator.release();
675 g_allocator_enabled = true;
661 size_t existing = StatisticsRecorder::GetHistogramCount(); 676 size_t existing = StatisticsRecorder::GetHistogramCount();
662 677
663 DLOG_IF(WARNING, existing) 678 DLOG_IF(WARNING, existing)
664 << existing << " histograms were created before persistence was enabled."; 679 << existing << " histograms were created before persistence was enabled.";
665 } 680 }
666 681
667 // static 682 // static
668 GlobalHistogramAllocator* GlobalHistogramAllocator::Get() { 683 GlobalHistogramAllocator* GlobalHistogramAllocator::Get() {
684 return g_allocator_enabled ? g_allocator : nullptr;
685 }
686
687 // static
688 GlobalHistogramAllocator* GlobalHistogramAllocator::GetEvenIfDisabled() {
669 return g_allocator; 689 return g_allocator;
670 } 690 }
671 691
672 // static 692 // static
673 std::unique_ptr<GlobalHistogramAllocator> 693 std::unique_ptr<GlobalHistogramAllocator>
674 GlobalHistogramAllocator::ReleaseForTesting() { 694 GlobalHistogramAllocator::ReleaseForTesting() {
675 GlobalHistogramAllocator* histogram_allocator = g_allocator; 695 GlobalHistogramAllocator* histogram_allocator = g_allocator;
676 if (!histogram_allocator) 696 if (!histogram_allocator)
677 return nullptr; 697 return nullptr;
678 PersistentMemoryAllocator* memory_allocator = 698 PersistentMemoryAllocator* memory_allocator =
(...skipping 18 matching lines...) Expand all
697 // the method GetCreateHistogramResultHistogram() *before* setting 717 // the method GetCreateHistogramResultHistogram() *before* setting
698 // the (temporary) memory allocator via SetGlobalAllocator() so that 718 // the (temporary) memory allocator via SetGlobalAllocator() so that
699 // histogram is instead allocated from the process heap. 719 // histogram is instead allocated from the process heap.
700 DCHECK_NE(kResultHistogram, histogram_data->name); 720 DCHECK_NE(kResultHistogram, histogram_data->name);
701 } 721 }
702 722
703 g_allocator = nullptr; 723 g_allocator = nullptr;
704 return WrapUnique(histogram_allocator); 724 return WrapUnique(histogram_allocator);
705 }; 725 };
706 726
727 void GlobalHistogramAllocator::SetPersistentLocation(const FilePath& location) {
728 persistent_location_ = location;
729 }
730
731 bool GlobalHistogramAllocator::WriteToPersistentLocation() {
732 #if defined(OS_NACL)
733 // NACL doesn't support file operations, including ImportantFileWriter.
734 NOTREACHED();
735 return false;
736 #else
Ilya Sherman 2016/04/27 20:31:33 Please DCHECK(g_allocator_enabled) in this code.
bcwhite 2016/05/02 14:46:47 Done.
737 // Stop if no destination is set, perhaps because it has not been enabled.
738 if (persistent_location_.empty()) {
739 NOTREACHED() << "Could not write \"" << Name() << "\" persistent histograms"
740 << " to file because no location was set.";
741 return false;
742 }
743
744 StringPiece contents(static_cast<const char*>(data()), used());
745 if (!ImportantFileWriter::WriteFileAtomically(persistent_location_,
746 contents)) {
747 LOG(ERROR) << "Could not write \"" << Name() << "\" persistent histograms"
748 << " to file: " << persistent_location_.value();
749 return false;
750 }
751
752 return true;
753 #endif
754 }
755
707 GlobalHistogramAllocator::GlobalHistogramAllocator( 756 GlobalHistogramAllocator::GlobalHistogramAllocator(
708 std::unique_ptr<PersistentMemoryAllocator> memory) 757 std::unique_ptr<PersistentMemoryAllocator> memory)
709 : PersistentHistogramAllocator(std::move(memory)), 758 : PersistentHistogramAllocator(std::move(memory)),
710 import_iterator_(this) {} 759 import_iterator_(this) {}
711 760
712 void GlobalHistogramAllocator::ImportHistogramsToStatisticsRecorder() { 761 void GlobalHistogramAllocator::ImportHistogramsToStatisticsRecorder() {
713 // Skip the import if it's the histogram that was last created. Should a 762 // Skip the import if it's the histogram that was last created. Should a
714 // race condition cause the "last created" to be overwritten before it 763 // race condition cause the "last created" to be overwritten before it
715 // is recognized here then the histogram will be created and be ignored 764 // is recognized here then the histogram will be created and be ignored
716 // when it is detected as a duplicate by the statistics-recorder. This 765 // when it is detected as a duplicate by the statistics-recorder. This
717 // simple check reduces the time of creating persistent histograms by 766 // simple check reduces the time of creating persistent histograms by
718 // about 40%. 767 // about 40%.
719 Reference record_to_ignore = last_created(); 768 Reference record_to_ignore = last_created();
720 769
721 // There is no lock on this because the iterator is lock-free while still 770 // There is no lock on this because the iterator is lock-free while still
722 // guaranteed to only return each entry only once. The StatisticsRecorder 771 // guaranteed to only return each entry only once. The StatisticsRecorder
723 // has its own lock so the Register operation is safe. 772 // has its own lock so the Register operation is safe.
724 while (true) { 773 while (true) {
725 std::unique_ptr<HistogramBase> histogram = 774 std::unique_ptr<HistogramBase> histogram =
726 import_iterator_.GetNextWithIgnore(record_to_ignore); 775 import_iterator_.GetNextWithIgnore(record_to_ignore);
727 if (!histogram) 776 if (!histogram)
728 break; 777 break;
729 StatisticsRecorder::RegisterOrDeleteDuplicate(histogram.release()); 778 StatisticsRecorder::RegisterOrDeleteDuplicate(histogram.release());
730 } 779 }
731 } 780 }
732 781
733 } // namespace base 782 } // namespace base
OLDNEW
« no previous file with comments | « base/metrics/persistent_histogram_allocator.h ('k') | chrome/browser/chrome_browser_field_trials.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698