| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim_test.py | 245 cache,
253 cache.access(k4)
290 def test_mix(cache): argument
338 assert cache.used_size <= cache.cache_size
419 assert cache.used_size <= cache.cache_size
506 cache.access(k)
515 cache.access(k)
529 cache.access(k)
566 cache.access(k)
573 cache.access(k)
[all …]
|
| D | block_cache_pysim.py | 1669 cache, argument
1814 cache.access(record)
1838 cache.cache_size,
1857 cache.cache_size,
1866 cache, argument
1887 cache.miss_ratio_stats,
1888 cache.per_hour_miss_ratio_stats,
1930 if not cache.is_ml_cache():
1933 policy_stats = [cache.policy_stats, cache.per_hour_policy_stats]
1986 cache,
[all …]
|
| /rocksdb-6.9/env/ |
| D | io_posix_test.cc | 36 ASSERT_EQ(0, cache.Size()); in TEST_F()
46 ASSERT_EQ(3, cache.Size()); in TEST_F()
47 ASSERT_TRUE(cache.Contains("/")); in TEST_F()
48 ASSERT_TRUE(cache.Contains("/db1")); in TEST_F()
49 ASSERT_TRUE(cache.Contains("/db2")); in TEST_F()
71 ASSERT_EQ(4, cache.Size()); in TEST_F()
72 ASSERT_TRUE(cache.Contains("/")); in TEST_F()
73 ASSERT_TRUE(cache.Contains("/db1")); in TEST_F()
74 ASSERT_TRUE(cache.Contains("/db2")); in TEST_F()
75 ASSERT_TRUE(cache.Contains("/db")); in TEST_F()
[all …]
|
| /rocksdb-6.9/cache/ |
| D | cache_test.cc | 111 cache->Release(handle); in Lookup()
175 cache->EraseUnRefEntries(); in TEST_P()
224 cache->Release(handle); in TEST_P()
267 cache->Release(handle); in TEST_P()
458 cache->Erase("foo"); in TEST_P()
466 ASSERT_OK(cache->Insert("bar", cache.get(), 1, &erase_deleter)); in TEST_P()
467 cache->Erase("bar"); in TEST_P()
582 cache->SetCapacity(10); in TEST_P()
603 cache->SetCapacity(7); in TEST_P()
699 cache->SetCapacity(n); in TEST_P()
[all …]
|
| D | cache_test.cc.d | 1 cache/cache_test.cc.d cache/cache_test.o: cache/cache_test.cc \
2 include/rocksdb/cache.h include/rocksdb/memory_allocator.h \
5 include/rocksdb/statistics.h cache/clock_cache.h cache/lru_cache.h \
6 cache/sharded_cache.h port/port.h port/port_posix.h \
14 util/hash.h port/malloc.h util/autovector.h cache/simple_deleter.h \
|
| D | lru_cache.cc.d | 1 cache/lru_cache.cc.d cache/lru_cache.o: cache/lru_cache.cc \
2 cache/lru_cache.h cache/sharded_cache.h port/port.h port/port_posix.h \
12 include/rocksdb/cache.h include/rocksdb/memory_allocator.h \
|
| D | clock_cache.cc.d | 1 cache/clock_cache.cc.d cache/clock_cache.o: cache/clock_cache.cc \
2 cache/clock_cache.h include/rocksdb/cache.h \
|
| D | sharded_cache.cc.d | 1 cache/sharded_cache.cc.d cache/sharded_cache.o: cache/sharded_cache.cc \
2 cache/sharded_cache.h port/port.h port/port_posix.h \
12 include/rocksdb/cache.h include/rocksdb/memory_allocator.h \
|
| D | cache_bench.cc.d | 1 cache/cache_bench.cc.d cache/cache_bench.o: cache/cache_bench.cc
|
| /rocksdb-6.9/memtable/ |
| D | write_buffer_manager_test.cc | 59 std::shared_ptr<Cache> cache = NewLRUCache(co); in TEST_F() local
62 new WriteBufferManager(50 * 1024 * 1024, cache)); in TEST_F()
66 ASSERT_GE(cache->GetPinnedUsage(), 2 * 256 * 1024); in TEST_F()
71 ASSERT_GE(cache->GetPinnedUsage(), 4 * 256 * 1024); in TEST_F()
76 ASSERT_GE(cache->GetPinnedUsage(), 11 * 1024 * 1024); in TEST_F()
81 ASSERT_GE(cache->GetPinnedUsage(), 11 * 1024 * 1024); in TEST_F()
88 ASSERT_GE(cache->GetPinnedUsage(), 51 * 1024 * 1024); in TEST_F()
95 ASSERT_GE(cache->GetPinnedUsage(), 51 * 1024 * 1024); in TEST_F()
128 ASSERT_LT(cache->GetPinnedUsage(), 1024 * 1024); in TEST_F()
138 ASSERT_GE(cache->GetPinnedUsage(), 10 * 1024 * 1024); in TEST_F()
[all …]
|
| D | write_buffer_manager.cc | 32 explicit CacheRep(std::shared_ptr<Cache> cache) in CacheRep()
33 : cache_(cache), cache_allocated_size_(0) { in CacheRep()
52 std::shared_ptr<Cache> cache) in WriteBufferManager() argument
59 if (cache) { in WriteBufferManager()
61 cache_rep_.reset(new CacheRep(cache)); in WriteBufferManager()
64 (void)cache; in WriteBufferManager()
|
| /rocksdb-6.9/CMakeFiles/cache_bench.dir/ |
| D | build.make | 72 CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o: CMakeFiles/cache_bench.dir/flags.make
73 CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o: cache/cache_bench.cc
74 CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o: CMakeFiles/cache_bench.dir/compiler_depend.ts
76 …cache/cache_bench.cc.o -MF CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o.d -o CMakeFiles/cache…
78 CMakeFiles/cache_bench.dir/cache/cache_bench.cc.i: cmake_force
79 …h=$(COLOR)" --green "Preprocessing CXX source to CMakeFiles/cache_bench.dir/cache/cache_bench.cc.i"
80 …DES) $(CXX_FLAGS) -E /rdbg-bench/src/rocksdb-6.9/cache/cache_bench.cc > CMakeFiles/cache_bench.dir…
82 CMakeFiles/cache_bench.dir/cache/cache_bench.cc.s: cmake_force
84 …ES) $(CXX_FLAGS) -S /rdbg-bench/src/rocksdb-6.9/cache/cache_bench.cc -o CMakeFiles/cache_bench.dir…
88 "CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o"
[all …]
|
| D | DependInfo.cmake | 11 …nch/src/rocksdb-6.9/cache/cache_bench.cc" "CMakeFiles/cache_bench.dir/cache/cache_bench.cc.o" "gcc…
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-05-12-partitioned-index-filter.markdown | 8 …cache, their relatively large size negatively affects the performance by i) occupying the block ca…
12 …ST lifetime, not so much when they compete with data blocks for the block cache space and are also…
16 …cache they are effectively competing with data blocks (as well as with each other) on this scarce …
18 After the cache miss of an index/filter, it has to be reloaded from the disk, and its large size is…
22 …cache the partitions that are required to perform the index/filter query. The top-level index, whi…
28 …de with 100TB of data by using direct IO (skipping OS file cache) and a very small block cache of …
32 …S file cache) and block cache of size 6G and 2G. Without partitioning the linkbench throughput dro…
|
| D | 2017-05-14-core-local-stats.markdown | 12 …cache line bouncing of atomics caused high CPU utilization. For example, we have tickers that coun…
16 …2 reader threads where most reads (99%+) are served by uncompressed block cache. Such a scenario s…
28 Perf snippet for "cache-misses" event:
36 The high CPU overhead for updating tickers and histograms corresponds well to the high cache misses.
40 …l set of atomic values that no other thread can update. This prevents the cache line bouncing prob…
46 …roved 7.8x compared to global atomics, corresponding to a 17.8x reduction in cache-misses overhead.
56 Perf snippet for "cache-misses" event:
77 …y to thread-local, each core updates only its local values, thus avoiding cache line bouncing. Loc…
81 …ame as before. CPU overhead worsened ~23% compared to thread-local, while cache performance was un…
91 Perf snippet for "cache-misses" event:
|
| D | 2018-08-23-data-block-hash-index.markdown | 43 …sing and comparison are needed. Each binary search branching triggers CPU cache miss, causing much…
82 …cache space, making the effective data block cache size smaller and increasing the data block cach…
108 …cache space pressure. In the following test, we use `db_bench` with RocksDB deployed on SSDs. The …
113 
115 …cache size is greater than 8GB, hash index can bring throughput gain. Cache size greater than 8GB …
|
| /rocksdb-6.9/db/ |
| D | db_block_cache_test.cc | 157 table_options.block_cache = cache; in TEST_F()
165 ASSERT_EQ(0, cache->GetUsage()); in TEST_F()
168 ASSERT_LT(0, cache->GetUsage()); in TEST_F()
171 ASSERT_EQ(0, cache->GetUsage()); in TEST_F()
181 table_options.block_cache = cache; in TEST_F()
197 size_t usage = cache->GetUsage(); in TEST_F()
199 cache->SetCapacity(usage); in TEST_F()
236 table_options.block_cache = cache; in TEST_F()
254 size_t usage = cache->GetUsage(); in TEST_F()
264 cache->SetCapacity(usage); in TEST_F()
[all …]
|
| /rocksdb-6.9/table/block_based/ |
| D | cachable_entry.h | 46 CachableEntry(T* value, Cache* cache, Cache::Handle* cache_handle, in CachableEntry() argument
49 , cache_(cache) in CachableEntry()
164 void SetCachedValue(T* value, Cache* cache, Cache::Handle* cache_handle) { in SetCachedValue() argument
166 assert(cache != nullptr); in SetCachedValue()
169 if (UNLIKELY(value_ == value && cache_ == cache && in SetCachedValue()
177 cache_ = cache; in SetCachedValue()
200 Cache* const cache = static_cast<Cache*>(arg1); in ReleaseCacheHandle() local
201 assert(cache); in ReleaseCacheHandle()
206 cache->Release(cache_handle); in ReleaseCacheHandle()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_bench.cc | 67 std::unique_ptr<PersistentCacheTier> cache(new BlockCacheTier(opt)); in NewBlockCache() local
68 Status status = cache->Open(); in NewBlockCache()
69 return cache; in NewBlockCache()
114 : cache_(cache) { in CacheTierBenchmark()
332 std::shared_ptr<ROCKSDB_NAMESPACE::PersistentCacheTier> cache; in main() local
335 cache = ROCKSDB_NAMESPACE::NewBlockCache(); in main()
338 cache = ROCKSDB_NAMESPACE::NewVolatileCache(); in main()
341 cache = ROCKSDB_NAMESPACE::NewTieredCache(); in main()
346 assert(cache); in main()
347 if (!cache) { in main()
[all …]
|
| D | persistent_cache_test.cc | 133 auto cache = NewTieredCache(max_volatile_cache_size, opt); in NewTieredCache() local
134 return cache; in NewTieredCache()
290 std::shared_ptr<PersistentCache> cache; in TEST_F() local
293 &cache)); in TEST_F()
294 ASSERT_TRUE(cache); in TEST_F()
295 ASSERT_EQ(cache->Stats().size(), 1); in TEST_F()
296 ASSERT_TRUE(cache->Stats()[0].size()); in TEST_F()
297 cache.reset(); in TEST_F()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | persistent_cache.cc | 35 auto* cache = in Java_org_rocksdb_PersistentCache_newPersistentCache() local
39 static_cast<bool>(joptimized_for_nvm), cache); in Java_org_rocksdb_PersistentCache_newPersistentCache()
43 return reinterpret_cast<jlong>(cache); in Java_org_rocksdb_PersistentCache_newPersistentCache()
53 auto* cache = in Java_org_rocksdb_PersistentCache_disposeInternal() local
56 delete cache; // delete std::shared_ptr in Java_org_rocksdb_PersistentCache_disposeInternal()
|
| /rocksdb-6.9/options/ |
| D | options.cc | 418 std::shared_ptr<Cache> cache = NewLRUCache(16 << 20); in OptimizeForSmallDb() local
420 ColumnFamilyOptions::OptimizeForSmallDb(&cache); in OptimizeForSmallDb()
421 DBOptions::OptimizeForSmallDb(&cache); in OptimizeForSmallDb()
476 DBOptions* DBOptions::OptimizeForSmallDb(std::shared_ptr<Cache>* cache) { in OptimizeForSmallDb() argument
483 0, (cache != nullptr) ? *cache : std::shared_ptr<Cache>()); in OptimizeForSmallDb()
490 std::shared_ptr<Cache>* cache) { in OptimizeForSmallDb() argument
499 (cache != nullptr) ? *cache : std::shared_ptr<Cache>(); in OptimizeForSmallDb()
603 ReadOptions::ReadOptions(bool cksum, bool cache) in ReadOptions() argument
611 fill_cache(cache), in ReadOptions()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util.cc | 20 std::shared_ptr<Cache>* cache) { in LoadOptionsFromFile() argument
34 if (cache != nullptr) { in LoadOptionsFromFile()
40 loaded_bbt_opt->block_cache = *cache; in LoadOptionsFromFile()
78 std::shared_ptr<Cache>* cache) { in LoadLatestOptions() argument
85 cf_descs, ignore_unknown_options, cache); in LoadLatestOptions()
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | sim_cache.cc | 157 SimCacheImpl(std::shared_ptr<Cache> sim_cache, std::shared_ptr<Cache> cache) in SimCacheImpl() argument
158 : cache_(cache), in SimCacheImpl()
332 std::shared_ptr<SimCache> NewSimCache(std::shared_ptr<Cache> cache, in NewSimCache() argument
338 return NewSimCache(NewLRUCache(co), cache, num_shard_bits); in NewSimCache()
342 std::shared_ptr<Cache> cache, in NewSimCache() argument
347 return std::make_shared<SimCacheImpl>(sim_cache, cache); in NewSimCache()
|
| /rocksdb-6.9/utilities/memory/ |
| D | memory_util.cc | 43 for (const auto* cache : cache_set) { in GetApproximateMemoryUsageByType() local
44 if (cache != nullptr) { in GetApproximateMemoryUsageByType()
45 (*usage_by_type)[MemoryUtil::kCacheTotal] += cache->GetUsage(); in GetApproximateMemoryUsageByType()
|