Lines Matching refs:state
345 TestState* state = reinterpret_cast<TestState*>(arg); in ConcurrentReader() local
346 Random rnd(state->seed_); in ConcurrentReader()
348 state->Change(TestState::RUNNING); in ConcurrentReader()
349 while (!state->quit_flag_.load(std::memory_order_acquire)) { in ConcurrentReader()
350 state->t_.ReadStep(&rnd); in ConcurrentReader()
353 state->Change(TestState::DONE); in ConcurrentReader()
365 TestState state(seed + 1); in RunConcurrent() local
367 Env::Default()->Schedule(ConcurrentReader, &state); in RunConcurrent()
368 state.Wait(TestState::RUNNING); in RunConcurrent()
370 state.t_.WriteStep(&rnd); in RunConcurrent()
372 state.quit_flag_.store(true, std::memory_order_release); in RunConcurrent()
373 state.Wait(TestState::DONE); in RunConcurrent()