Index: base/threading/worker_pool_posix_unittest.cc |
diff --git a/base/threading/worker_pool_posix_unittest.cc b/base/threading/worker_pool_posix_unittest.cc |
index 332c55e014fd0c8b0a9fc3f78c33b8193bde800e..c984ee33af77656cf3d1f4813802eee49b5ad4f7 100644 |
--- a/base/threading/worker_pool_posix_unittest.cc |
+++ b/base/threading/worker_pool_posix_unittest.cc |
@@ -6,8 +6,8 @@ |
#include <set> |
-#include "base/lock.h" |
#include "base/synchronization/condition_variable.h" |
+#include "base/synchronization/lock.h" |
#include "base/task.h" |
#include "base/threading/platform_thread.h" |
#include "base/synchronization/waitable_event.h" |
@@ -61,12 +61,12 @@ class IncrementingTask : public Task { |
virtual void Run() { |
AddSelfToUniqueThreadSet(); |
- AutoLock locked(*counter_lock_); |
+ base::AutoLock locked(*counter_lock_); |
(*counter_)++; |
} |
void AddSelfToUniqueThreadSet() { |
- AutoLock locked(*unique_threads_lock_); |
+ base::AutoLock locked(*unique_threads_lock_); |
unique_threads_->insert(PlatformThread::CurrentId()); |
} |
@@ -100,7 +100,7 @@ class BlockingIncrementingTask : public Task { |
virtual void Run() { |
{ |
- AutoLock num_waiting_to_start_locked(*num_waiting_to_start_lock_); |
+ base::AutoLock num_waiting_to_start_locked(*num_waiting_to_start_lock_); |
(*num_waiting_to_start_)++; |
} |
num_waiting_to_start_cv_->Signal(); |
@@ -138,14 +138,14 @@ class PosixDynamicThreadPoolTest : public testing::Test { |
} |
void WaitForTasksToStart(int num_tasks) { |
- AutoLock num_waiting_to_start_locked(num_waiting_to_start_lock_); |
+ base::AutoLock num_waiting_to_start_locked(num_waiting_to_start_lock_); |
while (num_waiting_to_start_ < num_tasks) { |
num_waiting_to_start_cv_.Wait(); |
} |
} |
void WaitForIdleThreads(int num_idle_threads) { |
- AutoLock pool_locked(*peer_.lock()); |
+ base::AutoLock pool_locked(*peer_.lock()); |
while (peer_.num_idle_threads() < num_idle_threads) { |
peer_.num_idle_threads_cv()->Wait(); |
} |
@@ -249,7 +249,7 @@ TEST_F(PosixDynamicThreadPoolTest, Complex) { |
// Wake up all idle threads so they can exit. |
{ |
- AutoLock locked(*peer_.lock()); |
+ base::AutoLock locked(*peer_.lock()); |
while (peer_.num_idle_threads() > 0) { |
peer_.tasks_available_cv()->Signal(); |
peer_.num_idle_threads_cv()->Wait(); |