| 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/threading/sequenced_worker_pool.h" | 5 #include "base/threading/sequenced_worker_pool.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 | 8 |
| 9 #include <algorithm> | 9 #include <algorithm> |
| 10 | 10 |
| (...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 227 | 227 |
| 228 base::ConditionVariable cond_var_; | 228 base::ConditionVariable cond_var_; |
| 229 | 229 |
| 230 // Protected by lock_. | 230 // Protected by lock_. |
| 231 std::vector<int> complete_sequence_; | 231 std::vector<int> complete_sequence_; |
| 232 | 232 |
| 233 // Counter of the number of "block" workers that have started. | 233 // Counter of the number of "block" workers that have started. |
| 234 size_t started_events_; | 234 size_t started_events_; |
| 235 }; | 235 }; |
| 236 | 236 |
| 237 class SequencedWorkerPoolTest : public testing::Test { | 237 class SequencedWorkerPoolTest : public ::testing::Test { |
| 238 public: | 238 public: |
| 239 SequencedWorkerPoolTest() | 239 SequencedWorkerPoolTest() |
| 240 : tracker_(new TestTracker) { | 240 : tracker_(new TestTracker) { |
| 241 ResetPool(); | 241 ResetPool(); |
| 242 } | 242 } |
| 243 | 243 |
| 244 const scoped_refptr<SequencedWorkerPool>& pool() { | 244 const scoped_refptr<SequencedWorkerPool>& pool() { |
| 245 return pool_owner_->pool(); | 245 return pool_owner_->pool(); |
| 246 } | 246 } |
| 247 TestTracker* tracker() { return tracker_.get(); } | 247 TestTracker* tracker() { return tracker_.get(); } |
| (...skipping 911 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1159 SequencedWorkerPoolSequencedTaskRunner, SequencedTaskRunnerTest, | 1159 SequencedWorkerPoolSequencedTaskRunner, SequencedTaskRunnerTest, |
| 1160 SequencedWorkerPoolSequencedTaskRunnerTestDelegate); | 1160 SequencedWorkerPoolSequencedTaskRunnerTestDelegate); |
| 1161 INSTANTIATE_TYPED_TEST_CASE_P( | 1161 INSTANTIATE_TYPED_TEST_CASE_P( |
| 1162 SequencedWorkerPoolSequencedTaskRunner, | 1162 SequencedWorkerPoolSequencedTaskRunner, |
| 1163 SequencedTaskRunnerDelayedTest, | 1163 SequencedTaskRunnerDelayedTest, |
| 1164 SequencedWorkerPoolSequencedTaskRunnerTestDelegate); | 1164 SequencedWorkerPoolSequencedTaskRunnerTestDelegate); |
| 1165 | 1165 |
| 1166 } // namespace | 1166 } // namespace |
| 1167 | 1167 |
| 1168 } // namespace base | 1168 } // namespace base |
| OLD | NEW |