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

Side by Side Diff: chrome/browser/metrics/histogram_synchronizer.cc

Issue 8603013: base::Bind() conversion for MetricsService. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: . Created 9 years, 1 month 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 | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 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 "chrome/browser/metrics/histogram_synchronizer.h" 5 #include "chrome/browser/metrics/histogram_synchronizer.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/logging.h" 8 #include "base/logging.h"
9 #include "base/metrics/histogram.h" 9 #include "base/metrics/histogram.h"
10 #include "base/threading/thread.h" 10 #include "base/threading/thread.h"
(...skipping 10 matching lines...) Expand all
21 // Negative numbers are never used as sequence numbers. We explicitly pick a 21 // Negative numbers are never used as sequence numbers. We explicitly pick a
22 // negative number that is "so negative" that even when we add one (as is done 22 // negative number that is "so negative" that even when we add one (as is done
23 // when we generated the next sequence number) that it will still be negative. 23 // when we generated the next sequence number) that it will still be negative.
24 // We have code that handles wrapping around on an overflow into negative 24 // We have code that handles wrapping around on an overflow into negative
25 // territory. 25 // territory.
26 static const int kNeverUsableSequenceNumber = -2; 26 static const int kNeverUsableSequenceNumber = -2;
27 27
28 HistogramSynchronizer::HistogramSynchronizer() 28 HistogramSynchronizer::HistogramSynchronizer()
29 : lock_(), 29 : lock_(),
30 received_all_renderer_histograms_(&lock_), 30 received_all_renderer_histograms_(&lock_),
31 callback_task_(NULL),
32 callback_thread_(NULL), 31 callback_thread_(NULL),
33 last_used_sequence_number_(kNeverUsableSequenceNumber), 32 last_used_sequence_number_(kNeverUsableSequenceNumber),
34 async_sequence_number_(kNeverUsableSequenceNumber), 33 async_sequence_number_(kNeverUsableSequenceNumber),
35 async_renderers_pending_(0), 34 async_renderers_pending_(0),
36 synchronous_sequence_number_(kNeverUsableSequenceNumber), 35 synchronous_sequence_number_(kNeverUsableSequenceNumber),
37 synchronous_renderers_pending_(0) { 36 synchronous_renderers_pending_(0) {
38 DCHECK(histogram_synchronizer_ == NULL); 37 DCHECK(histogram_synchronizer_ == NULL);
39 histogram_synchronizer_ = this; 38 histogram_synchronizer_ = this;
40 } 39 }
41 40
42 HistogramSynchronizer::~HistogramSynchronizer() { 41 HistogramSynchronizer::~HistogramSynchronizer() {
43 // Just in case we have any pending tasks, clear them out. 42 // Just in case we have any pending tasks, clear them out.
44 SetCallbackTaskAndThread(NULL, NULL); 43 SetCallbackTaskAndThread(NULL, base::Closure());
45 histogram_synchronizer_ = NULL; 44 histogram_synchronizer_ = NULL;
46 } 45 }
47 46
48 // static 47 // static
49 HistogramSynchronizer* HistogramSynchronizer::CurrentSynchronizer() { 48 HistogramSynchronizer* HistogramSynchronizer::CurrentSynchronizer() {
50 DCHECK(histogram_synchronizer_ != NULL); 49 DCHECK(histogram_synchronizer_ != NULL);
51 return histogram_synchronizer_; 50 return histogram_synchronizer_;
52 } 51 }
53 52
54 void HistogramSynchronizer::FetchRendererHistogramsSynchronously( 53 void HistogramSynchronizer::FetchRendererHistogramsSynchronously(
(...skipping 16 matching lines...) Expand all
71 UMA_HISTOGRAM_COUNTS("Histogram.RendersNotRespondingSynchronous", 70 UMA_HISTOGRAM_COUNTS("Histogram.RendersNotRespondingSynchronous",
72 unresponsive_renderer_count); 71 unresponsive_renderer_count);
73 if (!unresponsive_renderer_count) 72 if (!unresponsive_renderer_count)
74 UMA_HISTOGRAM_TIMES("Histogram.FetchRendererHistogramsSynchronously", 73 UMA_HISTOGRAM_TIMES("Histogram.FetchRendererHistogramsSynchronously",
75 TimeTicks::Now() - start); 74 TimeTicks::Now() - start);
76 } 75 }
77 76
78 // static 77 // static
79 void HistogramSynchronizer::FetchRendererHistogramsAsynchronously( 78 void HistogramSynchronizer::FetchRendererHistogramsAsynchronously(
80 MessageLoop* callback_thread, 79 MessageLoop* callback_thread,
81 Task* callback_task, 80 const base::Closure& callback,
82 int wait_time) { 81 int wait_time) {
83 DCHECK(callback_thread != NULL); 82 DCHECK(callback_thread != NULL);
84 DCHECK(callback_task != NULL); 83 DCHECK(!callback.is_null());
85 84
86 HistogramSynchronizer* current_synchronizer = CurrentSynchronizer(); 85 HistogramSynchronizer* current_synchronizer = CurrentSynchronizer();
87 86
88 if (current_synchronizer == NULL) { 87 if (current_synchronizer == NULL) {
89 // System teardown is happening. 88 // System teardown is happening.
90 callback_thread->PostTask(FROM_HERE, callback_task); 89 callback_thread->PostTask(FROM_HERE, callback);
91 return; 90 return;
92 } 91 }
93 92
94 current_synchronizer->SetCallbackTaskAndThread(callback_thread, 93 current_synchronizer->SetCallbackTaskAndThread(callback_thread,
95 callback_task); 94 callback);
96 95
97 int sequence_number = 96 int sequence_number =
98 current_synchronizer->NotifyAllRenderers(ASYNC_HISTOGRAMS); 97 current_synchronizer->NotifyAllRenderers(ASYNC_HISTOGRAMS);
99 98
100 // Post a task that would be called after waiting for wait_time. This acts 99 // Post a task that would be called after waiting for wait_time. This acts
101 // as a watchdog, to ensure that a non-responsive renderer won't block us from 100 // as a watchdog, to ensure that a non-responsive renderer won't block us from
102 // making the callback. 101 // making the callback.
103 BrowserThread::PostDelayedTask( 102 BrowserThread::PostDelayedTask(
104 BrowserThread::UI, FROM_HERE, 103 BrowserThread::UI, FROM_HERE,
105 base::Bind( 104 base::Bind(
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
169 } 168 }
170 169
171 if (asynchronous_completed) 170 if (asynchronous_completed)
172 ForceHistogramSynchronizationDoneCallback(sequence_number); 171 ForceHistogramSynchronizationDoneCallback(sequence_number);
173 else if (synchronous_completed) 172 else if (synchronous_completed)
174 received_all_renderer_histograms_.Signal(); 173 received_all_renderer_histograms_.Signal();
175 } 174 }
176 175
177 void HistogramSynchronizer::SetCallbackTaskAndThread( 176 void HistogramSynchronizer::SetCallbackTaskAndThread(
178 MessageLoop* callback_thread, 177 MessageLoop* callback_thread,
179 Task* callback_task) { 178 const base::Closure& callback) {
180 Task* old_task = NULL; 179 base::Closure old_callback;
181 MessageLoop* old_thread = NULL; 180 MessageLoop* old_thread = NULL;
182 TimeTicks old_start_time; 181 TimeTicks old_start_time;
183 int unresponsive_renderers; 182 int unresponsive_renderers;
184 const TimeTicks now = TimeTicks::Now(); 183 const TimeTicks now = TimeTicks::Now();
185 { 184 {
186 base::AutoLock auto_lock(lock_); 185 base::AutoLock auto_lock(lock_);
187 old_task = callback_task_; 186 old_callback = callback_;
188 callback_task_ = callback_task; 187 callback_ = callback;
189 old_thread = callback_thread_; 188 old_thread = callback_thread_;
190 callback_thread_ = callback_thread; 189 callback_thread_ = callback_thread;
191 unresponsive_renderers = async_renderers_pending_; 190 unresponsive_renderers = async_renderers_pending_;
192 old_start_time = async_callback_start_time_; 191 old_start_time = async_callback_start_time_;
193 async_callback_start_time_ = now; 192 async_callback_start_time_ = now;
194 // Prevent premature calling of our new callbacks. 193 // Prevent premature calling of our new callbacks.
195 async_sequence_number_ = kNeverUsableSequenceNumber; 194 async_sequence_number_ = kNeverUsableSequenceNumber;
196 } 195 }
197 // Just in case there was a task pending.... 196 // Just in case there was a task pending....
198 InternalPostTask(old_thread, old_task, unresponsive_renderers, 197 InternalPostTask(old_thread, old_callback, unresponsive_renderers,
199 old_start_time); 198 old_start_time);
200 } 199 }
201 200
202 void HistogramSynchronizer::ForceHistogramSynchronizationDoneCallback( 201 void HistogramSynchronizer::ForceHistogramSynchronizationDoneCallback(
203 int sequence_number) { 202 int sequence_number) {
204 Task* task = NULL; 203 base::Closure callback;
205 MessageLoop* thread = NULL; 204 MessageLoop* thread = NULL;
206 TimeTicks started; 205 TimeTicks started;
207 int unresponsive_renderers; 206 int unresponsive_renderers;
208 { 207 {
209 base::AutoLock lock(lock_); 208 base::AutoLock lock(lock_);
210 if (sequence_number != async_sequence_number_) 209 if (sequence_number != async_sequence_number_)
211 return; 210 return;
212 task = callback_task_; 211 callback = callback_;
213 thread = callback_thread_; 212 thread = callback_thread_;
214 callback_task_ = NULL; 213 callback_.Reset();
215 callback_thread_ = NULL; 214 callback_thread_ = NULL;
216 started = async_callback_start_time_; 215 started = async_callback_start_time_;
217 unresponsive_renderers = async_renderers_pending_; 216 unresponsive_renderers = async_renderers_pending_;
218 } 217 }
219 InternalPostTask(thread, task, unresponsive_renderers, started); 218 InternalPostTask(thread, callback, unresponsive_renderers, started);
220 } 219 }
221 220
222 void HistogramSynchronizer::InternalPostTask(MessageLoop* thread, Task* task, 221 void HistogramSynchronizer::InternalPostTask(MessageLoop* thread,
222 const base::Closure& callback,
223 int unresponsive_renderers, 223 int unresponsive_renderers,
224 const base::TimeTicks& started) { 224 const base::TimeTicks& started) {
225 if (!task || !thread) 225 if (callback.is_null() || !thread)
226 return; 226 return;
227 UMA_HISTOGRAM_COUNTS("Histogram.RendersNotRespondingAsynchronous", 227 UMA_HISTOGRAM_COUNTS("Histogram.RendersNotRespondingAsynchronous",
228 unresponsive_renderers); 228 unresponsive_renderers);
229 if (!unresponsive_renderers) { 229 if (!unresponsive_renderers) {
230 UMA_HISTOGRAM_TIMES("Histogram.FetchRendererHistogramsAsynchronously", 230 UMA_HISTOGRAM_TIMES("Histogram.FetchRendererHistogramsAsynchronously",
231 TimeTicks::Now() - started); 231 TimeTicks::Now() - started);
232 } 232 }
233 233
234 thread->PostTask(FROM_HERE, task); 234 thread->PostTask(FROM_HERE, callback);
235 } 235 }
236 236
237 int HistogramSynchronizer::GetNextAvailableSequenceNumber( 237 int HistogramSynchronizer::GetNextAvailableSequenceNumber(
238 RendererHistogramRequester requester, 238 RendererHistogramRequester requester,
239 int renderer_count) { 239 int renderer_count) {
240 base::AutoLock auto_lock(lock_); 240 base::AutoLock auto_lock(lock_);
241 ++last_used_sequence_number_; 241 ++last_used_sequence_number_;
242 // Watch out for wrapping to a negative number. 242 // Watch out for wrapping to a negative number.
243 if (last_used_sequence_number_ < 0) { 243 if (last_used_sequence_number_ < 0) {
244 // Bypass the reserved number, which is used when a renderer spontaneously 244 // Bypass the reserved number, which is used when a renderer spontaneously
245 // decides to send some histogram data. 245 // decides to send some histogram data.
246 last_used_sequence_number_ = 246 last_used_sequence_number_ =
247 chrome::kHistogramSynchronizerReservedSequenceNumber + 1; 247 chrome::kHistogramSynchronizerReservedSequenceNumber + 1;
248 } 248 }
249 DCHECK_NE(last_used_sequence_number_, 249 DCHECK_NE(last_used_sequence_number_,
250 chrome::kHistogramSynchronizerReservedSequenceNumber); 250 chrome::kHistogramSynchronizerReservedSequenceNumber);
251 if (requester == ASYNC_HISTOGRAMS) { 251 if (requester == ASYNC_HISTOGRAMS) {
252 async_sequence_number_ = last_used_sequence_number_; 252 async_sequence_number_ = last_used_sequence_number_;
253 async_renderers_pending_ = renderer_count; 253 async_renderers_pending_ = renderer_count;
254 } else if (requester == SYNCHRONOUS_HISTOGRAMS) { 254 } else if (requester == SYNCHRONOUS_HISTOGRAMS) {
255 synchronous_sequence_number_ = last_used_sequence_number_; 255 synchronous_sequence_number_ = last_used_sequence_number_;
256 synchronous_renderers_pending_ = renderer_count; 256 synchronous_renderers_pending_ = renderer_count;
257 } 257 }
258 return last_used_sequence_number_; 258 return last_used_sequence_number_;
259 } 259 }
260 260
261 // static 261 // static
262 HistogramSynchronizer* HistogramSynchronizer::histogram_synchronizer_ = NULL; 262 HistogramSynchronizer* HistogramSynchronizer::histogram_synchronizer_ = NULL;
OLDNEW
« no previous file with comments | « chrome/browser/metrics/histogram_synchronizer.h ('k') | chrome/browser/metrics/metrics_service.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698