TheCloud/dwarfs
1
0
Fork 0
mirror of https://github.com/mhx/dwarfs.git synced 2025-09-17 08:18:07 -04:00
Code Issues Packages Projects Releases Wiki Activity

Limit LRU cache size

Browse Source
This commit is contained in:
Marcus Holland-Moritz 2020-12-17 21:36:54 +01:00
parent ed24a60062
commit 629f3a4177
1 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/dwarfs/block_cache.cpp
View File

@ -268,20 +268,23 @@ class block_cache_ : public block_cache::impl {
void set_block_size(size_t size) override { void set_block_size(size_t size) override {
// XXX: This currently inevitably clears the cache // XXX: This currently inevitably clears the cache
auto max_blocks = std::max<size_t>(options_.max_bytes / size, 1); auto max_blocks = std::max<size_t>(options_.max_bytes / size, 1);
{
std::lock_guard<std::mutex> lock(mx_); if (!block_.empty() && max_blocks > block_.size()) {
cache_.~lru_type(); max_blocks = block_.size();
new (&cache_) lru_type(max_blocks);
cache_.setPruneHook(
[this](size_t block_no, std::shared_ptr<cached_block>&& block) {
LOG_DEBUG << "evicting block " << block_no
<< " from cache, decompression ratio = "
<< double(block->range_end()) /
double(block->uncompressed_size());
++blocks_evicted_;
update_block_stats(*block);
});
} }
std::lock_guard<std::mutex> lock(mx_);
cache_.~lru_type();
new (&cache_) lru_type(max_blocks);
cache_.setPruneHook(
[this](size_t block_no, std::shared_ptr<cached_block>&& block) {
LOG_DEBUG << "evicting block " << block_no
<< " from cache, decompression ratio = "
<< double(block->range_end()) /
double(block->uncompressed_size());
++blocks_evicted_;
update_block_stats(*block);
});
} }
std::future<block_range> std::future<block_range>