| /rocksdb-6.9/util/ |
| D | thread_local_test.cc | 146 env_->StartThread(func, static_cast<void*>(&p)); in TEST_F()
221 env_->StartThread(func, static_cast<void*>(&p1)); in TEST_F()
224 env_->StartThread(func, static_cast<void*>(&p2)); in TEST_F()
270 env_->StartThread(func0, static_cast<void*>(&p)); in TEST_F()
307 env_->StartThread(func1, static_cast<void*>(&p)); in TEST_F()
356 env_->StartThread(func2, static_cast<void*>(&p)); in TEST_F()
431 env_->StartThread(func, static_cast<void*>(&p)); in TEST_F()
490 env_->StartThread(func, static_cast<void*>(¶ms)); in TEST_F()
|
| D | rate_limiter_test.cc | 105 env->StartThread(writer, &arg); in TEST_F()
165 env->StartThread(writer, &arg); in TEST_F()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_driver.cc | 72 db_stress_env->StartThread(ThreadBody, threads[i]); in RunStressTest()
76 db_stress_env->StartThread(PoolSizeChangeThread, &bg_thread); in RunStressTest()
80 db_stress_env->StartThread(DbVerificationThread, in RunStressTest()
|
| /rocksdb-6.9/tools/ |
| D | db_repl_stress.cc | 128 env->StartThread(DataPumpThreadBody, &dataPump); in main()
135 env->StartThread(ReplicationThreadBody, &replThread); in main()
|
| D | db_bench_tool.cc | 3374 FLAGS_env->StartThread(ThreadBody, &arg[i]); in RunBenchmark()
|
| /rocksdb-6.9/hdfs/ |
| D | env_hdfs.h | 114 void StartThread(void (*function)(void* arg), void* arg) override { in StartThread() function
115 posixEnv->StartThread(function, arg); in StartThread()
338 virtual void StartThread(void (* /*function*/)(void* arg), in StartThread() function
|
| /rocksdb-6.9/port/win/ |
| D | env_win.h | 54 void StartThread(void(*function)(void* arg), void* arg);
308 void StartThread(void(*function)(void* arg), void* arg) override;
|
| D | env_win.cc | 1241 void WinEnvThreads::StartThread(void(*function)(void* arg), void* arg) { in StartThread() function in ROCKSDB_NAMESPACE::port::WinEnvThreads
1467 void WinEnv::StartThread(void(*function)(void* arg), void* arg) { in StartThread() function in ROCKSDB_NAMESPACE::port::WinEnv
1468 return winenv_threads_.StartThread(function, arg); in StartThread()
|
| /rocksdb-6.9/env/ |
| D | env_posix.cc | 221 void StartThread(void (*function)(void* arg), void* arg) override;
459 void PosixEnv::StartThread(void (*function)(void* arg), void* arg) { in StartThread() function in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv
|
| D | env_test.cc | 132 env_->StartThread(&SetBool, &called); in TEST_F()
377 TEST_P(EnvPosixTestWithParam, StartThread) { in TEST_P() argument
382 env_->StartThread(&ThreadBody, &state); in TEST_P()
|
| D | composite_env_wrapper.h | 512 void StartThread(void (*f)(void*), void* a) override { in StartThread() function
513 return env_target_->StartThread(f, a); in StartThread()
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 163 env->StartThread(ThreadBody, threads[i]); in Run()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | hash_table_bench.cc | 135 env->StartThread(fn, this); in StartThreads()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env.h | 406 virtual void StartThread(void (*function)(void* arg), void* arg) = 0;
1297 void StartThread(void (*f)(void*), void* a) override { in StartThread() function
1298 return target_->StartThread(f, a); in StartThread()
|
| /rocksdb-6.9/db/ |
| D | db_test.cc | 2536 env_->StartThread(MTThreadBody, &thread[id]); in TEST_P()
2608 env_->StartThread(GCThreadBody, &thread[id]); in TEST_F()
|