| /rocksdb-6.9/build_tools/ |
| D | regression_build_test.sh | 78 --threads=8 > ${STAT_FILE}.overwrite
96 --threads=1 > /dev/null
114 --threads=16 > ${STAT_FILE}.readrandom
133 --threads=16 > ${STAT_FILE}.readrandomtailing
171 --threads=16 > ${STAT_FILE}.readrandom_mem_sst
190 --threads=1 > /dev/null
208 --threads=16 > /dev/null
247 --threads=16 > ${STAT_FILE}.readwhilewriting
308 --threads=1 > /dev/null
319 --threads=32 \
[all …]
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 61 for (auto& thread : threads) { in basicNThreads()
127 for (auto& thread : threads) { in lockWithTryAndTimedNThreads()
171 for (auto& thread : threads) { in combineNThreads()
226 for (auto& thread : threads) { in combineWithLockNThreads()
296 for (auto& thread : threads) { in combineWithTryLockNThreads()
397 for (auto& thread : threads) { in combineWithLockTryAndTimedNThreads()
686 for (auto& thread : threads) { in stressTryLockWithConcurrentLocks()
730 for (auto& thread : threads) { in concurrentTryLocks()
922 for (auto& thread : threads) { in concurrentLocksManyMutexes()
1030 for (auto& thread : threads) { in concurrentExceptionPropagationStress()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_write_test.cc | 46 std::vector<port::Thread> threads; in TEST_P() local
106 threads.emplace_back(write_slowdown_func); in TEST_P()
109 threads.emplace_back(write_slowdown_func); in TEST_P()
113 threads.emplace_back(write_slowdown_func); in TEST_P()
117 threads.emplace_back(write_slowdown_func); in TEST_P()
129 for (auto& t : threads) { in TEST_P()
143 std::vector<port::Thread> threads; in TEST_P() local
161 threads.push_back(port::Thread( in TEST_P()
181 threads[i].join(); in TEST_P()
291 std::thread threads[10]; in TEST_P() local
[all …]
|
| D | column_family_test.cc | 1446 std::vector<port::Thread> threads; in TEST_P() local
1447 threads.emplace_back([&] { in TEST_P()
1461 threads.emplace_back([&] { in TEST_P()
1471 for (auto& t : threads) { in TEST_P()
1567 threads.join(); in TEST_P()
1666 threads.join(); in TEST_P()
1774 threads.join(); in TEST_P()
1868 threads.join(); in TEST_P()
1961 threads.join(); in TEST_P()
2438 std::vector<port::Thread> threads; in TEST_P() local
[all …]
|
| D | write_callback_test.cc | 336 std::vector<port::Thread> threads; in TEST_F() local
338 threads.emplace_back(write_with_callback_func); in TEST_F()
340 for (auto& t : threads) { in TEST_F()
|
| D | db_test.cc | 296 if (threads.empty()) { in TEST_F()
317 for (auto& t : threads) { in TEST_F()
350 if (threads.empty()) { in TEST_F()
375 for (auto& t : threads) { in TEST_F()
418 if (threads.empty()) { in TEST_F()
444 for (auto& t : threads) { in TEST_F()
925 for (auto& t : threads) { in TEST_F()
3861 for (auto& t : threads) { in TEST_F()
5910 for (auto& t : threads) { in TEST_F()
6411 threads.emplace_back([&]() { in TEST_F()
[all …]
|
| D | version_builder.cc | 720 std::vector<port::Thread> threads; in LoadTableHandlers() local
722 threads.emplace_back(load_handlers_func); in LoadTableHandlers()
725 for (auto& t : threads) { in LoadTableHandlers()
|
| /rocksdb-6.9/util/ |
| D | dynamic_bloom_test.cc | 225 std::vector<port::Thread> threads; in TEST_F() local
249 threads.emplace_back(adder, t); in TEST_F()
251 while (threads.size() > 0) { in TEST_F()
252 threads.back().join(); in TEST_F()
253 threads.pop_back(); in TEST_F()
275 while (threads.size() > 0) { in TEST_F()
276 threads.back().join(); in TEST_F()
277 threads.pop_back(); in TEST_F()
302 while (threads.size() > 0) { in TEST_F()
303 threads.back().join(); in TEST_F()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | dbench_monitor | 46 threads [threads]
70 : ${threads:=8}
84 …-compression_type=$ztype --benchmarks="$benches" --reads="$reads" --threads="$threads" --cache_siz…
88 …-compression_type=$ztype --benchmarks="$benches" --reads="$reads" --threads="$threads" --cache_siz…
|
| D | regression_test.sh | 207 threads=${3:-$NUM_THREADS}
223 --threads=$threads \
276 update_report "$1" "$RESULT_PATH/$1" $ops $threads
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_driver.cc | 69 std::vector<ThreadState*> threads(n); in RunStressTest() local
71 threads[i] = new ThreadState(i, &shared); in RunStressTest()
72 db_stress_env->StartThread(ThreadBody, threads[i]); in RunStressTest()
128 threads[0]->stats.Merge(threads[i]->stats); in RunStressTest()
130 threads[0]->stats.Report("Stress Test"); in RunStressTest()
133 delete threads[i]; in RunStressTest()
134 threads[i] = nullptr; in RunStressTest()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_test.h | 55 std::list<port::Thread> threads; in SpawnThreads() local
58 threads.push_back(std::move(th)); in SpawnThreads()
60 return threads; in SpawnThreads()
64 void Join(std::list<port::Thread>&& threads) { in Join() argument
65 for (auto& th : threads) { in Join()
68 threads.clear(); in Join()
77 auto threads = SpawnThreads(nthreads, fn); in Insert() local
79 Join(std::move(threads)); in Insert()
92 auto threads = SpawnThreads(nthreads, fn); variable
94 Join(std::move(threads));
|
| D | persistent_cache_bench.cc | 124 std::list<port::Thread> threads; in CacheTierBenchmark() local
125 Spawn(FLAGS_nthread_write, &threads, in CacheTierBenchmark()
127 Spawn(FLAGS_nthread_read, &threads, in CacheTierBenchmark()
140 Join(&threads); in CacheTierBenchmark()
260 void Spawn(const size_t n, std::list<port::Thread>* threads, in Spawn() argument
263 threads->emplace_back(fn); in Spawn()
268 void Join(std::list<port::Thread>* threads) { in Join() argument
269 for (auto& th : *threads) { in Join()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-05-14-core-local-stats.markdown | 10 …like min/max/per-bucket counters. These statistics could be updated by all user/background threads.
16 Here are perf results for 32 reader threads where most reads (99%+) are served by uncompressed bloc…
18 … -g ./db_bench -statistics -use_existing_db=true -benchmarks=readrandom -threads=32 -cache_size=10…
42 …gate all threads' local values. This adds some overhead, which may pass unnoticed if statistics ar…
75 …threads, or polling statistics infrequently. Eventually, though, we found use cases where those as…
77 … depends only on number of cores, not the number of threads. So, applications with many more threa…
|
| D | 2017-07-25-rocksdb-5-6-1-released.markdown | 9 … can achieve this by configuring their high-pri thread pool to have zero threads. See https://gith…
10 …ith `Options::max_background_jobs`, which automatically decides how many threads to allocate towar…
15 … previous thread-local approach, particularly for applications with many threads. See http://rocks…
|
| D | 2014-06-27-avoid-expensive-locks-in-get.markdown | 27 …ped RocksDB from scaling read throughput beyond 8 cores. Running 32 read threads on a 32-core CPU …
59 …threads spinning on CPU or even trigger thread context switches in which all readers compete to ac…
79 (3) After any flush/compaction, the background thread performs a sweep (CAS) across all threads’ lo…
|
| D | 2015-11-16-analysis-file-read-latency-by-level.markdown | 195 …20. I am inserting 1 billion hashes and reading 1 billion hashes with 32 threads. The histogram sh…
221 If I remember correctly, with db_bench, if you specify –num=1000000000 –threads=32, it is every thr…
234 …sable_seek_compaction=1 –mmap_read=0 –statistics=1 –histogram=1 –num=$r –threads=$t –value_size=$v…
237 …sable_seek_compaction=1 –mmap_read=0 –statistics=1 –histogram=1 –num=$r –threads=$t –value_size=$v…
244 It’s a printing error then. If you have `num=1000000000` and `t=32`, it will be 32 threads, and eac…
|
| D | 2015-10-27-getthreadlist.markdown | 118 In the above output, we can see `GetThreadList()` reports the activity of two threads: one thread r…
129 // If true, then the status of the threads involved in this DB will
|
| D | 2017-06-29-rocksdb-5-5-1-released.markdown | 18 …ned_write which may improve write throughput in case writing from multiple threads and WAL enabled.
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 417 std::vector<port::Thread> threads; in Run() local
422 RunThreads(&threads, &bytes_written, &bytes_read, true, &read_hits); in Run()
448 virtual void RunThreads(std::vector<port::Thread>* threads,
485 void RunThreads(std::vector<port::Thread>* threads, uint64_t* bytes_written, in RunThreads() argument
489 threads->emplace_back( in RunThreads()
493 for (auto& thread : *threads) { in RunThreads()
513 threads->emplace_back(SeqReadBenchmarkThread( in RunThreads()
517 for (auto& thread : *threads) { in RunThreads()
541 threads->emplace_back(ConcurrentFillBenchmarkThread( in RunThreads()
545 threads->emplace_back( in RunThreads()
[all …]
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 31 DEFINE_int32(threads, 16, "Number of concurrent threads to run.");
160 std::vector<ThreadState*> threads(num_threads_); in Run() local
162 threads[i] = new ThreadState(i, &shared); in Run()
163 env->StartThread(ThreadBody, threads[i]); in Run()
|
| /rocksdb-6.9/logging/ |
| D | env_logger_test.cc | 137 std::vector<port::Thread> threads; in TEST_F() local
141 threads.push_back(port::Thread(cb)); in TEST_F()
145 for (auto& th : threads) { in TEST_F()
|
| /rocksdb-6.9/file/ |
| D | delete_scheduler_test.cc | 266 std::vector<port::Thread> threads; in TEST_F() local
277 threads.emplace_back(delete_thread); in TEST_F()
280 for (size_t i = 0; i < threads.size(); i++) { in TEST_F()
281 threads[i].join(); in TEST_F()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_transaction_test.cc | 307 std::vector<port::Thread> threads; in TEST_P() local
309 threads.emplace_back(stress_thread, i); in TEST_P()
312 for (auto& t : threads) { in TEST_P()
|
| D | transaction_test.cc | 517 std::vector<port::Thread> threads; in TEST_P() local
589 for (auto& t : threads) { in TEST_P()
724 std::vector<port::Thread> threads; in TEST_P() local
793 for (auto& t : threads) { in TEST_P()
844 std::vector<port::Thread> threads; in TEST_P() local
849 for (auto& t : threads) { in TEST_P()
1480 std::vector<port::Thread> threads; in TEST_P() local
1484 for (auto& t : threads) { in TEST_P()
5313 std::vector<port::Thread> threads; in TEST_P() local
5363 threads.emplace_back(call_checker); in TEST_P()
[all …]
|