| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Env.java | 66 public int getBackgroundThreads(final Priority priority) { in getBackgroundThreads() argument
93 public int getThreadPoolQueueLen(final Priority priority) { in getThreadPoolQueueLen() argument
108 final Priority priority) { in incBackgroundThreadsIfNeeded() argument
120 public Env lowerThreadPoolIOPriority(final Priority priority) { in lowerThreadPoolIOPriority() argument
121 lowerThreadPoolIOPriority(nativeHandle_, priority.getValue()); in lowerThreadPoolIOPriority()
154 final long handle, final int number, final byte priority); in setBackgroundThreads() argument
156 final byte priority); in getBackgroundThreads() argument
158 final byte priority); in getThreadPoolQueueLen() argument
160 final int number, final byte priority); in incBackgroundThreadsIfNeeded() argument
162 final byte priority); in lowerThreadPoolIOPriority() argument
[all …]
|
| D | Priority.java | 42 for (final Priority priority : Priority.values()) { in getPriority()
43 if (priority.getValue() == value){ in getPriority()
44 return priority; in getPriority()
|
| /rocksdb-6.9/cache/ |
| D | lru_cache_test.cc | 39 Cache::Priority priority = Cache::Priority::LOW) { in Insert() argument
41 nullptr /*deleter*/, nullptr /*handle*/, priority); in Insert()
44 void Insert(char key, Cache::Priority priority = Cache::Priority::LOW) { in Insert() argument
45 Insert(std::string(1, key), priority); in Insert()
|
| D | lru_cache.h | 109 void SetPriority(Cache::Priority priority) { in SetPriority()
110 if (priority == Cache::Priority::HIGH) { in SetPriority()
215 Cache::Priority priority) override; in ALIGN_AS()
|
| D | sharded_cache.h | 31 Cache::Priority priority) = 0;
75 Priority priority) override;
|
| D | sharded_cache.cc | 48 Priority priority) { in Insert() argument
51 ->Insert(key, hash, value, charge, deleter, handle, priority); in Insert()
|
| D | lru_cache.cc | 341 Cache::Handle** handle, Cache::Priority priority) { in Insert() argument
359 e->SetPriority(priority); in Insert()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2016-01-29-compaction_pri.markdown | 24 We created a compaction priority **kOldestSmallestSeqFirst** for the same effect. With this mode, w…
30 The compaction priority **kOldestLargestSeqFirst** optimizes this use case. In this mode, we will p…
36 Our default compaction priority **kByCompensatedSize** considers the case. If number of deletes in …
40 …o compact may impact space efficiency. We don't yet have a a compaction priority to optimize this …
43 In all, there three choices of compaction priority modes optimizing different scenarios. if you hav…
51 …m.blogspot.com/2016/02/compaction-priority-in-rocksdb.html](http://smalldatum.blogspot.com/2016/02…
|
| D | 2017-07-25-rocksdb-5-6-1-released.markdown | 18 * Introduce WriteOptions.low_pri. If it is true, low priority writes will be throttled if the compa…
|
| D | 2016-09-28-rocksdb-4-11-2-released.markdown | 47 …reground when destroying iterators. Instead, a job is scheduled in high priority queue and would b…
|
| /rocksdb-6.9/db/ |
| D | db_block_cache_test.cc | 447 Handle** handle, Priority priority) override { in Insert() argument
448 if (priority == Priority::LOW) { in Insert()
453 return LRUCache::Insert(key, value, charge, deleter, handle, priority); 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()
|
| D | internal_stats.cc | 1171 for (size_t priority = 0; priority < comp_stats_by_pri_.size(); priority++) { in DumpCFMapStatsByPriority() local
1172 if (comp_stats_by_pri_[priority].micros > 0) { in DumpCFMapStatsByPriority()
1177 comp_stats_by_pri_[priority]); in DumpCFMapStatsByPriority()
1178 (*priorities_stats)[static_cast<int>(priority)] = priority_stats; in DumpCFMapStatsByPriority()
1273 for (size_t priority = 0; priority < comp_stats_by_pri_.size(); ++priority) { in DumpCFStatsNoFileHistogram() local
1274 if (priorities_stats.find(static_cast<int>(priority)) != in DumpCFStatsNoFileHistogram()
1278 Env::PriorityToString(static_cast<Env::Priority>(priority)), in DumpCFStatsNoFileHistogram()
1279 priorities_stats[static_cast<int>(priority)]); in DumpCFStatsNoFileHistogram()
|
| /rocksdb-6.9/port/ |
| D | port_posix.cc | 234 void SetCpuPriority(ThreadId id, CpuPriority priority) { in SetCpuPriority() argument
238 switch (priority) { in SetCpuPriority()
259 (void)priority; in SetCpuPriority()
|
| D | port_posix.h | 220 extern void SetCpuPriority(ThreadId id, CpuPriority priority);
|
| /rocksdb-6.9/util/ |
| D | threadpool_imp.cc | 99 void SetThreadPriority(Env::Priority priority) { priority_ = priority; } in SetThreadPriority()
498 void ThreadPoolImpl::SetThreadPriority(Env::Priority priority) { in SetThreadPriority() argument
499 impl_->SetThreadPriority(priority); in SetThreadPriority()
|
| D | threadpool_imp.h | 89 void SetThreadPriority(Env::Priority priority);
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | sim_cache.cc | 172 Handle** handle, Priority priority) override { in Insert() argument
179 key_only_cache_->Insert(key, nullptr, charge, nullptr, nullptr, priority); in Insert()
188 return cache_->Insert(key, value, charge, deleter, handle, priority); in Insert()
|
| D | cache_simulator.cc | 88 const Slice& key, uint64_t value_size, Cache::Priority priority, in AccessKVPair() argument
104 /*handle=*/nullptr, priority); in AccessKVPair()
|
| D | cache_simulator.h | 138 Cache::Priority priority,
|
| /rocksdb-6.9/port/win/ |
| D | port_win.cc | 267 void SetCpuPriority(ThreadId id, CpuPriority priority) { in SetCpuPriority() argument
270 (void)priority; in SetCpuPriority()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 1846 std::atomic<CpuPriority> priority(CpuPriority::kNormal); in TEST_F() local
1849 priority.store(*reinterpret_cast<CpuPriority*>(new_priority)); in TEST_F()
1865 ASSERT_EQ(priority, CpuPriority::kNormal); in TEST_F()
1877 ASSERT_EQ(priority, CpuPriority::kLow); in TEST_F()
1890 ASSERT_EQ(priority, CpuPriority::kLow); in TEST_F()
1902 ASSERT_EQ(priority, CpuPriority::kIdle); in TEST_F()
1909 priority = CpuPriority::kNormal; in TEST_F()
1917 ASSERT_EQ(priority, CpuPriority::kNormal); in TEST_F()
|
| D | backupable_db.cc | 754 CpuPriority priority = threads_cpu_priority_; in Initialize() local
755 if (current_priority != priority) { in Initialize()
757 "BackupEngineImpl::Initialize:SetCpuPriority", &priority); in Initialize()
758 port::SetCpuPriority(0, priority); in Initialize()
759 current_priority = priority; in Initialize()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim.py | 1244 def __init__(self, key, value_size, priority): argument
1247 self.priority = priority
1251 if other.priority != self.priority:
1252 return self.priority - other.priority
1300 self.L = evict_entry.priority
|
| /rocksdb-6.9/include/rocksdb/ |
| D | cache.h | 182 Priority priority = Priority::LOW) = 0;
|
| /rocksdb-6.9/env/ |
| D | env.cc | 85 std::string Env::PriorityToString(Env::Priority priority) { in PriorityToString() argument
86 switch (priority) { in PriorityToString()
|