Home
last modified time | relevance | path

Searched refs:GetThreadPoolQueueLen (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/env/
Denv_test.cc105 while (env_->GetThreadPoolQueueLen(Env::Priority::LOW) != 0) { in WaitThreadPoolsEmpty()
108 while (env_->GetThreadPoolQueueLen(Env::Priority::HIGH) != 0) { in WaitThreadPoolsEmpty()
485 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
487 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) { in TEST_P()
495 env_->GetThreadPoolQueueLen()); in TEST_P()
497 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
499 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
535 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
544 env_->GetThreadPoolQueueLen()); in TEST_P()
546 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
[all …]
Denv_posix.cc225 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override;
442 unsigned int PosixEnv::GetThreadPoolQueueLen(Priority pri) const { in GetThreadPoolQueueLen() function in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv
Dcomposite_env_wrapper.h516 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
517 return env_target_->GetThreadPoolQueueLen(pri);
/rocksdb-6.9/hdfs/
Denv_hdfs.h120 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
121 return posixEnv->GetThreadPoolQueueLen(pri);
343 virtual unsigned int GetThreadPoolQueueLen(
/rocksdb-6.9/port/win/
Denv_win.h58 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const;
312 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const override;
Denv_win.cc1264 unsigned int WinEnvThreads::GetThreadPoolQueueLen(Env::Priority pri) const { in GetThreadPoolQueueLen() function in ROCKSDB_NAMESPACE::port::WinEnvThreads
1475 unsigned int WinEnv::GetThreadPoolQueueLen(Env::Priority pri) const { in GetThreadPoolQueueLen() function in ROCKSDB_NAMESPACE::port::WinEnv
1476 return winenv_threads_.GetThreadPoolQueueLen(pri); in GetThreadPoolQueueLen()
/rocksdb-6.9/java/rocksjni/
Denv.cc76 const int queue_len = rocks_env->GetThreadPoolQueueLen( in Java_org_rocksdb_Env_getThreadPoolQueueLen()
/rocksdb-6.9/include/rocksdb/
Denv.h412 virtual unsigned int GetThreadPoolQueueLen(Priority /*pri*/ = LOW) const {
1301 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
1302 return target_->GetThreadPoolQueueLen(pri);
/rocksdb-6.9/db/
Ddb_compaction_test.cc805 ASSERT_EQ(1u, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_F()
819 ASSERT_EQ(3U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_F()
850 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_F()
4655 ASSERT_EQ(cf_count, env_->GetThreadPoolQueueLen(Env::LOW)); in TEST_F()
Ddb_test.cc3824 if (options.env->GetThreadPoolQueueLen(Env::Priority::LOW) <= 1 && in TEST_F()
3825 options.env->GetThreadPoolQueueLen(Env::Priority::HIGH) <= 2) { in TEST_F()
3832 ASSERT_EQ(1U, options.env->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_F()
3834 ASSERT_EQ(2U, options.env->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_F()
/rocksdb-6.9/
DHISTORY.md1101 * Added Env::GetThreadPoolQueueLen(), which returns the waiting queue length of thread pools