| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.cc | 491 auto shared = thread->shared; in OperateDb()
505 thread->stats.Start(); in OperateDb()
521 thread->shared->GetStressTest()->Reopen(thread); in OperateDb()
537 SetOptions(thread); in OperateDb()
756 thread->stats.Stop(); in OperateDb()
824 if (thread->rand.OneIn(16)) { in TestIterate()
1275 if (thread->rand.OneIn(2)) { in TestApproximateSize()
1295 if (thread->rand.OneIn(2)) { in TestApproximateSize()
1456 std::min(thread->rand.Uniform(25), thread->rand.Uniform(25)); in TestPauseBackground()
1566 if (thread->rand.OneIn(2)) { in TestCompactRange()
[all …]
|
| D | no_batched_ops_stress.cc | 22 auto shared = thread->shared; in VerifyDb()
36 if (!thread->rand.OneIn(2)) { in VerifyDb()
150 thread->stats.AddGets(1, 1); in TestGet()
153 thread->stats.AddGets(1, 0); in TestGet()
157 thread->stats.AddErrors(1); in TestGet()
207 thread->rand.Next() % thread->shared->UNKNOWN_SENTINEL; in TestMultiGet()
296 thread->stats.AddErrors(1); in TestPrefixScan()
307 auto shared = thread->shared; in TestPut()
387 auto shared = thread->shared; in TestDelete()
426 thread->stats.AddDeletes(1); in TestDelete()
[all …]
|
| D | db_stress_test_base.h | 35 void OperateDb(ThreadState* thread);
36 virtual void VerifyDb(ThreadState* thread) const = 0;
49 Status SetOptions(ThreadState* thread);
77 ThreadState* thread, const ReadOptions& read_opts,
81 virtual Status TestPrefixScan(ThreadState* thread,
168 virtual Status TestBackupRestore(ThreadState* thread,
172 virtual Status TestCheckpoint(ThreadState* thread,
180 Status TestPauseBackground(ThreadState* thread);
185 Status MaybeReleaseSnapshots(ThreadState* thread, uint64_t i);
192 ThreadState* thread, uint64_t iteration,
[all …]
|
| D | cf_consistency_stress.cc | 43 thread->stats.AddErrors(1); in TestPut()
66 thread->stats.AddErrors(1); in TestDelete()
78 auto shared = thread->shared; in TestDeleteRange()
96 thread->stats.AddErrors(1); in TestDeleteRange()
124 if (thread->rand.OneIn(2)) { in TestGet()
188 thread->stats.AddErrors(1); in TestGet()
192 thread->stats.AddGets(1, 1); in TestGet()
197 thread->stats.AddErrors(1); in TestGet()
272 thread->stats.AddErrors(1); in TestPrefixScan()
365 assert(thread != nullptr); in VerifyDb()
[all …]
|
| D | db_stress_common.cc | 84 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in PoolSizeChangeThread() local
85 SharedState* shared = thread->shared; in PoolSizeChangeThread()
103 thread->rand.Next() % (thread_pool_size_var * 2 + 1); in PoolSizeChangeThread()
119 auto* thread = reinterpret_cast<ThreadState*>(v); in DbVerificationThread() local
120 SharedState* shared = thread->shared; in DbVerificationThread()
135 stress_test->ContinuouslyVerifyDb(thread); in DbVerificationThread()
162 int64_t GenerateOneKey(ThreadState* thread, uint64_t iteration) { in GenerateOneKey() argument
172 (static_cast<double>(thread->rand.Next() % FLAGS_max_key)) / in GenerateOneKey()
185 std::vector<int64_t> GenerateNKeys(ThreadState* thread, int num_keys, in GenerateNKeys() argument
199 (static_cast<double>(thread->rand.Next() % FLAGS_max_key)) / in GenerateNKeys()
[all …]
|
| D | batched_ops_stress.cc | 28 thread->rand.Next() % thread->shared->UNKNOWN_SENTINEL; in TestPut()
52 thread->stats.AddErrors(1); in TestPut()
81 thread->stats.AddErrors(1); in TestDelete()
83 thread->stats.AddDeletes(10); in TestDelete()
137 thread->stats.AddErrors(1); in TestGet()
142 thread->stats.AddGets(1, 0); in TestGet()
153 thread->stats.AddGets(1, 1); in TestGet()
203 thread->stats.AddErrors(1); in TestMultiGet()
208 thread->stats.AddGets(1, 0); in TestMultiGet()
271 if (thread->rand.OneIn(2) && in TestPrefixScan()
[all …]
|
| D | db_stress_driver.cc | 16 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody() local
17 SharedState* shared = thread->shared; in ThreadBody()
20 thread->shared->GetStressTest()->VerifyDb(thread); in ThreadBody()
32 thread->shared->GetStressTest()->OperateDb(thread); in ThreadBody()
45 thread->shared->GetStressTest()->VerifyDb(thread); in ThreadBody()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 62 thread.join(); in basicNThreads()
128 thread.join(); in lockWithTryAndTimedNThreads()
172 thread.join(); in combineNThreads()
227 thread.join(); in combineWithLockNThreads()
626 auto thread = std::thread{[&]() { in TEST()
637 thread.join(); in TEST()
644 auto thread = std::thread{[&]() { in TEST()
655 thread.join(); in TEST()
834 auto thread = std::thread{[&]() { in TEST()
879 thread.join(); in TEST()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 3291 ThreadState* thread; member
3298 ThreadState* thread = arg->thread; in ThreadBody() local
3312 thread->stats.Start(thread->tid); in ThreadBody()
3314 thread->stats.Stop(); in ThreadBody()
4824 (void)thread; in DoDeterministicCompact()
5745 SeekRandom(thread); in SeekRandomWhileWriting()
5753 SeekRandom(thread); in SeekRandomWhileMerging()
5794 ReadRandom(thread); in ReadWhileWriting()
5835 if (thread->shared->num_done + 1 >= thread->shared->num_initialized) { in BGWriter()
5882 BGScan(thread); in ReadWhileScanning()
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-10-27-getthreadlist.markdown | 153 the current status of a thread. The `ThreadStatus` structure, defined in
157 // An unique ID for the thread.
160 // The type of the thread, it could be HIGH_PRIORITY,
164 // The name of the DB instance where the thread is currently
165 // involved with. It would be set to empty string if the thread
169 // The name of the column family where the thread is currently
170 // It would be set to empty string if the thread does not involve
174 // The operation (high-level action) that the current thread is involved.
177 // The elapsed time in micros of the current thread operation.
180 // An integer showing the current stage where the thread is involved
[all …]
|
| D | 2014-06-27-avoid-expensive-locks-in-get.markdown | 32 …thread local storage](http://en.wikipedia.org/wiki/Thread-local_storage). Version change is a rare…
59 …he assembly code. Mutex can keep threads spinning on CPU or even trigger thread context switches i…
64 …thread can visit GetImpl() once but can never come back again. SuperVersion is referenced and cach…
69 (1) A reader thread uses CAS to acquire SuperVersion from its local storage and to put in a special…
74 …thread tries to return SuperVersion to local storage by CAS, expecting the special flag (SuperVers…
79 …on, the background thread performs a sweep (CAS) across all threads’ local storage and frees encou…
|
| D | 2017-05-14-core-local-stats.markdown | 40 …thread-local storage. Each thread has a local set of atomic values that no other thread can update…
42 …urate statistics. We handle this by merging a thread's local values into process-wide variables up…
75 The thread-local approach is working well for applications calling RocksDB from only a few threads,…
77 …ticker/histogram statistics will be local to each CPU core. Similarly to thread-local, each core u…
81 Update benchmark setup is same as before. CPU overhead worsened ~23% compared to thread-local, whil…
99 …me as before with times in milliseconds. Average latency improved by 6.3x compared to thread-local.
|
| D | 2017-07-25-rocksdb-5-6-1-released.markdown | 9 …same thread pool is no longer supported by setting `max_background_flushes=0`. Instead, users can …
15 …-local storage. This improves aggregation speed compared to our previous thread-local approach, pa…
|
| D | 2019-08-15-unordered-write.markdown | 14 - Read-your-own writes: When a write thread returns to the user, a subsequent read by the same thre…
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 197 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody() local
198 SharedState* shared = thread->shared; in ThreadBody()
210 thread->shared->GetCacheBench()->OperateCache(thread); in ThreadBody()
221 void OperateCache(ThreadState* thread) { in OperateCache() argument
223 uint64_t rand_key = thread->rnd.Next() % FLAGS_max_key; in OperateCache()
226 int32_t prob_op = thread->rnd.Uniform(100); in OperateCache()
|
| /rocksdb-6.9/util/ |
| D | repeatable_thread_test.cc | 32 ROCKSDB_NAMESPACE::RepeatableThread thread( in TEST_F() local
53 thread.cancel(); in TEST_F()
90 ROCKSDB_NAMESPACE::RepeatableThread thread( in TEST_F() local
94 thread.TEST_WaitForRun([&] { mock_env_->set_current_time(i); }); in TEST_F()
100 thread.cancel(); in TEST_F()
|
| D | repeatable_thread.h | 38 thread_([this] { thread(); }) { in function_()
102 void thread() { in thread() function
|
| D | random.cc | 31 size_t seed = std::hash<std::thread::id>()(std::this_thread::get_id()); in GetTLSInstance()
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 493 for (auto& thread : *threads) { in RunThreads()
494 thread.join(); in RunThreads()
517 for (auto& thread : *threads) { in RunThreads()
518 thread.join(); in RunThreads()
549 for (auto& thread : *threads) { in RunThreads()
550 thread.join(); in RunThreads()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.h | 34 std::unordered_map<std::string, std::thread::id> marked_thread_id_;
66 std::thread::id thread_id) { in DisabledByMarker()
|
| D | testharness.cc | 34 size_t tid = std::hash<std::thread::id>()(std::this_thread::get_id()); in PerThreadDBPath()
|
| /rocksdb-6.9/ |
| D | WINDOWS_PORT.md | 58 …on par with posix_env. This means we replicated the functionality of the thread pool and other thi…
59 * Replicate posix logic using std:thread primitives.
66 …thread-pool implementation we chose to replicate posix logic using `std::thread` primitives. This …
80 To mitigate the lack of thread local storage cleanup on thread-exit we added a limited amount of wi…
|
| /rocksdb-6.9/db/ |
| D | db_write_test.cc | 291 std::thread threads[10]; in TEST_P()
293 … threads[t] = std::thread([t, wal_key_prefix, wal_value, no_wal_key_prefix, no_wal_value, this] { in TEST_P()
|
| D | db_wal_test.cc | 202 ROCKSDB_NAMESPACE::port::Thread thread([&]() { ASSERT_OK(db_->SyncWAL()); }); in TEST_F() local
214 thread.join(); in TEST_F()
234 ROCKSDB_NAMESPACE::port::Thread thread( in TEST_F() local
242 thread.join(); in TEST_F()
588 ROCKSDB_NAMESPACE::port::Thread thread([&]() { in TEST_F() local
597 thread.join(); in TEST_F()
|
| D | db_test.cc | 2531 MTThread thread[kNumThreads]; in TEST_P() local
2533 thread[id].state = &mt; in TEST_P()
2534 thread[id].id = id; in TEST_P()
2603 GCThread thread[kGCNumThreads]; in TEST_F() local
2605 thread[id].id = id; in TEST_F()
2606 thread[id].db = db_; in TEST_F()
2607 thread[id].done = false; in TEST_F()
4079 for (auto thread : thread_list) { in VerifyOperationCount() local
4396 for (auto thread : thread_list) { in TEST_P() local
4421 for (auto thread : thread_list) { in TEST_P() local
[all …]
|