35   void Run(Thread* self) {  in Run()  argument
36     LOG(INFO) << "Before barrier" << *self;  in Run()
38     barrier_->Wait(self);  in Run()
40     LOG(INFO) << "After barrier" << *self;  in Run()
62   Thread* self = Thread::Current();  in TEST_F()  local
69     thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2));  in TEST_F()
71   thread_pool.StartWorkers(self);  in TEST_F()
73     timeout_barrier.Increment(self, 1, 100);  // sleep 100 msecs  in TEST_F()
78   barrier.Wait(self);  in TEST_F()
80   thread_pool.Wait(self, true, false);  in TEST_F()
84   timeout_barrier.Init(self, 0);  // Reset to zero for destruction.  in TEST_F()
94   void Run(Thread* self) {  in Run()  argument
98       barrier_->Pass(self);  in Run()
113   Thread* self = Thread::Current();  in TEST_F()  local
120     thread_pool.AddTask(self, new CheckPassTask(&barrier, &count, num_sub_tasks));  in TEST_F()
122   thread_pool.StartWorkers(self);  in TEST_F()
125   barrier.Increment(self, expected_total_tasks);  in TEST_F()