TheCloud/dwarfs
1
0
Fork 0
mirror of https://github.com/mhx/dwarfs.git synced 2025-09-12 05:49:56 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: more logging for cached_block / block_cache

Browse Source
This commit is contained in:
Marcus Holland-Moritz 2025-03-28 11:54:21 +01:00
parent 38b9cfd8e1
commit 703c4a5aa0
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/reader/internal/block_cache.cpp
View File

@ -386,6 +386,7 @@ class block_cache_ final : public block_cache::impl {
if (cache_.findWithoutPromotion(*next) == cache_.end() &&
active_.find(*next) == active_.end()) {
sequential_prefetches_.fetch_add(1, std::memory_order_relaxed);
LOG_TRACE << "prefetching block " << *next;
create_cached_block(*next, std::promise<block_range>{}, 0,
std::numeric_limits<size_t>::max());
}

11
src/reader/internal/cached_block.cpp
View File

@ -42,6 +42,8 @@ namespace {
template <typename LoggerPolicy>
class cached_block_ final : public cached_block {
public:
static inline std::atomic<size_t> instance_count_{0};
cached_block_(logger& lgr, fs_section const& b, std::shared_ptr<mmif> mm,
bool release, bool disable_integrity_check)
: decompressor_(std::make_unique<block_decompressor>(
@ -54,9 +56,16 @@ class cached_block_ final : public cached_block {
if (!disable_integrity_check && !section_.check(*mm_)) {
DWARFS_THROW(runtime_error, "block data integrity check failed");
}
std::atomic_fetch_add(&instance_count_, 1U);
LOG_TRACE << "create cached block " << section_.section_number().value()
<< " [" << instance_count_
<< "], release=" << (release ? "true" : "false");
}
~cached_block_() override {
std::atomic_fetch_sub(&instance_count_, 1U);
LOG_TRACE << "delete cached block " << section_.section_number().value()
<< " [" << instance_count_ << "]";
if (decompressor_) {
try_release();
}
@ -116,6 +125,8 @@ class cached_block_ final : public cached_block {
private:
void try_release() {
if (release_) {
LOG_TRACE << "releasing mapped memory for block "
<< section_.section_number().value();
if (auto ec = mm_->release(section_.start(), section_.length())) {
LOG_INFO << "madvise() failed: " << ec.message();
}