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

Side by Side Diff: third_party/WebKit/Source/platform/scheduler/base/work_queue_sets.cc

Issue 2940933003: DO NOT SUBMIT results of new clang-format (Closed)
Patch Set: Created 3 years, 6 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 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 "platform/scheduler/base/work_queue_sets.h" 5 #include "platform/scheduler/base/work_queue_sets.h"
6 6
7 #include "base/logging.h" 7 #include "base/logging.h"
8 8
9 namespace blink { 9 namespace blink {
10 namespace scheduler { 10 namespace scheduler {
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
54 } 54 }
55 55
56 void WorkQueueSets::OnTaskPushedToEmptyQueue(WorkQueue* work_queue) { 56 void WorkQueueSets::OnTaskPushedToEmptyQueue(WorkQueue* work_queue) {
57 // NOTE if this function changes, we need to keep |WorkQueueSets::AddQueue| in 57 // NOTE if this function changes, we need to keep |WorkQueueSets::AddQueue| in
58 // sync. 58 // sync.
59 DCHECK_EQ(this, work_queue->work_queue_sets()); 59 DCHECK_EQ(this, work_queue->work_queue_sets());
60 EnqueueOrder enqueue_order; 60 EnqueueOrder enqueue_order;
61 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); 61 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order);
62 DCHECK(has_enqueue_order); 62 DCHECK(has_enqueue_order);
63 size_t set_index = work_queue->work_queue_set_index(); 63 size_t set_index = work_queue->work_queue_set_index();
64 DCHECK_LT(set_index, work_queue_heaps_.size()) << " set_index = " 64 DCHECK_LT(set_index, work_queue_heaps_.size())
65 << set_index; 65 << " set_index = " << set_index;
66 // |work_queue| should not be in work_queue_heaps_[set_index]. 66 // |work_queue| should not be in work_queue_heaps_[set_index].
67 DCHECK(!work_queue->heap_handle().IsValid()); 67 DCHECK(!work_queue->heap_handle().IsValid());
68 work_queue_heaps_[set_index].insert({enqueue_order, work_queue}); 68 work_queue_heaps_[set_index].insert({enqueue_order, work_queue});
69 } 69 }
70 70
71 void WorkQueueSets::OnPopQueue(WorkQueue* work_queue) { 71 void WorkQueueSets::OnPopQueue(WorkQueue* work_queue) {
72 // Assume that |work_queue| contains the lowest enqueue_order. 72 // Assume that |work_queue| contains the lowest enqueue_order.
73 size_t set_index = work_queue->work_queue_set_index(); 73 size_t set_index = work_queue->work_queue_set_index();
74 DCHECK_EQ(this, work_queue->work_queue_sets()); 74 DCHECK_EQ(this, work_queue->work_queue_sets());
75 DCHECK_LT(set_index, work_queue_heaps_.size()); 75 DCHECK_LT(set_index, work_queue_heaps_.size());
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
118 const OldestTaskEnqueueOrder& oldest = work_queue_heaps_[set_index].Min(); 118 const OldestTaskEnqueueOrder& oldest = work_queue_heaps_[set_index].Min();
119 *out_work_queue = oldest.value; 119 *out_work_queue = oldest.value;
120 *out_enqueue_order = oldest.key; 120 *out_enqueue_order = oldest.key;
121 EnqueueOrder enqueue_order; 121 EnqueueOrder enqueue_order;
122 DCHECK(oldest.value->GetFrontTaskEnqueueOrder(&enqueue_order) && 122 DCHECK(oldest.value->GetFrontTaskEnqueueOrder(&enqueue_order) &&
123 oldest.key == enqueue_order); 123 oldest.key == enqueue_order);
124 return true; 124 return true;
125 } 125 }
126 126
127 bool WorkQueueSets::IsSetEmpty(size_t set_index) const { 127 bool WorkQueueSets::IsSetEmpty(size_t set_index) const {
128 DCHECK_LT(set_index, work_queue_heaps_.size()) << " set_index = " 128 DCHECK_LT(set_index, work_queue_heaps_.size())
129 << set_index; 129 << " set_index = " << set_index;
130 return work_queue_heaps_[set_index].empty(); 130 return work_queue_heaps_[set_index].empty();
131 } 131 }
132 132
133 #if DCHECK_IS_ON() || !defined(NDEBUG) 133 #if DCHECK_IS_ON() || !defined(NDEBUG)
134 bool WorkQueueSets::ContainsWorkQueueForTest( 134 bool WorkQueueSets::ContainsWorkQueueForTest(
135 const WorkQueue* work_queue) const { 135 const WorkQueue* work_queue) const {
136 EnqueueOrder enqueue_order; 136 EnqueueOrder enqueue_order;
137 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); 137 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order);
138 138
139 for (const IntrusiveHeap<OldestTaskEnqueueOrder>& heap : work_queue_heaps_) { 139 for (const IntrusiveHeap<OldestTaskEnqueueOrder>& heap : work_queue_heaps_) {
(...skipping 12 matching lines...) Expand all
152 return true; 152 return true;
153 } 153 }
154 154
155 return false; 155 return false;
156 } 156 }
157 #endif 157 #endif
158 158
159 } // namespace internal 159 } // namespace internal
160 } // namespace scheduler 160 } // namespace scheduler
161 } // namespace blink 161 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698