kip_db 0.1.2-alpha.26.fix1

use crate::kernel::lsm::version::edit::EditType;
use crate::kernel::KernelResult;
use itertools::Itertools;

#[derive(Clone, Copy, Eq, PartialEq, Debug)]
pub(crate) struct VersionMeta {
    /// SSTable集合占有磁盘大小
    pub(crate) size_of_disk: u64,
    /// SSTable集合中指令数量
    pub(crate) len: usize,
}

impl VersionMeta {
    // MetaData对SSTable统计数据处理
    pub(crate) fn statistical_process(
        &mut self,
        vec_statistics_sst_meta: Vec<EditType>,
    ) -> KernelResult<()> {
        // 优先对新增数据进行统计再统一减去对应的数值避免删除动作聚集在前部分导致数值溢出
        for event_type in vec_statistics_sst_meta.into_iter().sorted() {
            match event_type {
                EditType::Add(meta) => {
                    self.size_of_disk += meta.size_of_disk;
                    self.len += meta.len;
                }
                EditType::Del(meta) => {
                    self.size_of_disk -= meta.size_of_disk;
                    self.len -= meta.len;
                }
            }
        }

        Ok(())
    }
}