| /rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/ |
| D | DbBenchmark.java | 179 tid_ = tid; in BenchmarkTask()
180 rand_ = new Random(randSeed + tid * 1000); in BenchmarkTask()
183 stats_ = new Stats(tid); in BenchmarkTask()
214 super(tid, randSeed, numEntries, keyRange); in WriteTask()
223 super(tid, randSeed, numEntries, keyRange); in WriteTask()
291 super(tid, randSeed, numEntries, keyRange, in WriteSequentialTask()
298 super(tid, randSeed, numEntries, keyRange, in WriteSequentialTask()
311 super(tid, randSeed, numEntries, keyRange, in WriteRandomTask()
318 super(tid, randSeed, numEntries, keyRange, in WriteRandomTask()
332 super(tid, randSeed, numEntries, keyRange, in WriteUniqueRandomTask()
[all …]
|
| /rocksdb-6.9/env/ |
| D | env_posix.cc | 139 for (const auto tid : threads_to_join_) { in ~PosixEnv() local
140 pthread_join(tid, nullptr); in ~PosixEnv()
246 static uint64_t gettid(pthread_t tid) { in gettid() argument
248 memcpy(&thread_id, &tid, std::min(sizeof(thread_id), sizeof(tid))); in gettid()
253 pthread_t tid = pthread_self(); in gettid() local
254 return gettid(tid); in gettid()
472 for (const auto tid : threads_to_join_) { in WaitForJoin() local
473 pthread_join(tid, nullptr); in WaitForJoin()
|
| /rocksdb-6.9/test_util/ |
| D | testharness.cc | 34 size_t tid = std::hash<std::thread::id>()(std::this_thread::get_id()); in PerThreadDBPath() local
35 return dir + "/" + name + "_" + std::to_string(tid); in PerThreadDBPath()
|
| /rocksdb-6.9/db/ |
| D | db_flush_test.cc | 152 std::thread::id tid; in TEST_F() local
156 if (tid == std::thread::id()) { in TEST_F()
157 tid = std::this_thread::get_id(); in TEST_F()
159 ASSERT_EQ(tid, std::this_thread::get_id()); in TEST_F()
165 ASSERT_EQ(tid, std::this_thread::get_id()); in TEST_F()
|
| D | db_compaction_test.cc | 277 for (int tid = 0; tid < 3; ++tid) { in TEST_P() local
282 if (tid == 1) { in TEST_P()
286 } else if (tid == 2) { in TEST_P()
325 for (int tid = 0; tid < 3; ++tid) { in TEST_P() local
331 if (tid == 1) { in TEST_P()
333 } else if (tid == 2) { in TEST_P()
540 for (int tid = 0; tid < 2; ++tid) { in TEST_P() local
545 if (tid == 1) { in TEST_P()
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 118 uint32_t tid; member
123 : tid(index), rnd(1000 + index), shared(_shared) {} in ThreadState()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.cc | 544 if (thread->tid == 0 && FLAGS_verify_db_one_in > 0 && in OperateDb()
737 uint32_t tid = thread->tid; in OperateDb() local
739 static_cast<size_t>(tid) < secondaries_.size()); in OperateDb()
741 Status s = secondaries_[tid]->TryCatchUpWithPrimary(); in OperateDb()
1188 std::string backup_dir = FLAGS_db + "/.backup" + ToString(thread->tid); in TestBackupRestore()
1189 std::string restore_dir = FLAGS_db + "/.restore" + ToString(thread->tid); in TestBackupRestore()
1317 FLAGS_db + "/.checkpoint" + ToString(thread->tid); in TestCheckpoint()
1484 if (FLAGS_compare_full_db_state_snapshot && (thread->tid == 0)) { in TestAcquireSnapshot()
|
| D | db_stress_shared_state.h | 365 uint32_t tid; // 0..n-1 member
387 : tid(index), rand(1000 + index + _shared->GetSeed()), shared(_shared) {} in ThreadState()
|
| D | no_batched_ops_stress.cc | 25 int64_t start = keys_per_thread * thread->tid; in VerifyDb()
29 if (thread->tid == shared->GetNumThreads() - 1) { in VerifyDb()
526 FLAGS_db + "/." + ToString(thread->tid) + ".sst"; in TestIngestExternalFile()
|
| D | cf_consistency_stress.cc | 300 FLAGS_db + "/.checkpoint" + ToString(thread->tid); in TestCheckpoint()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_transaction_test.cc | 175 size_t tid = std::hash<std::thread::id>()(std::this_thread::get_id()); in TEST_P() local
176 Random64 rnd(static_cast<uint32_t>(tid)); in TEST_P()
|
| D | transaction_test.cc | 817 size_t tid = std::hash<std::thread::id>()(std::this_thread::get_id()); in TEST_P() local
818 Random rnd(static_cast<uint32_t>(tid)); in TEST_P()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 2239 int tid; // 0..n-1 when running in n threads member
2245 : tid(index), in ThreadState()
3312 thread->stats.Start(thread->tid); in ThreadBody()
5621 if (thread->tid > 0) { in IteratorCreationWhileWriting()
5744 if (thread->tid > 0) { in SeekRandomWhileWriting()
5752 if (thread->tid > 0) { in SeekRandomWhileMerging()
5793 if (thread->tid > 0) { in ReadWhileWriting()
5801 if (thread->tid > 0) { in ReadWhileMerging()
5879 if (thread->tid > 0) { in ReadWhileScanning()
6397 thread->stats.Start(thread->tid); in WriteSeqSeekSeq()
[all …]
|