Index: components/metrics/profiler/tracking_synchronizer.cc |
diff --git a/components/metrics/profiler/tracking_synchronizer.cc b/components/metrics/profiler/tracking_synchronizer.cc |
index 8d53bd2a7ec19f42df2336cd968f5dcf49eb89b2..327c94dd632a3a66eaca95f3df5d3cb201c2cf8c 100644 |
--- a/components/metrics/profiler/tracking_synchronizer.cc |
+++ b/components/metrics/profiler/tracking_synchronizer.cc |
@@ -54,23 +54,23 @@ class TrackingSynchronizer::RequestContext { |
~RequestContext() {} |
void SetReceivedProcessGroupCount(bool done) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
received_process_group_count_ = done; |
} |
// Methods for book keeping of processes_pending_. |
void IncrementProcessesPending() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
++processes_pending_; |
} |
void AddProcessesPending(int processes_pending) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
processes_pending_ += processes_pending; |
} |
void DecrementProcessesPending() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
--processes_pending_; |
} |
@@ -79,7 +79,7 @@ class TrackingSynchronizer::RequestContext { |
// |processes_pending_| are zero, then delete the current object by calling |
// Unregister. |
void DeleteIfAllDone() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
if (processes_pending_ <= 0 && received_process_group_count_) |
RequestContext::Unregister(sequence_number_); |
@@ -90,7 +90,7 @@ class TrackingSynchronizer::RequestContext { |
static RequestContext* Register( |
int sequence_number, |
const base::WeakPtr<TrackingSynchronizerObserver>& callback_object) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
RequestContext* request = new RequestContext( |
callback_object, sequence_number); |
@@ -102,7 +102,7 @@ class TrackingSynchronizer::RequestContext { |
// Find the |RequestContext| in |outstanding_requests_| map for the given |
// |sequence_number|. |
static RequestContext* GetRequestContext(int sequence_number) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
RequestContextMap::iterator it = |
outstanding_requests_.Get().find(sequence_number); |
@@ -118,7 +118,7 @@ class TrackingSynchronizer::RequestContext { |
// |outstanding_requests_| map. This method is called when all changes have |
// been acquired, or when the wait time expires (whichever is sooner). |
static void Unregister(int sequence_number) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
RequestContextMap::iterator it = |
outstanding_requests_.Get().find(sequence_number); |
@@ -198,7 +198,7 @@ TrackingSynchronizer::~TrackingSynchronizer() { |
// static |
void TrackingSynchronizer::FetchProfilerDataAsynchronously( |
const base::WeakPtr<TrackingSynchronizerObserver>& callback_object) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
if (!g_tracking_synchronizer) { |
// System teardown is happening. |
@@ -219,7 +219,7 @@ void TrackingSynchronizer::FetchProfilerDataAsynchronously( |
void TrackingSynchronizer::OnPendingProcesses(int sequence_number, |
int pending_processes, |
bool end) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
RequestContext* request = RequestContext::GetRequestContext(sequence_number); |
if (!request) |
@@ -233,14 +233,14 @@ void TrackingSynchronizer::OnProfilerDataCollected( |
int sequence_number, |
const tracked_objects::ProcessDataSnapshot& profiler_data, |
int process_type) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
DecrementPendingProcessesAndSendData(sequence_number, profiler_data, |
process_type); |
} |
int TrackingSynchronizer::RegisterAndNotifyAllProcesses( |
const base::WeakPtr<TrackingSynchronizerObserver>& callback_object) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
int sequence_number = GetNextAvailableSequenceNumber(); |
@@ -266,7 +266,7 @@ void TrackingSynchronizer::DecrementPendingProcessesAndSendData( |
int sequence_number, |
const tracked_objects::ProcessDataSnapshot& profiler_data, |
int process_type) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
RequestContext* request = RequestContext::GetRequestContext(sequence_number); |
if (!request) |
@@ -283,7 +283,7 @@ void TrackingSynchronizer::DecrementPendingProcessesAndSendData( |
} |
int TrackingSynchronizer::GetNextAvailableSequenceNumber() { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
+ DCHECK_CURRENTLY_ON(BrowserThread::UI); |
++last_used_sequence_number_; |