From cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71 Mon Sep 17 00:00:00 2001 From: Douglas Rumbaugh Date: Thu, 25 Sep 2025 14:42:44 -0400 Subject: Code reformatting --- include/framework/reconstruction/TieringPolicy.h | 26 +++++++++++++++--------- 1 file changed, 16 insertions(+), 10 deletions(-) (limited to 'include/framework/reconstruction/TieringPolicy.h') diff --git a/include/framework/reconstruction/TieringPolicy.h b/include/framework/reconstruction/TieringPolicy.h index b1fcb49..c16c427 100644 --- a/include/framework/reconstruction/TieringPolicy.h +++ b/include/framework/reconstruction/TieringPolicy.h @@ -21,11 +21,13 @@ class TieringPolicy : public ReconstructionPolicy { LevelVector; public: - TieringPolicy(size_t scale_factor, size_t buffer_size, double modifier=0) - : m_scale_factor(scale_factor), m_buffer_size(buffer_size), m_size_modifier(modifier) {} + TieringPolicy(size_t scale_factor, size_t buffer_size, double modifier = 0) + : m_scale_factor(scale_factor), m_buffer_size(buffer_size), + m_size_modifier(modifier) {} - std::vector get_reconstruction_tasks( - const Version *version, LockManager &lock_mngr) const override { + std::vector + get_reconstruction_tasks(const Version *version, + LockManager &lock_mngr) const override { return {}; } @@ -34,7 +36,8 @@ public: ReconstructionVector reconstructions; auto levels = version->get_structure()->get_level_vector(); - level_index target_level = find_reconstruction_target(levels, version->get_structure()->get_record_count()); + level_index target_level = find_reconstruction_target( + levels, version->get_structure()->get_record_count()); assert(target_level != -1); level_index source_level = 0; @@ -47,12 +50,13 @@ public: size_t total_reccnt = levels[i - 1]->get_record_count(); std::vector shards; - for (ssize_t j=0; j<(ssize_t)levels[i-1]->get_shard_count(); j++) { - shards.push_back({i-1, j}); + for (ssize_t j = 0; j < (ssize_t)levels[i - 1]->get_shard_count(); j++) { + shards.push_back({i - 1, j}); } if (total_reccnt > 0 || shards.size() > 0) { - reconstructions.add_reconstruction(shards, i, total_reccnt, ReconstructionType::Compact); + reconstructions.add_reconstruction(shards, i, total_reccnt, + ReconstructionType::Compact); } } @@ -60,7 +64,8 @@ public: } private: - level_index find_reconstruction_target(LevelVector &levels, size_t reccnt) const { + level_index find_reconstruction_target(LevelVector &levels, + size_t reccnt) const { level_index target_level = invalid_level_idx; for (level_index i = 1; i < (level_index)levels.size(); i++) { @@ -74,7 +79,8 @@ private: } inline size_t capacity(size_t reccnt) const { - return std::ceil((double) m_scale_factor * std::pow(std::log10(reccnt), m_size_modifier)); + return std::ceil((double)m_scale_factor * + std::pow(std::log10(reccnt), m_size_modifier)); } size_t m_scale_factor; -- cgit v1.2.3