Home
last modified time | relevance | path

Searched defs:thread (Results 1 – 20 of 20) sorted by relevance

/rocksdb-6.9/db_stress_tool/
Ddb_stress_common.cc84 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in PoolSizeChangeThread() local
119 auto* thread = reinterpret_cast<ThreadState*>(v); in DbVerificationThread() local
162 int64_t GenerateOneKey(ThreadState* thread, uint64_t iteration) { in GenerateOneKey()
185 std::vector<int64_t> GenerateNKeys(ThreadState* thread, int num_keys, in GenerateNKeys()
Dno_batched_ops_stress.cc103 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()
521 void TestIngestExternalFile(ThreadState* thread, in TestIngestExternalFile()
Dcf_consistency_stress.cc20 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()
116 Status TestGet(ThreadState* thread, const ReadOptions& readoptions, in TestGet()
203 ThreadState* thread, const ReadOptions& read_opts, in TestMultiGet()
237 Status TestPrefixScan(ThreadState* thread, const ReadOptions& readoptions, in TestPrefixScan()
278 ColumnFamilyHandle* GetControlCfh(ThreadState* thread, in GetControlCfh()
296 Status TestCheckpoint(ThreadState* thread, in TestCheckpoint()
Ddb_stress_test_base.cc424 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()
1182 ThreadState* thread, const std::vector<int>& rand_column_families, in TestBackupRestore()
1267 ThreadState* thread, uint64_t iteration, in TestApproximateSize()
1309 Status StressTest::TestCheckpoint(ThreadState* thread, in TestCheckpoint()
1389 void StressTest::TestCompactFiles(ThreadState* thread, in TestCompactFiles()
1445 Status StressTest::TestPauseBackground(ThreadState* thread) { in TestPauseBackground()
1461 void StressTest::TestAcquireSnapshot(ThreadState* thread, in TestAcquireSnapshot()
[all …]
Dbatched_ops_stress.cc22 Status TestPut(ThreadState* thread, WriteOptions& write_opts, in TestPut()
63 Status TestDelete(ThreadState* thread, WriteOptions& writeoptions, in TestDelete()
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()
Ddb_stress_driver.cc16 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody() local
/rocksdb-6.9/tools/
Ddb_bench_tool.cc3291 ThreadState* thread; member
3298 ThreadState* thread = arg->thread; in ThreadBody() local
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()
5414 void MixGraph(ThreadState* thread) { in MixGraph()
5886 void BGScan(ThreadState* thread) { in BGScan()
6835 void Compact(ThreadState* thread) { in Compact()
[all …]
/rocksdb-6.9/util/
Drepeatable_thread_test.cc32 ROCKSDB_NAMESPACE::RepeatableThread thread( in TEST_F() local
90 ROCKSDB_NAMESPACE::RepeatableThread thread( in TEST_F() local
Drepeatable_thread.h102 void thread() { in thread() function
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp61 for (auto& thread : threads) { in basicNThreads() local
127 for (auto& thread : threads) { in lockWithTryAndTimedNThreads() local
171 for (auto& thread : threads) { in combineNThreads() local
226 for (auto& thread : threads) { in combineWithLockNThreads() local
296 for (auto& thread : threads) { in combineWithTryLockNThreads() local
397 for (auto& thread : threads) { in combineWithLockTryAndTimedNThreads() local
686 for (auto& thread : threads) { in stressTryLockWithConcurrentLocks() local
730 for (auto& thread : threads) { in concurrentTryLocks() local
922 for (auto& thread : threads) { in concurrentLocksManyMutexes() local
1030 for (auto& thread : threads) { in concurrentExceptionPropagationStress() local
[all …]
/rocksdb-6.9/cache/
Dcache_bench.cc197 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in ThreadBody() local
221 void OperateCache(ThreadState* thread) { in OperateCache()
/rocksdb-6.9/db/
Ddb_dynamic_level_test.cc251 ROCKSDB_NAMESPACE::port::Thread thread([this] { in TEST_F() local
Ddb_wal_test.cc202 ROCKSDB_NAMESPACE::port::Thread thread([&]() { ASSERT_OK(db_->SyncWAL()); }); in TEST_F() local
234 ROCKSDB_NAMESPACE::port::Thread thread( in TEST_F() local
588 ROCKSDB_NAMESPACE::port::Thread thread([&]() { in TEST_F() local
Ddb_test.cc2531 MTThread thread[kNumThreads]; in TEST_P() local
2603 GCThread thread[kGCNumThreads]; in TEST_F() local
4079 for (auto thread : thread_list) { in VerifyOperationCount() local
4119 for (auto thread : thread_list) { in TEST_F() local
4396 for (auto thread : thread_list) { in TEST_P() local
4421 for (auto thread : thread_list) { in TEST_P() local
4483 for (auto thread : thread_list) { in TEST_P() local
4508 for (auto thread : thread_list) { in TEST_P() local
Dcolumn_family_test.cc605 ROCKSDB_NAMESPACE::port::Thread thread( in TEST_P() local
3212 ROCKSDB_NAMESPACE::port::Thread thread([&] { db_->SyncWAL(); }); in TEST_P() local
Ddb_test2.cc4270 port::Thread thread([&]() { ASSERT_OK(Flush()); }); in TEST_F() local
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc590 for (auto& thread : thread_pool) { in Run() local
679 for (auto& thread : thread_pool) { in Run() local
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc850 port::Thread thread([this]() { in TEST_F() local
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc716 port::Thread thread([this]() { ASSERT_OK(Put("key2", "val2")); }); in TEST_F() local
/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc9958 HANDLE thread = ::OpenThread(SYNCHRONIZE | THREAD_QUERY_INFORMATION, in StartWatcherThreadFor() local