Home
last modified time | relevance | path

Searched refs:UnSchedule (Results 1 – 10 of 10) sorted by relevance

/rocksdb-6.9/util/
Dthreadpool_imp.cc73 int UnSchedule(void* arg);
390 int ThreadPoolImpl::Impl::UnSchedule(void* arg) { in UnSchedule() function in ROCKSDB_NAMESPACE::ThreadPoolImpl::Impl
483 int ThreadPoolImpl::UnSchedule(void* arg) { in UnSchedule() function in ROCKSDB_NAMESPACE::ThreadPoolImpl
484 return impl_->UnSchedule(arg); in UnSchedule()
Dthreadpool_imp.h78 int UnSchedule(void* tag);
/rocksdb-6.9/hdfs/
Denv_hdfs.h110 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() function
111 return posixEnv->UnSchedule(tag, pri); in UnSchedule()
336 virtual int UnSchedule(void* /*tag*/, Priority /*pri*/) override { return 0; } in UnSchedule() function
/rocksdb-6.9/env/
Denv_posix.cc219 int UnSchedule(void* arg, Priority pri) override;
438 int PosixEnv::UnSchedule(void* arg, Priority pri) { in UnSchedule() function in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv
439 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
Denv_test.cc288 TEST_P(EnvPosixTestWithParam, UnSchedule) { in TEST_P() argument
302 ASSERT_EQ(0, env_->UnSchedule(&called, Env::Priority::LOW)); in TEST_P()
305 ASSERT_EQ(1, env_->UnSchedule(&sleeping_task1, Env::Priority::LOW)); in TEST_P()
Dcomposite_env_wrapper.h508 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() function
509 return env_target_->UnSchedule(tag, pri); in UnSchedule()
/rocksdb-6.9/port/win/
Denv_win.h52 int UnSchedule(void* arg, Env::Priority pri);
306 int UnSchedule(void* arg, Env::Priority pri) override;
Denv_win.cc1221 int WinEnvThreads::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule() function in ROCKSDB_NAMESPACE::port::WinEnvThreads
1222 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
1463 int WinEnv::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule() function in ROCKSDB_NAMESPACE::port::WinEnv
1464 return winenv_threads_.UnSchedule(arg, pri); in UnSchedule()
/rocksdb-6.9/include/rocksdb/
Denv.h402 virtual int UnSchedule(void* /*arg*/, Priority /*pri*/) { return 0; } in UnSchedule() function
1293 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() function
1294 return target_->UnSchedule(tag, pri); in UnSchedule()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc459 env_->UnSchedule(this, Env::Priority::BOTTOM); in CloseHelper()
460 int compactions_unscheduled = env_->UnSchedule(this, Env::Priority::LOW); in CloseHelper()
461 int flushes_unscheduled = env_->UnSchedule(this, Env::Priority::HIGH); in CloseHelper()