Home
last modified time | relevance | path

Searched refs:Schedule (Results 1 – 25 of 25) sorted by relevance

/rocksdb-6.9/util/
Dthread_list_test.cc135 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
139 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
256 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
262 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
268 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
274 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
Dthreadpool_imp.h71 void Schedule(void (*function)(void* arg1), void* arg, void* tag,
Dthreadpool_imp.cc473 void ThreadPoolImpl::Schedule(void(*function)(void* arg1), void* arg, in Schedule() function in ROCKSDB_NAMESPACE::ThreadPoolImpl
/rocksdb-6.9/db/
Ddeletefile_test.cc244 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
248 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
291 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
357 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
400 env_->Schedule(&DeleteFileTest::DoSleep, this, Env::Priority::HIGH); in TEST_F()
402 env_->Schedule(&DeleteFileTest::GuardFinish, nullptr, Env::Priority::HIGH); in TEST_F()
Dfault_injection_test.cc395 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
481 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
Ddb_test.cc3817 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
3994 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4029 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4052 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4849 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
4880 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
5315 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
5318 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
5939 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
6162 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
[all …]
Ddb_properties_test.cc735 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
738 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
989 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
Dcolumn_family_test.cc2431 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
2445 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
2994 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
3039 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
Ddb_compaction_test.cc783 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
832 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
2745 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
2838 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
4614 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
5184 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_tasks, in TEST_P()
Ddb_basic_test.cc361 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_F()
364 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
Ddb_universal_compaction_test.cc189 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
Ddb_test2.cc4234 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
4246 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
/rocksdb-6.9/env/
Denv_test.cc124 env_->Schedule(&SetBool, &called, static_cast<Env::Priority>(pri)); in TEST_F()
311 env_->Schedule(&SetBool, &called); in TEST_P()
351 env_->Schedule(&CB::Run, &cb1); in TEST_P()
352 env_->Schedule(&CB::Run, &cb2); in TEST_P()
353 env_->Schedule(&CB::Run, &cb3); in TEST_P()
354 env_->Schedule(&CB::Run, &cb4); in TEST_P()
479 env_->Schedule(&CB::Run, &low_pool_job); in TEST_P()
480 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
529 env_->Schedule(&CB::Run, &low_pool_job); in TEST_P()
530 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
[all …]
Denv_posix.cc215 void Schedule(void (*function)(void* arg1), void* arg, Priority pri = LOW,
432 void PosixEnv::Schedule(void (*function)(void* arg1), void* arg, Priority pri, in Schedule() function in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv
435 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()
Dcomposite_env_wrapper.h503 void Schedule(void (*f)(void* arg), void* a, Priority pri,
505 return env_target_->Schedule(f, a, pri, tag, u);
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc331 thread_pool.Schedule(&Replayer::BGWorkWriteBatch, ra.release(), nullptr, in MultiThreadReplay()
335 thread_pool.Schedule(&Replayer::BGWorkGet, ra.release(), nullptr, in MultiThreadReplay()
339 thread_pool.Schedule(&Replayer::BGWorkIterSeek, ra.release(), nullptr, in MultiThreadReplay()
343 thread_pool.Schedule(&Replayer::BGWorkIterSeekForPrev, ra.release(), in MultiThreadReplay()
/rocksdb-6.9/hdfs/
Denv_hdfs.h104 void Schedule(void (*function)(void* arg), void* arg, Priority pri = LOW,
107 posixEnv->Schedule(function, arg, pri, tag, unschedFunction);
332 virtual void Schedule(void (* /*function*/)(void* arg), void* /*arg*/,
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc600 Env::Default()->Schedule(ConcurrentReader, &state); in RunConcurrentRead()
624 Env::Default()->Schedule(ConcurrentReader, &state); in RunConcurrentInsert()
630 Env::Default()->Schedule(ConcurrentWriter, &state); in RunConcurrentInsert()
Dskiplist_test.cc367 Env::Default()->Schedule(ConcurrentReader, &state); in RunConcurrent()
/rocksdb-6.9/port/win/
Denv_win.h49 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
303 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
Denv_win.cc1214 void WinEnvThreads::Schedule(void(*function)(void*), void* arg, in Schedule() function in ROCKSDB_NAMESPACE::port::WinEnvThreads
1218 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()
1457 void WinEnv::Schedule(void(*function)(void*), void* arg, Env::Priority pri, in Schedule() function in ROCKSDB_NAMESPACE::port::WinEnv
1460 return winenv_threads_.Schedule(function, arg, pri, tag, unschedFunction); in Schedule()
/rocksdb-6.9/examples/
Dcompact_files_example.cc107 options_.env->Schedule(&FullCompactor::CompactFiles, task); in ScheduleCompaction()
/rocksdb-6.9/include/rocksdb/
Denv.h396 virtual void Schedule(void (*function)(void* arg), void* arg,
1288 void Schedule(void (*f)(void* arg), void* a, Priority pri,
1290 return target_->Schedule(f, a, pri, tag, u);
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1551 env_->Schedule(&DBImpl::BGWorkCompaction, ca, thread_pool_pri, this, in RunManualCompaction()
1977 env_->Schedule(&DBImpl::BGWorkFlush, fta, Env::Priority::HIGH, this, in MaybeScheduleFlushOrCompaction()
1995 env_->Schedule(&DBImpl::BGWorkFlush, fta, Env::Priority::LOW, this, in MaybeScheduleFlushOrCompaction()
2026 env_->Schedule(&DBImpl::BGWorkCompaction, ca, Env::Priority::LOW, this, in MaybeScheduleFlushOrCompaction()
2801 env_->Schedule(&DBImpl::BGWorkBottomCompaction, ca, Env::Priority::BOTTOM, in BackgroundCompaction()
Ddb_impl.cc1339 env_->Schedule(&DBImpl::BGWorkPurge, this, Env::Priority::HIGH, nullptr); in SchedulePurge()