OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/statistics_recorder.h" | 5 #include "base/metrics/statistics_recorder.h" |
6 | 6 |
7 #include "base/at_exit.h" | 7 #include "base/at_exit.h" |
8 #include "base/debug/leak_annotations.h" | 8 #include "base/debug/leak_annotations.h" |
9 #include "base/json/string_escape.h" | 9 #include "base/json/string_escape.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
12 #include "base/metrics/histogram.h" | 12 #include "base/metrics/histogram.h" |
13 #include "base/strings/stringprintf.h" | 13 #include "base/strings/stringprintf.h" |
14 #include "base/synchronization/lock.h" | 14 #include "base/synchronization/lock.h" |
15 #include "base/values.h" | 15 #include "base/values.h" |
16 | 16 |
17 using std::list; | |
18 using std::string; | |
19 | |
20 namespace { | 17 namespace { |
21 // Initialize histogram statistics gathering system. | 18 // Initialize histogram statistics gathering system. |
22 base::LazyInstance<base::StatisticsRecorder>::Leaky g_statistics_recorder_ = | 19 base::LazyInstance<base::StatisticsRecorder>::Leaky g_statistics_recorder_ = |
23 LAZY_INSTANCE_INITIALIZER; | 20 LAZY_INSTANCE_INITIALIZER; |
24 } // namespace | 21 } // namespace |
25 | 22 |
26 namespace base { | 23 namespace base { |
27 | 24 |
28 // static | 25 // static |
29 void StatisticsRecorder::Initialize() { | 26 void StatisticsRecorder::Initialize() { |
(...skipping 22 matching lines...) Expand all Loading... |
52 return histogram; | 49 return histogram; |
53 } | 50 } |
54 | 51 |
55 HistogramBase* histogram_to_delete = NULL; | 52 HistogramBase* histogram_to_delete = NULL; |
56 HistogramBase* histogram_to_return = NULL; | 53 HistogramBase* histogram_to_return = NULL; |
57 { | 54 { |
58 base::AutoLock auto_lock(*lock_); | 55 base::AutoLock auto_lock(*lock_); |
59 if (histograms_ == NULL) { | 56 if (histograms_ == NULL) { |
60 histogram_to_return = histogram; | 57 histogram_to_return = histogram; |
61 } else { | 58 } else { |
62 const string& name = histogram->histogram_name(); | 59 const std::string& name = histogram->histogram_name(); |
63 HistogramMap::iterator it = histograms_->find(name); | 60 HistogramMap::iterator it = histograms_->find(name); |
64 if (histograms_->end() == it) { | 61 if (histograms_->end() == it) { |
65 (*histograms_)[name] = histogram; | 62 (*histograms_)[name] = histogram; |
66 ANNOTATE_LEAKING_OBJECT_PTR(histogram); // see crbug.com/79322 | 63 ANNOTATE_LEAKING_OBJECT_PTR(histogram); // see crbug.com/79322 |
67 histogram_to_return = histogram; | 64 histogram_to_return = histogram; |
68 } else if (histogram == it->second) { | 65 } else if (histogram == it->second) { |
69 // The histogram was registered before. | 66 // The histogram was registered before. |
70 histogram_to_return = histogram; | 67 histogram_to_return = histogram; |
71 } else { | 68 } else { |
72 // We already have one histogram with this name. | 69 // We already have one histogram with this name. |
(...skipping 16 matching lines...) Expand all Loading... |
89 ANNOTATE_LEAKING_OBJECT_PTR(ranges); | 86 ANNOTATE_LEAKING_OBJECT_PTR(ranges); |
90 return ranges; | 87 return ranges; |
91 } | 88 } |
92 | 89 |
93 base::AutoLock auto_lock(*lock_); | 90 base::AutoLock auto_lock(*lock_); |
94 if (ranges_ == NULL) { | 91 if (ranges_ == NULL) { |
95 ANNOTATE_LEAKING_OBJECT_PTR(ranges); | 92 ANNOTATE_LEAKING_OBJECT_PTR(ranges); |
96 return ranges; | 93 return ranges; |
97 } | 94 } |
98 | 95 |
99 list<const BucketRanges*>* checksum_matching_list; | 96 std::list<const BucketRanges*>* checksum_matching_list; |
100 RangesMap::iterator ranges_it = ranges_->find(ranges->checksum()); | 97 RangesMap::iterator ranges_it = ranges_->find(ranges->checksum()); |
101 if (ranges_->end() == ranges_it) { | 98 if (ranges_->end() == ranges_it) { |
102 // Add a new matching list to map. | 99 // Add a new matching list to map. |
103 checksum_matching_list = new list<const BucketRanges*>(); | 100 checksum_matching_list = new std::list<const BucketRanges*>(); |
104 ANNOTATE_LEAKING_OBJECT_PTR(checksum_matching_list); | 101 ANNOTATE_LEAKING_OBJECT_PTR(checksum_matching_list); |
105 (*ranges_)[ranges->checksum()] = checksum_matching_list; | 102 (*ranges_)[ranges->checksum()] = checksum_matching_list; |
106 } else { | 103 } else { |
107 checksum_matching_list = ranges_it->second; | 104 checksum_matching_list = ranges_it->second; |
108 } | 105 } |
109 | 106 |
110 list<const BucketRanges*>::iterator checksum_matching_list_it; | 107 for (const BucketRanges* existing_ranges : *checksum_matching_list) { |
111 for (checksum_matching_list_it = checksum_matching_list->begin(); | |
112 checksum_matching_list_it != checksum_matching_list->end(); | |
113 ++checksum_matching_list_it) { | |
114 const BucketRanges* existing_ranges = *checksum_matching_list_it; | |
115 if (existing_ranges->Equals(ranges)) { | 108 if (existing_ranges->Equals(ranges)) { |
116 if (existing_ranges == ranges) { | 109 if (existing_ranges == ranges) { |
117 return ranges; | 110 return ranges; |
118 } else { | 111 } else { |
119 ranges_deleter.reset(ranges); | 112 ranges_deleter.reset(ranges); |
120 return existing_ranges; | 113 return existing_ranges; |
121 } | 114 } |
122 } | 115 } |
123 } | 116 } |
124 // We haven't found a BucketRanges which has the same ranges. Register the | 117 // We haven't found a BucketRanges which has the same ranges. Register the |
125 // new BucketRanges. | 118 // new BucketRanges. |
126 checksum_matching_list->push_front(ranges); | 119 checksum_matching_list->push_front(ranges); |
127 return ranges; | 120 return ranges; |
128 } | 121 } |
129 | 122 |
130 // static | 123 // static |
131 void StatisticsRecorder::WriteHTMLGraph(const std::string& query, | 124 void StatisticsRecorder::WriteHTMLGraph(const std::string& query, |
132 std::string* output) { | 125 std::string* output) { |
133 if (!IsActive()) | 126 if (!IsActive()) |
134 return; | 127 return; |
135 | 128 |
136 Histograms snapshot; | 129 Histograms snapshot; |
137 GetSnapshot(query, &snapshot); | 130 GetSnapshot(query, &snapshot); |
138 for (Histograms::iterator it = snapshot.begin(); | 131 for (const HistogramBase* histogram : snapshot) { |
139 it != snapshot.end(); | 132 histogram->WriteHTMLGraph(output); |
140 ++it) { | |
141 (*it)->WriteHTMLGraph(output); | |
142 output->append("<br><hr><br>"); | 133 output->append("<br><hr><br>"); |
143 } | 134 } |
144 } | 135 } |
145 | 136 |
146 // static | 137 // static |
147 void StatisticsRecorder::WriteGraph(const std::string& query, | 138 void StatisticsRecorder::WriteGraph(const std::string& query, |
148 std::string* output) { | 139 std::string* output) { |
149 if (!IsActive()) | 140 if (!IsActive()) |
150 return; | 141 return; |
151 if (query.length()) | 142 if (query.length()) |
152 StringAppendF(output, "Collections of histograms for %s\n", query.c_str()); | 143 StringAppendF(output, "Collections of histograms for %s\n", query.c_str()); |
153 else | 144 else |
154 output->append("Collections of all histograms\n"); | 145 output->append("Collections of all histograms\n"); |
155 | 146 |
156 Histograms snapshot; | 147 Histograms snapshot; |
157 GetSnapshot(query, &snapshot); | 148 GetSnapshot(query, &snapshot); |
158 for (Histograms::iterator it = snapshot.begin(); | 149 for (const HistogramBase* histogram : snapshot) { |
159 it != snapshot.end(); | 150 histogram->WriteAscii(output); |
160 ++it) { | |
161 (*it)->WriteAscii(output); | |
162 output->append("\n"); | 151 output->append("\n"); |
163 } | 152 } |
164 } | 153 } |
165 | 154 |
166 // static | 155 // static |
167 std::string StatisticsRecorder::ToJSON(const std::string& query) { | 156 std::string StatisticsRecorder::ToJSON(const std::string& query) { |
168 if (!IsActive()) | 157 if (!IsActive()) |
169 return std::string(); | 158 return std::string(); |
170 | 159 |
171 std::string output("{"); | 160 std::string output("{"); |
172 if (!query.empty()) { | 161 if (!query.empty()) { |
173 output += "\"query\":"; | 162 output += "\"query\":"; |
174 EscapeJSONString(query, true, &output); | 163 EscapeJSONString(query, true, &output); |
175 output += ","; | 164 output += ","; |
176 } | 165 } |
177 | 166 |
178 Histograms snapshot; | 167 Histograms snapshot; |
179 GetSnapshot(query, &snapshot); | 168 GetSnapshot(query, &snapshot); |
180 output += "\"histograms\":["; | 169 output += "\"histograms\":["; |
181 bool first_histogram = true; | 170 bool first_histogram = true; |
182 for (Histograms::const_iterator it = snapshot.begin(); it != snapshot.end(); | 171 for (const HistogramBase* histogram : snapshot) { |
183 ++it) { | |
184 if (first_histogram) | 172 if (first_histogram) |
185 first_histogram = false; | 173 first_histogram = false; |
186 else | 174 else |
187 output += ","; | 175 output += ","; |
188 std::string json; | 176 std::string json; |
189 (*it)->WriteJSON(&json); | 177 histogram->WriteJSON(&json); |
190 output += json; | 178 output += json; |
191 } | 179 } |
192 output += "]}"; | 180 output += "]}"; |
193 return output; | 181 return output; |
194 } | 182 } |
195 | 183 |
196 // static | 184 // static |
197 void StatisticsRecorder::GetHistograms(Histograms* output) { | 185 void StatisticsRecorder::GetHistograms(Histograms* output) { |
198 if (lock_ == NULL) | 186 if (lock_ == NULL) |
199 return; | 187 return; |
200 base::AutoLock auto_lock(*lock_); | 188 base::AutoLock auto_lock(*lock_); |
201 if (histograms_ == NULL) | 189 if (histograms_ == NULL) |
202 return; | 190 return; |
203 | 191 |
204 for (HistogramMap::iterator it = histograms_->begin(); | 192 for (const auto& entry : *histograms_) { |
205 histograms_->end() != it; | 193 DCHECK_EQ(entry.first, entry.second->histogram_name()); |
206 ++it) { | 194 output->push_back(entry.second); |
207 DCHECK_EQ(it->first, it->second->histogram_name()); | |
208 output->push_back(it->second); | |
209 } | 195 } |
210 } | 196 } |
211 | 197 |
212 // static | 198 // static |
213 void StatisticsRecorder::GetBucketRanges( | 199 void StatisticsRecorder::GetBucketRanges( |
214 std::vector<const BucketRanges*>* output) { | 200 std::vector<const BucketRanges*>* output) { |
215 if (lock_ == NULL) | 201 if (lock_ == NULL) |
216 return; | 202 return; |
217 base::AutoLock auto_lock(*lock_); | 203 base::AutoLock auto_lock(*lock_); |
218 if (ranges_ == NULL) | 204 if (ranges_ == NULL) |
219 return; | 205 return; |
220 | 206 |
221 for (RangesMap::iterator it = ranges_->begin(); | 207 for (const auto& entry : *ranges_) { |
222 ranges_->end() != it; | 208 for (const auto& range_entry : *entry.second) { |
223 ++it) { | 209 output->push_back(range_entry); |
224 list<const BucketRanges*>* ranges_list = it->second; | |
225 list<const BucketRanges*>::iterator ranges_list_it; | |
226 for (ranges_list_it = ranges_list->begin(); | |
227 ranges_list_it != ranges_list->end(); | |
228 ++ranges_list_it) { | |
229 output->push_back(*ranges_list_it); | |
230 } | 210 } |
231 } | 211 } |
232 } | 212 } |
233 | 213 |
234 // static | 214 // static |
235 HistogramBase* StatisticsRecorder::FindHistogram(const std::string& name) { | 215 HistogramBase* StatisticsRecorder::FindHistogram(const std::string& name) { |
236 if (lock_ == NULL) | 216 if (lock_ == NULL) |
237 return NULL; | 217 return NULL; |
238 base::AutoLock auto_lock(*lock_); | 218 base::AutoLock auto_lock(*lock_); |
239 if (histograms_ == NULL) | 219 if (histograms_ == NULL) |
240 return NULL; | 220 return NULL; |
241 | 221 |
242 HistogramMap::iterator it = histograms_->find(name); | 222 HistogramMap::iterator it = histograms_->find(name); |
243 if (histograms_->end() == it) | 223 if (histograms_->end() == it) |
244 return NULL; | 224 return NULL; |
245 return it->second; | 225 return it->second; |
246 } | 226 } |
247 | 227 |
248 // private static | 228 // private static |
249 void StatisticsRecorder::GetSnapshot(const std::string& query, | 229 void StatisticsRecorder::GetSnapshot(const std::string& query, |
250 Histograms* snapshot) { | 230 Histograms* snapshot) { |
251 if (lock_ == NULL) | 231 if (lock_ == NULL) |
252 return; | 232 return; |
253 base::AutoLock auto_lock(*lock_); | 233 base::AutoLock auto_lock(*lock_); |
254 if (histograms_ == NULL) | 234 if (histograms_ == NULL) |
255 return; | 235 return; |
256 | 236 |
257 for (HistogramMap::iterator it = histograms_->begin(); | 237 for (const auto& entry : *histograms_) { |
258 histograms_->end() != it; | 238 if (entry.first.find(query) != std::string::npos) |
259 ++it) { | 239 snapshot->push_back(entry.second); |
260 if (it->first.find(query) != std::string::npos) | |
261 snapshot->push_back(it->second); | |
262 } | 240 } |
263 } | 241 } |
264 | 242 |
265 // This singleton instance should be started during the single threaded portion | 243 // This singleton instance should be started during the single threaded portion |
266 // of main(), and hence it is not thread safe. It initializes globals to | 244 // of main(), and hence it is not thread safe. It initializes globals to |
267 // provide support for all future calls. | 245 // provide support for all future calls. |
268 StatisticsRecorder::StatisticsRecorder() { | 246 StatisticsRecorder::StatisticsRecorder() { |
269 DCHECK(!histograms_); | 247 DCHECK(!histograms_); |
270 if (lock_ == NULL) { | 248 if (lock_ == NULL) { |
271 // This will leak on purpose. It's the only way to make sure we won't race | 249 // This will leak on purpose. It's the only way to make sure we won't race |
272 // against the static uninitialization of the module while one of our | 250 // against the static uninitialization of the module while one of our |
273 // static methods relying on the lock get called at an inappropriate time | 251 // static methods relying on the lock get called at an inappropriate time |
274 // during the termination phase. Since it's a static data member, we will | 252 // during the termination phase. Since it's a static data member, we will |
275 // leak one per process, which would be similar to the instance allocated | 253 // leak one per process, which would be similar to the instance allocated |
276 // during static initialization and released only on process termination. | 254 // during static initialization and released only on process termination. |
277 lock_ = new base::Lock; | 255 lock_ = new base::Lock; |
278 } | 256 } |
279 base::AutoLock auto_lock(*lock_); | 257 base::AutoLock auto_lock(*lock_); |
280 histograms_ = new HistogramMap; | 258 histograms_ = new HistogramMap; |
281 ranges_ = new RangesMap; | 259 ranges_ = new RangesMap; |
282 | 260 |
283 if (VLOG_IS_ON(1)) | 261 if (VLOG_IS_ON(1)) |
284 AtExitManager::RegisterCallback(&DumpHistogramsToVlog, this); | 262 AtExitManager::RegisterCallback(&DumpHistogramsToVlog, this); |
285 } | 263 } |
286 | 264 |
287 // static | 265 // static |
288 void StatisticsRecorder::DumpHistogramsToVlog(void* instance) { | 266 void StatisticsRecorder::DumpHistogramsToVlog(void* instance) { |
289 string output; | 267 std::string output; |
290 StatisticsRecorder::WriteGraph(std::string(), &output); | 268 StatisticsRecorder::WriteGraph(std::string(), &output); |
291 VLOG(1) << output; | 269 VLOG(1) << output; |
292 } | 270 } |
293 | 271 |
294 StatisticsRecorder::~StatisticsRecorder() { | 272 StatisticsRecorder::~StatisticsRecorder() { |
295 DCHECK(histograms_ && ranges_ && lock_); | 273 DCHECK(histograms_ && ranges_ && lock_); |
296 | 274 |
297 // Clean up. | 275 // Clean up. |
298 scoped_ptr<HistogramMap> histograms_deleter; | 276 scoped_ptr<HistogramMap> histograms_deleter; |
299 scoped_ptr<RangesMap> ranges_deleter; | 277 scoped_ptr<RangesMap> ranges_deleter; |
(...skipping 11 matching lines...) Expand all Loading... |
311 | 289 |
312 | 290 |
313 // static | 291 // static |
314 StatisticsRecorder::HistogramMap* StatisticsRecorder::histograms_ = NULL; | 292 StatisticsRecorder::HistogramMap* StatisticsRecorder::histograms_ = NULL; |
315 // static | 293 // static |
316 StatisticsRecorder::RangesMap* StatisticsRecorder::ranges_ = NULL; | 294 StatisticsRecorder::RangesMap* StatisticsRecorder::ranges_ = NULL; |
317 // static | 295 // static |
318 base::Lock* StatisticsRecorder::lock_ = NULL; | 296 base::Lock* StatisticsRecorder::lock_ = NULL; |
319 | 297 |
320 } // namespace base | 298 } // namespace base |
OLD | NEW |