2242   SharedState* shared;  member
3290     SharedState* shared;  member
3297     SharedState* shared = arg->shared;  in ThreadBody()  local
3300       MutexLock l(&shared->mu);  in ThreadBody()
3301       shared->num_initialized++;  in ThreadBody()
3302       if (shared->num_initialized >= shared->total) {  in ThreadBody()
3303         shared->cv.SignalAll();  in ThreadBody()
3305       while (!shared->start) {  in ThreadBody()
3306         shared->cv.Wait();  in ThreadBody()
3310     SetPerfLevel(static_cast<PerfLevel> (shared->perf_level));  in ThreadBody()
3317       MutexLock l(&shared->mu);  in ThreadBody()
3318       shared->num_done++;  in ThreadBody()
3319       if (shared->num_done >= shared->total) {  in ThreadBody()
3320         shared->cv.SignalAll();  in ThreadBody()
3327     SharedState shared;  in RunBenchmark()  local
3328     shared.total = n;  in RunBenchmark()
3329     shared.num_initialized = 0;  in RunBenchmark()
3330     shared.num_done = 0;  in RunBenchmark()
3331     shared.start = false;  in RunBenchmark()
3333       shared.write_rate_limiter.reset(  in RunBenchmark()
3337       shared.read_rate_limiter.reset(NewGenericRateLimiter(  in RunBenchmark()
3370       arg[i].shared = &shared;  in RunBenchmark()
3373       arg[i].thread->shared = &shared;  in RunBenchmark()
3377     shared.mu.Lock();  in RunBenchmark()
3378     while (shared.num_initialized < n) {  in RunBenchmark()
3379       shared.cv.Wait();  in RunBenchmark()
3382     shared.start = true;  in RunBenchmark()
3383     shared.cv.SignalAll();  in RunBenchmark()
3384     while (shared.num_done < n) {  in RunBenchmark()
3385       shared.cv.Wait();  in RunBenchmark()
3387     shared.mu.Unlock();  in RunBenchmark()
4481       if (thread->shared->write_rate_limiter.get() != nullptr) {  in DoWrite()
4482         thread->shared->write_rate_limiter->Request(  in DoWrite()
4512           thread->shared->write_rate_limiter.reset(  in DoWrite()
4855       if (thread->shared->read_rate_limiter.get() != nullptr &&  in ReadSequential()
4857         thread->shared->read_rate_limiter->Request(1024, Env::IO_HIGH,  in ReadSequential()
4908       if (thread->shared->read_rate_limiter.get() != nullptr &&  in ReadToRowCache()
4910         thread->shared->read_rate_limiter->Request(  in ReadToRowCache()
4948       if (thread->shared->read_rate_limiter.get() != nullptr &&  in ReadReverse()
4950         thread->shared->read_rate_limiter->Request(1024, Env::IO_HIGH,  in ReadReverse()
4992       if (thread->shared->read_rate_limiter.get() != nullptr) {  in ReadRandomFast()
4993         thread->shared->read_rate_limiter->Request(  in ReadRandomFast()
5085       if (thread->shared->read_rate_limiter.get() != nullptr &&  in ReadRandom()
5087         thread->shared->read_rate_limiter->Request(  in ReadRandom()
5176       if (thread->shared->read_rate_limiter.get() != nullptr &&  in MultiReadRandom()
5178         thread->shared->read_rate_limiter->Request(  in MultiReadRandom()
5447       thread->shared->read_rate_limiter.reset(NewGenericRateLimiter(  in MixGraph()
5450       thread->shared->write_rate_limiter.reset(  in MixGraph()
5503         thread->shared->write_rate_limiter.reset(  in MixGraph()
5505         thread->shared->read_rate_limiter.reset(NewGenericRateLimiter(  in MixGraph()
5533         if (thread->shared->read_rate_limiter.get() != nullptr &&  in MixGraph()
5535           thread->shared->read_rate_limiter->Request(  in MixGraph()
5558         if (thread->shared->write_rate_limiter) {  in MixGraph()
5559           thread->shared->write_rate_limiter->Request(  in MixGraph()
5719       if (thread->shared->read_rate_limiter.get() != nullptr &&  in SeekRandom()
5721         thread->shared->read_rate_limiter->Request(  in SeekRandom()
5830         MutexLock l(&thread->shared->mu);  in BGWriter()
5835         if (thread->shared->num_done + 1 >= thread->shared->num_initialized) {  in BGWriter()
6155       if (thread->shared->write_rate_limiter) {  in UpdateRandom()
6156         thread->shared->write_rate_limiter->Request(  in UpdateRandom()
6698         MutexLock l(&thread->shared->mu);  in TimeSeriesReadOrDelete()
6699         if (thread->shared->num_done >= 1) {  in TimeSeriesReadOrDelete()
6744       if (thread->shared->read_rate_limiter.get() != nullptr) {  in TimeSeriesReadOrDelete()
6745         thread->shared->read_rate_limiter->Request(  in TimeSeriesReadOrDelete()