1bf59ebba0
This adds the helpers which are needed by both repair and compaction to add incremental repair support.
27 lines
692 B
C++
27 lines
692 B
C++
/*
|
|
* Copyright (C) 2025-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#include "repair/incremental.hh"
|
|
#include "utils/log.hh"
|
|
#include <algorithm>
|
|
#include <ranges>
|
|
|
|
extern logging::logger rlogger;
|
|
|
|
namespace repair {
|
|
|
|
bool is_repaired(int64_t sstables_repaired_at, const sstables::shared_sstable& sst) {
|
|
auto& stats = sst->get_stats_metadata();
|
|
bool repaired = stats.repaired_at !=0 && stats.repaired_at <= sstables_repaired_at;
|
|
rlogger.debug("Checking sst={} repaired_at={} sstables_repaired_at={} repaired={}",
|
|
sst->toc_filename(), stats.repaired_at, sstables_repaired_at, repaired);
|
|
return repaired;
|
|
}
|
|
|
|
}
|