infinite-db 0.4.0

A spatial-graph database using n-dimensional curves and hyperedges for engineering logic.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

//! Post-compaction block-file garbage collection.

use std::io;

use crate::infinitedb_core::{block::BlockId, snapshot::Snapshot};
use crate::infinitedb_storage::{gc::safe_to_delete, nvme::BlockStore};

use super::branch_overlay::BranchOverlayStore;
use super::snapshot_store::SnapshotStore;

/// Collect snapshot heads that must pin block files during GC.
pub fn live_snapshots_for_gc(
    snapshots: &SnapshotStore,
    branch_overlays: Option<&BranchOverlayStore>,
) -> Vec<Snapshot> {
    let mut live: Vec<Snapshot> = snapshots
        .all()
        .into_values()
        .map(|snap| (*snap).clone())
        .collect();
    if let Some(overlays) = branch_overlays {
        live.extend(overlays.branch_base_snapshots());
    }
    live
}

/// Delete superseded block files that are unreferenced by any live snapshot head.
pub fn gc_superseded_blocks(
    store: &BlockStore,
    superseded: &[BlockId],
    live_snapshots: &[Snapshot],
) -> io::Result<usize> {
    let deletable = safe_to_delete(superseded, live_snapshots);
    for id in &deletable {
        store.delete_block(*id)?;
    }
    Ok(deletable.len())
}