| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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; |
| OLD | NEW |