Home
last modified time | relevance | path

Searched refs:cache_ (Results 1 – 20 of 20) sorted by relevance

/rocksdb-6.9/db/
Ddb_logical_block_size_cache_test.cc29 LogicalBlockSizeCache* cache_; member in ROCKSDB_NAMESPACE::EnvWithCustomLogicalBlockSizeCache
45 cache_.reset( in DBLogicalBlockSizeCacheTest()
82 ASSERT_EQ(2, cache_->Size()); in TEST_F()
135 ASSERT_EQ(1, cache_->Size()); in TEST_F()
141 ASSERT_EQ(3, cache_->Size()); in TEST_F()
151 ASSERT_EQ(3, cache_->Size()); in TEST_F()
165 ASSERT_EQ(0, cache_->Size()); in TEST_F()
181 ASSERT_EQ(1, cache_->Size()); in TEST_F()
187 ASSERT_EQ(2, cache_->Size()); in TEST_F()
206 ASSERT_EQ(2, cache_->Size()); in TEST_F()
[all …]
Dtable_cache.h180 Cache* get_cache() const { return cache_; } in get_cache()
189 if (cache_->GetCapacity() >= kInfiniteCapacity) { in SetTablesAreImmortal()
220 Cache* const cache_; variable
Dtable_cache.cc65 cache_(cache), in TableCache()
79 return reinterpret_cast<TableReader*>(cache_->Value(handle)); in GetTableReaderFromHandle()
83 cache_->Release(handle); in ReleaseHandle()
130 cache_->Erase(key); in EraseHandle()
145 *handle = cache_->Lookup(key); in FindTable()
164 s = cache_->Insert(key, table_reader.get(), 1, in FindTable()
214 result->RegisterCleanup(&UnrefEntry, cache_, handle); in NewIterator()
/rocksdb-6.9/table/block_based/
Dcachable_entry.h49 , cache_(cache) in CachableEntry()
55 assert(!!cache_ == !!cache_handle_); in CachableEntry()
64 , cache_(rhs.cache_) in CachableEntry()
70 assert(!!cache_ == !!cache_handle_); in CachableEntry()
84 cache_ = rhs.cache_;
126 assert(cache_ != nullptr); in TransferTo()
177 cache_ = cache; in SetCachedValue()
185 assert(cache_ != nullptr); in ReleaseResource()
186 cache_->Release(cache_handle_); in ReleaseResource()
194 cache_ = nullptr; in ResetFields()
[all …]
Dpartitioned_filter_block_test.cc67 std::shared_ptr<Cache> cache_; member in ROCKSDB_NAMESPACE::PartitionedFilterBlockTest
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc158 : cache_(cache), in SimCacheImpl()
185 if (!cache_) { in Insert()
203 if (!cache_) { in Lookup()
206 return cache_->Lookup(key, stats); in Lookup()
216 cache_->Erase(key); in Erase()
227 return cache_->HasStrictCapacityLimit(); in HasStrictCapacityLimit()
233 return cache_->GetUsage(handle); in GetUsage()
237 return cache_->GetCharge(handle); in GetCharge()
243 cache_->DisownData(); in DisownData()
254 cache_->EraseUnRefEntries(); in EraseUnRefEntries()
[all …]
/rocksdb-6.9/cache/
Dcache_test.cc134 Erase(cache_, key); in Erase()
340 cache_->Release(h1); in TEST_P()
351 cache_->Release(h2); in TEST_P()
383 cache_->Release(h); in TEST_P()
439 cache_->Release(h201); in TEST_P()
440 cache_->Release(h202); in TEST_P()
441 cache_->Release(h203); in TEST_P()
442 cache_->Release(h204); in TEST_P()
487 cache_->Release(h1); in TEST_P()
491 cache_->Release(h2); in TEST_P()
[all …]
Dlru_cache_test.cc21 if (cache_ != nullptr) { in DeleteCache()
22 cache_->~LRUCacheShard(); in DeleteCache()
23 port::cacheline_aligned_free(cache_); in DeleteCache()
24 cache_ = nullptr; in DeleteCache()
31 cache_ = reinterpret_cast<LRUCacheShard*>( in NewCache()
33 new (cache_) LRUCacheShard(capacity, false /*strict_capcity_limit*/, in NewCache()
40 cache_->Insert(key, 0 /*hash*/, nullptr /*value*/, 1 /*charge*/, in Insert()
49 auto handle = cache_->Lookup(key, 0 /*hash*/); in Lookup()
51 cache_->Release(handle); in Lookup()
65 cache_->TEST_GetLRUList(&lru, &lru_low_pri); in ValidateLRUList()
[all …]
Dcache_bench.cc131 cache_ = NewClockCache(FLAGS_cache_size, FLAGS_num_shard_bits); in CacheBench()
132 if (!cache_) { in CacheBench()
137 cache_ = NewLRUCache(FLAGS_cache_size, FLAGS_num_shard_bits); in CacheBench()
150 cache_->Insert(key, new char[10], 1, in PopulateCache()
193 std::shared_ptr<Cache> cache_; member in ROCKSDB_NAMESPACE::CacheBench
229 cache_->Insert(key, new char[10], 1, in OperateCache()
234 auto handle = cache_->Lookup(key); in OperateCache()
236 cache_->Release(handle); in OperateCache()
241 cache_->Erase(key); in OperateCache()
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_test.h38 if (cache_) { in ~PersistentCacheTierTest()
39 Status s = cache_->Close(); in ~PersistentCacheTierTest()
47 if (cache_) { in Flush()
48 cache_->TEST_Flush(); in Flush()
185 cache_->Close(); in RunInsertTest()
186 cache_.reset(); in RunInsertTest()
196 cache_->Close(); in RunNegativeInsertTest()
197 cache_.reset(); in RunNegativeInsertTest()
208 cache_->Close(); in RunInsertTestWithEviction()
209 cache_.reset(); in RunInsertTestWithEviction()
[all …]
Dpersistent_cache_test.cc150 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
167 cache_ = std::make_shared<VolatileCacheTier>(); in TEST_F()
170 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
175 cache_ = NewTieredCache(Env::Default(), path_, in TEST_F()
186 cache_ = std::make_shared<VolatileCacheTier>(); in TEST_F()
196 cache_ = std::make_shared<VolatileCacheTier>( in TEST_F()
210 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
223 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
236 cache_ = NewTieredCache(Env::Default(), path_, in TEST_F()
249 cache_ = NewTieredCache( in TEST_F()
[all …]
Dpersistent_cache_bench.cc114 : cache_(cache) { in CacheTierBenchmark()
144 cache_->TEST_Flush(); in CacheTierBenchmark()
145 cache_->Close(); in CacheTierBenchmark()
162 << cache_->PrintStats() << std::endl; in PrintStats()
177 cache_->TEST_Flush(); in Prepop()
200 Status status = cache_->Insert(block_key, block.get(), FLAGS_iosize); in InsertKey()
233 Status status = cache_->Lookup(key, &block, &size); in ReadKey()
297 std::shared_ptr<PersistentCacheTier> cache_; // cache implementation member in ROCKSDB_NAMESPACE::CacheTierBenchmark
Dblock_cache_tier_file.h76 explicit Writer(PersistentCacheTier* const cache) : cache_(cache) {} in Writer()
86 PersistentCacheTier* const cache_; variable
Dblock_cache_tier_file.cc577 while (!cache_->Reserve(io.buf_->Used())) { in ThreadMain()
/rocksdb-6.9/memtable/
Dwrite_buffer_manager.cc24 std::shared_ptr<Cache> cache_; member
33 : cache_(cache), cache_allocated_size_(0) { in CacheRep()
72 cache_rep_->cache_->Release(handle, true); in ~WriteBufferManager()
92 cache_rep_->cache_->Insert(cache_rep_->GetNextCacheKey(), nullptr, in ReserveMemWithCache()
122 cache_rep_->cache_->Release(cache_rep_->dummy_handles_.back(), true); in FreeMemWithCache()
/rocksdb-6.9/env/
Dio_posix.h92 auto it = cache_.find(dir); in GetRefCount()
93 if (it == cache_.end()) { in GetRefCount()
99 size_t Size() const { return cache_.size(); } in Size()
103 return cache_.find(dir) != cache_.end(); in Contains()
120 std::map<std::string, CacheValue> cache_; variable
Dio_posix.cc396 if (cache_.find(dir) == cache_.end()) { in RefAndCacheLogicalBlockSize()
412 auto& v = cache_[dir]; in RefAndCacheLogicalBlockSize()
432 auto it = cache_.find(dir); in UnrefAndTryRemoveCachedLogicalBlockSize()
433 if (it != cache_.end() && !(--(it->second.ref))) { in UnrefAndTryRemoveCachedLogicalBlockSize()
434 cache_.erase(it); in UnrefAndTryRemoveCachedLogicalBlockSize()
447 auto it = cache_.find(dir); in GetLogicalBlockSize()
448 if (it != cache_.end()) { in GetLogicalBlockSize()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc2290 std::shared_ptr<Cache> cache_; member in ROCKSDB_NAMESPACE::Benchmark
2639 : cache_(NewCache(FLAGS_cache_size)), in Benchmark()
2669 cache_ = in Benchmark()
2672 cache_ = NewSimCache(cache_, FLAGS_simcache_size, 0); in Benchmark()
2728 if (cache_.get() != nullptr) { in ~Benchmark()
2730 cache_->DisownData(); in ~Benchmark()
3268 static_cast_with_check<SimCache, Cache>(cache_.get()) in Run()
3606 new WriteBufferManager(FLAGS_db_write_buffer_size, cache_)); in InitializeOptionsFromFlags()
3798 if (cache_ == nullptr) { in InitializeOptionsFromFlags()
3811 block_based_options.block_cache = cache_; in InitializeOptionsFromFlags()
[all …]
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.h208 std::shared_ptr<Cache> cache_; variable
Ddb_stress_test_base.cc19 : cache_(NewCache(FLAGS_cache_size)), in StressTest()
1735 block_based_options.block_cache = cache_; in Open()