Home
last modified time | relevance | path

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

123

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DDefaultEnvTest.java30 defaultEnv.setBackgroundThreads(5, Priority.BOTTOM); in backgroundThreads()
36 defaultEnv.setBackgroundThreads(5, Priority.LOW); in backgroundThreads()
39 defaultEnv.setBackgroundThreads(5, Priority.HIGH); in backgroundThreads()
59 defaultEnv.incBackgroundThreadsIfNeeded(20, Priority.LOW); in incBackgroundThreadsIfNeeded()
62 defaultEnv.incBackgroundThreadsIfNeeded(20, Priority.HIGH); in incBackgroundThreadsIfNeeded()
70 defaultEnv.lowerThreadPoolIOPriority(Priority.BOTTOM); in lowerThreadPoolIOPriority()
72 defaultEnv.lowerThreadPoolIOPriority(Priority.LOW); in lowerThreadPoolIOPriority()
74 defaultEnv.lowerThreadPoolIOPriority(Priority.HIGH); in lowerThreadPoolIOPriority()
81 defaultEnv.lowerThreadPoolCPUPriority(Priority.BOTTOM); in lowerThreadPoolCPUPriority()
83 defaultEnv.lowerThreadPoolCPUPriority(Priority.LOW); in lowerThreadPoolCPUPriority()
[all …]
/rocksdb-6.9/cache/
Dlru_cache_test.cc39 Cache::Priority priority = Cache::Priority::LOW) { in Insert()
44 void Insert(char key, Cache::Priority priority = Cache::Priority::LOW) { in Insert()
124 Insert("a", Cache::Priority::LOW); in TEST_F()
125 Insert("b", Cache::Priority::LOW); in TEST_F()
126 Insert("c", Cache::Priority::LOW); in TEST_F()
133 Insert("d", Cache::Priority::LOW); in TEST_F()
147 Insert("a", Cache::Priority::LOW); in TEST_F()
148 Insert("b", Cache::Priority::LOW); in TEST_F()
149 Insert("c", Cache::Priority::LOW); in TEST_F()
153 Insert("u", Cache::Priority::LOW); in TEST_F()
[all …]
Dlru_cache.h109 void SetPriority(Cache::Priority priority) { in SetPriority()
110 if (priority == Cache::Priority::HIGH) { in SetPriority()
215 Cache::Priority priority) override; in ALIGN_AS()
Dsharded_cache.h31 Cache::Priority priority) = 0;
75 Priority priority) override;
/rocksdb-6.9/env/
Denv_posix.cc219 int UnSchedule(void* arg, Priority pri) override;
326 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in SetBackgroundThreads()
330 int GetBackgroundThreads(Priority pri) override { in GetBackgroundThreads()
331 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in GetBackgroundThreads()
342 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in IncBackgroundThreadsIfNeeded()
347 assert(pool >= Priority::BOTTOM && pool <= Priority::HIGH); in LowerThreadPoolIOPriority()
356 assert(pool >= Priority::BOTTOM && pool <= Priority::HIGH); in LowerThreadPoolCPUPriority()
407 thread_pools_storage_(Priority::TOTAL), in PosixEnv()
416 static_cast<Env::Priority>(pool_id)); in PosixEnv()
434 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in Schedule()
[all …]
Denv_test.cc295 Env::Priority::LOW); in TEST_P()
299 Env::Priority::LOW, &sleeping_task1); in TEST_P()
573 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
578 Env::Priority::HIGH); in TEST_P()
587 env_->SetBackgroundThreads(2, Env::Priority::HIGH); in TEST_P()
595 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
611 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
620 env_->SetBackgroundThreads(7, Env::Priority::HIGH); in TEST_P()
643 Env::Priority::HIGH); in TEST_P()
692 Env::Priority::HIGH); in TEST_P()
[all …]
Denv.cc85 std::string Env::PriorityToString(Env::Priority priority) { in PriorityToString()
87 case Env::Priority::BOTTOM: in PriorityToString()
89 case Env::Priority::LOW: in PriorityToString()
91 case Env::Priority::HIGH: in PriorityToString()
93 case Env::Priority::USER: in PriorityToString()
95 case Env::Priority::TOTAL: in PriorityToString()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DEnv.java55 return setBackgroundThreads(number, Priority.LOW); in setBackgroundThreads()
66 public int getBackgroundThreads(final Priority priority) { in getBackgroundThreads()
80 public Env setBackgroundThreads(final int number, final Priority priority) { in setBackgroundThreads()
93 public int getThreadPoolQueueLen(final Priority priority) { in getThreadPoolQueueLen()
108 final Priority priority) { in incBackgroundThreadsIfNeeded()
120 public Env lowerThreadPoolIOPriority(final Priority priority) { in lowerThreadPoolIOPriority()
132 public Env lowerThreadPoolCPUPriority(final Priority priority) { in lowerThreadPoolCPUPriority()
DPriority.java11 public enum Priority { enum
19 Priority(final byte value) { in Priority() method in Priority
41 static Priority getPriority(final byte value) { in getPriority()
42 for (final Priority priority : Priority.values()) { in getPriority()
/rocksdb-6.9/port/win/
Denv_win.h49 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
52 int UnSchedule(void* arg, Env::Priority pri);
58 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const;
67 void SetBackgroundThreads(int num, Env::Priority pri);
68 int GetBackgroundThreads(Env::Priority pri);
70 void IncBackgroundThreadsIfNeeded(int num, Env::Priority pri);
303 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
306 int UnSchedule(void* arg, Env::Priority pri) override;
312 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const override;
325 void SetBackgroundThreads(int num, Env::Priority pri) override;
[all …]
Denv_win.cc1199 static_cast<Env::Priority>(pool_id)); in WinEnvThreads()
1215 Env::Priority pri, void* tag, in Schedule()
1217 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in Schedule()
1221 int WinEnvThreads::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule()
1265 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetThreadPoolQueueLen()
1281 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in SetBackgroundThreads()
1285 int WinEnvThreads::GetBackgroundThreads(Env::Priority pri) { in GetBackgroundThreads()
1286 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetBackgroundThreads()
1291 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in IncBackgroundThreadsIfNeeded()
1463 int WinEnv::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule()
[all …]
/rocksdb-6.9/hdfs/
Denv_hdfs.h104 void Schedule(void (*function)(void* arg), void* arg, Priority pri = LOW,
110 int UnSchedule(void* tag, Priority pri) override { in UnSchedule()
120 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
147 void SetBackgroundThreads(int number, Priority pri = LOW) override {
151 int GetBackgroundThreads(Priority pri = LOW) override {
155 void IncBackgroundThreadsIfNeeded(int number, Priority pri) override { in IncBackgroundThreadsIfNeeded()
333 Priority /*pri*/ = LOW, void* /*tag*/ = nullptr,
344 Priority /*pri*/ = LOW) const override {
370 Priority /*pri*/ = LOW) override {}
371 virtual int GetBackgroundThreads(Priority /*pri*/ = LOW) override {
[all …]
/rocksdb-6.9/util/
Dthreadpool_imp.cc96 Env::Priority GetThreadPriority() const { return priority_; } in GetThreadPriority()
99 void SetThreadPriority(Env::Priority priority) { priority_ = priority; } in SetThreadPriority()
106 Env::Priority priority_;
287 case Env::Priority::HIGH: in BGThreadWrapper()
290 case Env::Priority::LOW: in BGThreadWrapper()
293 case Env::Priority::BOTTOM: in BGThreadWrapper()
296 case Env::Priority::USER: in BGThreadWrapper()
299 case Env::Priority::TOTAL: in BGThreadWrapper()
493 Env::Priority ThreadPoolImpl::GetThreadPriority() const { in GetThreadPriority()
498 void ThreadPoolImpl::SetThreadPriority(Env::Priority priority) { in SetThreadPriority()
Dthread_list_test.cc136 &running_task, Env::Priority::HIGH); in TEST_F()
140 &running_task, Env::Priority::LOW); in TEST_F()
257 &flush_write_task, Env::Priority::HIGH); in TEST_F()
263 &compaction_write_task, Env::Priority::LOW); in TEST_F()
269 &compaction_read_task, Env::Priority::LOW); in TEST_F()
275 &compaction_wait_task, Env::Priority::LOW); in TEST_F()
Dthreadpool_imp.h86 Env::Priority GetThreadPriority() const;
89 void SetThreadPriority(Env::Priority priority);
/rocksdb-6.9/include/rocksdb/
Denv.h379 enum Priority { BOTTOM, LOW, HIGH, USER, TOTAL }; enum
381 static std::string PriorityToString(Priority priority);
397 Priority pri = LOW, void* tag = nullptr,
461 virtual int GetBackgroundThreads(Priority pri = LOW) = 0;
473 virtual void LowerThreadPoolIOPriority(Priority /*pool*/ = LOW) {}
1288 void Schedule(void (*f)(void* arg), void* a, Priority pri,
1293 int UnSchedule(void* tag, Priority pri) override { in UnSchedule()
1328 void SetBackgroundThreads(int num, Priority pri) override { in SetBackgroundThreads()
1331 int GetBackgroundThreads(Priority pri) override { in GetBackgroundThreads()
1343 void LowerThreadPoolIOPriority(Priority pool = LOW) override {
[all …]
Dcache.h144 enum class Priority { HIGH, LOW }; enum
182 Priority priority = Priority::LOW) = 0;
/rocksdb-6.9/utilities/simulator_cache/
Dcache_simulator.cc77 Cache::Priority PrioritizedCacheSimulator::ComputeBlockPriority( in ComputeBlockPriority()
82 return Cache::Priority::HIGH; in ComputeBlockPriority()
84 return Cache::Priority::LOW; in ComputeBlockPriority()
88 const Slice& key, uint64_t value_size, Cache::Priority priority, in AccessKVPair()
148 AccessKVPair(row_key, access.referenced_data_size, Cache::Priority::HIGH, in Access()
181 /*handle=*/nullptr, Cache::Priority::HIGH); in Access()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc144 Env::Priority thread_pri) { in FlushMemTableToOutputFile()
1546 Env::Priority thread_pool_pri = Env::Priority::LOW; in RunManualCompaction()
1549 thread_pool_pri = Env::Priority::BOTTOM; in RunManualCompaction()
1976 fta->thread_pri_ = Env::Priority::HIGH; in MaybeScheduleFlushOrCompaction()
1994 fta->thread_pri_ = Env::Priority::LOW; in MaybeScheduleFlushOrCompaction()
2154 IOSTATS_SET_THREAD_POOL_ID(Env::Priority::LOW); in BGWorkCompaction()
2159 prepicked_compaction, Env::Priority::LOW); in BGWorkCompaction()
2166 IOSTATS_SET_THREAD_POOL_ID(Env::Priority::BOTTOM); in BGWorkBottomCompaction()
2176 IOSTATS_SET_THREAD_POOL_ID(Env::Priority::HIGH); in BGWorkPurge()
2379 assert((bg_thread_pri == Env::Priority::BOTTOM && in BackgroundCallCompaction()
[all …]
/rocksdb-6.9/db/
Ddeletefile_test.cc245 &sleeping_task_before, Env::Priority::HIGH); in TEST_F()
249 &sleeping_task_after, Env::Priority::HIGH); in TEST_F()
292 &sleeping_task_after, Env::Priority::HIGH); in TEST_F()
358 &sleeping_task_after, Env::Priority::HIGH); 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()
Ddb_block_cache_test.cc447 Handle** handle, Priority priority) override { in Insert()
448 if (priority == Priority::LOW) { in Insert()
463 for (auto priority : {Cache::Priority::LOW, Cache::Priority::HIGH}) { in TEST_F()
472 priority == Cache::Priority::HIGH ? true : false; in TEST_F()
491 if (priority == Cache::Priority::LOW) { in TEST_F()
509 if (priority == Cache::Priority::LOW) { in TEST_F()
Dflush_job.h75 Env::Priority thread_pri);
159 Env::Priority thread_pri_;
Dflush_job_test.cc143 true /* write_manifest */, Env::Priority::USER); in TEST_F()
226 true /* write_manifest */, Env::Priority::USER); in TEST_F()
293 true /* write_manifest */, Env::Priority::USER); in TEST_F()
365 Env::Priority::USER)); in TEST_F()
481 true /* write_manifest */, Env::Priority::USER); in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_job.h80 Env::Priority thread_pri,
198 Env::Priority thread_pri_;
/rocksdb-6.9/db_stress_tool/
Ddb_stress_tool.cc80 ROCKSDB_NAMESPACE::Env::Priority::LOW); in db_stress_tool()
82 ROCKSDB_NAMESPACE::Env::Priority::BOTTOM); in db_stress_tool()

123