| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.h | 35 void OperateDb(ThreadState* thread);
36 virtual void VerifyDb(ThreadState* thread) const = 0;
43 ThreadState::SnapshotState& snap_state);
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);
192 ThreadState* thread, uint64_t iteration,
[all …]
|
| D | db_stress_driver.cc | 16 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody()
69 std::vector<ThreadState*> threads(n); 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()
|
| D | cf_consistency_stress.cc | 20 Status TestPut(ThreadState* thread, WriteOptions& write_opts, in TestPut()
52 Status TestDelete(ThreadState* thread, WriteOptions& write_opts, in TestDelete()
73 Status TestDeleteRange(ThreadState* thread, WriteOptions& write_opts, in TestDeleteRange()
105 ThreadState* /* thread */, in TestIngestExternalFile() argument
116 Status TestGet(ThreadState* thread, const ReadOptions& readoptions, in TestGet()
203 ThreadState* thread, const ReadOptions& read_opts, in TestMultiGet()
278 ColumnFamilyHandle* GetControlCfh(ThreadState* thread, in GetControlCfh()
286 Status TestCheckpoint(ThreadState* /* thread */, in TestCheckpoint() argument
296 Status TestCheckpoint(ThreadState* thread, in TestCheckpoint()
349 void VerifyDb(ThreadState* thread) const override { in VerifyDb()
[all …]
|
| D | batched_ops_stress.cc | 22 Status TestPut(ThreadState* thread, WriteOptions& write_opts, in TestPut()
63 Status TestDelete(ThreadState* thread, WriteOptions& writeoptions, in TestDelete()
89 Status TestDeleteRange(ThreadState* /* thread */, in TestDeleteRange() argument
101 ThreadState* /* thread */, in TestIngestExternalFile() argument
117 Status TestGet(ThreadState* thread, const ReadOptions& readoptions, in TestGet()
173 ThreadState* thread, const ReadOptions& readoptions, in TestMultiGet()
248 Status TestPrefixScan(ThreadState* thread, const ReadOptions& readoptions, in TestPrefixScan()
335 void VerifyDb(ThreadState* /* thread */) const override {} in VerifyDb()
|
| D | db_stress_common.cc | 84 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in PoolSizeChangeThread()
119 auto* thread = reinterpret_cast<ThreadState*>(v); in DbVerificationThread()
162 int64_t GenerateOneKey(ThreadState* thread, uint64_t iteration) { in GenerateOneKey()
185 std::vector<int64_t> GenerateNKeys(ThreadState* thread, int num_keys, in GenerateNKeys()
|
| D | no_batched_ops_stress.cc | 20 void VerifyDb(ThreadState* thread) const override { in VerifyDb()
103 void MaybeClearOneColumnFamily(ThreadState* thread) override { in MaybeClearOneColumnFamily()
140 Status TestGet(ThreadState* thread, const ReadOptions& read_opts, in TestGet()
163 ThreadState* thread, const ReadOptions& read_opts, in TestMultiGet()
263 Status TestPrefixScan(ThreadState* thread, const ReadOptions& read_opts, in TestPrefixScan()
302 Status TestPut(ThreadState* thread, WriteOptions& write_opts, in TestPut()
381 Status TestDelete(ThreadState* thread, WriteOptions& write_opts, in TestDelete()
457 Status TestDeleteRange(ThreadState* thread, WriteOptions& write_opts, in TestDeleteRange()
510 ThreadState* /* thread */, in TestIngestExternalFile() argument
521 void TestIngestExternalFile(ThreadState* thread, in TestIngestExternalFile()
|
| D | db_stress_test_base.cc | 424 Status StressTest::SetOptions(ThreadState* thread) { in SetOptions()
488 void StressTest::OperateDb(ThreadState* thread) { in OperateDb()
814 Status StressTest::TestIterate(ThreadState* thread, in TestIterate()
1022 void StressTest::VerifyIterator(ThreadState* thread, in VerifyIterator()
1151 ThreadState* /* thread */, in TestBackupRestore() argument
1162 ThreadState* /* thread */, in TestCheckpoint() argument
1267 ThreadState* thread, uint64_t iteration, in TestApproximateSize()
1309 Status StressTest::TestCheckpoint(ThreadState* thread, in TestCheckpoint()
1389 void StressTest::TestCompactFiles(ThreadState* thread, in TestCompactFiles()
1498 ThreadState::SnapshotState snap_state = { in TestAcquireSnapshot()
[all …]
|
| D | db_stress_shared_state.h | 364 struct ThreadState { struct
386 ThreadState(uint32_t index, SharedState* _shared) in ThreadState() argument
|
| D | db_stress_common.h | 502 extern int64_t GenerateOneKey(ThreadState* thread, uint64_t iteration);
504 extern std::vector<int64_t> GenerateNKeys(ThreadState* thread, int num_keys,
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 117 struct ThreadState { struct
122 ThreadState(uint32_t index, SharedState* _shared) in ThreadState() argument
160 std::vector<ThreadState*> threads(num_threads_); in Run()
162 threads[i] = new ThreadState(i, &shared); in Run()
197 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody()
221 void OperateCache(ThreadState* thread) { in OperateCache()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 2238 struct ThreadState { struct
3291 ThreadState* thread;
3298 ThreadState* thread = arg->thread; in ThreadBody()
3404 void Crc32c(ThreadState* thread) { in Crc32c()
3425 void xxHash(ThreadState* thread) { in xxHash()
3460 void Compress(ThreadState *thread) { in Compress()
4266 void WriteSeq(ThreadState* thread) { in WriteSeq()
4320 DB* SelectDB(ThreadState* thread) { in SelectDB()
5886 void BGScan(ThreadState* thread) { in BGScan()
6835 void Compact(ThreadState* thread) { in Compact()
[all …]
|