17   SharedState* shared = thread->shared;  in ThreadBody()  local
19   if (shared->ShouldVerifyAtBeginning()) {  in ThreadBody()
20     thread->shared->GetStressTest()->VerifyDb(thread);  in ThreadBody()
23     MutexLock l(shared->GetMutex());  in ThreadBody()
24     shared->IncInitialized();  in ThreadBody()
25     if (shared->AllInitialized()) {  in ThreadBody()
26       shared->GetCondVar()->SignalAll();  in ThreadBody()
28     while (!shared->Started()) {  in ThreadBody()
29       shared->GetCondVar()->Wait();  in ThreadBody()
32   thread->shared->GetStressTest()->OperateDb(thread);  in ThreadBody()
35     MutexLock l(shared->GetMutex());  in ThreadBody()
36     shared->IncOperated();  in ThreadBody()
37     if (shared->AllOperated()) {  in ThreadBody()
38       shared->GetCondVar()->SignalAll();  in ThreadBody()
40     while (!shared->VerifyStarted()) {  in ThreadBody()
41       shared->GetCondVar()->Wait();  in ThreadBody()
45   thread->shared->GetStressTest()->VerifyDb(thread);  in ThreadBody()
48     MutexLock l(shared->GetMutex());  in ThreadBody()
49     shared->IncDone();  in ThreadBody()
50     if (shared->AllDone()) {  in ThreadBody()
51       shared->GetCondVar()->SignalAll();  in ThreadBody()
59   SharedState shared(db_stress_env, stress);  in RunStressTest()  local
61     stress->InitReadonlyDb(&shared);  in RunStressTest()
64   uint32_t n = shared.GetNumThreads();  in RunStressTest()
71     threads[i] = new ThreadState(i, &shared);  in RunStressTest()
74   ThreadState bg_thread(0, &shared);  in RunStressTest()
78   ThreadState continuous_verification_thread(0, &shared);  in RunStressTest()
89     MutexLock l(shared.GetMutex());  in RunStressTest()
90     while (!shared.AllInitialized()) {  in RunStressTest()
91       shared.GetCondVar()->Wait();  in RunStressTest()
93     if (shared.ShouldVerifyAtBeginning()) {  in RunStressTest()
94       if (shared.HasVerificationFailedYet()) {  in RunStressTest()
105     shared.SetStart();  in RunStressTest()
106     shared.GetCondVar()->SignalAll();  in RunStressTest()
107     while (!shared.AllOperated()) {  in RunStressTest()
108       shared.GetCondVar()->Wait();  in RunStressTest()
120     shared.SetStartVerify();  in RunStressTest()
121     shared.GetCondVar()->SignalAll();  in RunStressTest()
122     while (!shared.AllDone()) {  in RunStressTest()
123       shared.GetCondVar()->Wait();  in RunStressTest()
137   if (!FLAGS_test_batches_snapshots && !shared.HasVerificationFailedYet()) {  in RunStressTest()
145     MutexLock l(shared.GetMutex());  in RunStressTest()
146     shared.SetShouldStopBgThread();  in RunStressTest()
147     while (!shared.BgThreadsFinished()) {  in RunStressTest()
148       shared.GetCondVar()->Wait();  in RunStressTest()
156   if (shared.HasVerificationFailedYet()) {  in RunStressTest()