Searched refs:cv (Results 1 – 7 of 7) sorted by relevance
| /rocksdb-6.9/util/ |
| D | thread_local_test.cc | 33 cv(c), in Params()
43 port::CondVar* cv; member
149 cv.Wait(); in TEST_F()
181 p.cv->Wait(); in TEST_F()
258 p.cv->Wait(); in TEST_F()
284 p.cv->Wait(); in TEST_F()
324 p.cv->Wait(); in TEST_F()
362 cv.Wait(); in TEST_F()
437 cv.Wait(); in TEST_F()
496 cv.Wait(); in TEST_F()
[all …]
|
| D | rate_limiter.cc | 39 : request_bytes(_bytes), bytes(_bytes), cv(_mu), granted(false) {} in Req()
42 port::CondVar cv; member
82 r->cv.Signal(); in ~GenericRateLimiter()
85 r->cv.Signal(); in ~GenericRateLimiter()
159 timedout = r.cv.TimedWait(wait_until); in Request()
163 r.cv.Wait(); in Request()
204 queue_[Env::IO_HIGH].front()->cv.Signal(); in Request()
206 queue_[Env::IO_LOW].front()->cv.Signal(); in Request()
259 next_req->cv.Signal(); in Refill()
|
| /rocksdb-6.9/db/ |
| D | db_write_test.cc | 49 port::CondVar cv(&mutex); in TEST_P() local
69 cv.SignalAll(); in TEST_P()
107 cv.Wait(); in TEST_P()
110 cv.Wait(); in TEST_P()
112 cv.Wait(); in TEST_P()
114 cv.Wait(); in TEST_P()
116 cv.Wait(); in TEST_P()
118 cv.Wait(); in TEST_P()
|
| D | version_set.cc | 3479 InstrumentedCondVar cv; member
3488 cv(mu), in ManifestWriter()
4054 ready->cv.Signal(); in ProcessManifestWrites()
4061 manifest_writers_.front()->cv.Signal(); in ProcessManifestWrites()
4110 first_writer.cv.Wait(); in LogAndApply()
4137 manifest_writers_.front()->cv.Signal(); in LogAndApply()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim.sh | 36 current_jobs=$(ps aux | grep pysim | grep python | grep -cv grep)
51 current_jobs=$(ps aux | grep pysim | grep python | grep -cv grep)
67 current_jobs=$(ps aux | grep pysim | grep python | grep -cv grep)
|
| /rocksdb-6.9/env/ |
| D | env_test.cc | 400 port::CondVar cv(&mutex); in TEST_P() local
468 CB low_pool_job("low", kLowPoolSize, &mutex, &cv, &should_start); in TEST_P()
469 CB high_pool_job("high", kHighPoolSize, &mutex, &cv, &should_start); in TEST_P()
505 cv.SignalAll(); in TEST_P()
554 cv.SignalAll(); in TEST_P()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 2218 port::CondVar cv; member
2234 SharedState() : cv(&mu), perf_level(FLAGS_perf_level) { } in SharedState()
3303 shared->cv.SignalAll(); in ThreadBody()
3306 shared->cv.Wait(); in ThreadBody()
3320 shared->cv.SignalAll(); in ThreadBody()
3379 shared.cv.Wait(); in RunBenchmark()
3383 shared.cv.SignalAll(); in RunBenchmark()
3385 shared.cv.Wait(); in RunBenchmark()
|