Searched refs:WaitFlag (Results 1 – 12 of 12) sorted by relevance
52 enum class WaitFlag : int { kBlocking, kNonBlocking }; enum83 Status Join(WaitFlag wf = WaitFlag::kBlocking);
140 Status Task::Join(WaitFlag blocking) { in Join()145 if (blocking == WaitFlag::kBlocking) { in Join()148 } else if (blocking == WaitFlag::kNonBlocking) { in Join()
138 Status join_all(Task::WaitFlag wf = Task::WaitFlag::kBlocking);
316 Status TaskGroup::join_all(Task::WaitFlag wf) { in join_all()331 return (join_all(Task::WaitFlag::kNonBlocking)); in DoServiceStop()
70 Status Task::Join(WaitFlag wf = WaitFlag::kBlocking);76 enum class WaitFlag : int { kBlocking, kNonBlocking };166 Status TaskGroup::join_all(Task::WaitFlag wf = Task::WaitFlag::kBlocking);
50 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()66 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()
170 tg_->join_all(Task::WaitFlag::kNonBlocking); in Run_test_0()237 tg_->join_all(Task::WaitFlag::kNonBlocking); in Run_test_1()
84 ASSERT_TRUE(vg.join_all(Task::WaitFlag::kNonBlocking).IsOk()); in TEST_F()
69 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kNonBlocking)); in DoServiceStop()
1037 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kBlocking)); in Run()
245 RETURN_IF_NOT_OK(pTask->Join(Task::WaitFlag::kBlocking)); in RunFirstEpoch()390 RETURN_IF_NOT_OK(pTask->Join(Task::WaitFlag::kBlocking)); in RunReadEpoch()
131 RETURN_IF_NOT_OK(vg.join_all(Task::WaitFlag::kBlocking)); in InitAndLoad()