Function restore_crdt_checkpoints

nodedb/src/storage/snapshot_executor.rs:231–253

(
    data_dir: &Path,
    _core_id: usize,
    crdt_snapshots: &[crate::data::snapshot::CrdtSnapshot],
)

}

fn restore_crdt_checkpoints(
    data_dir: &Path,
    _core_id: usize,
    crdt_snapshots: &[crate::data::snapshot::CrdtSnapshot],
) -> crate::Result<()> {
    if crdt_snapshots.is_empty() {
        return Ok(());
    }

    let ckpt_dir = data_dir.join("crdt-ckpt");
    // no-objectstore: CRDT state lands in a local engine-owned directory.
    std::fs::create_dir_all(&ckpt_dir).map_err(crate::Error::Io)?;

    for snap in crdt_snapshots {
        let ckpt_path = ckpt_dir.join(format!("tenant-{}.ckpt", snap.tenant_id));
        let tmp_path = ckpt_dir.join(format!("tenant-{}.ckpt.tmp", snap.tenant_id));
        nodedb_wal::segment::atomic_write_fsync(&tmp_path, &ckpt_path, &snap.snapshot_bytes)
            .map_err(crate::Error::Wal)?;
    }

    info!(tenants = crdt_snapshots.len(), "CRDT checkpoints restored");
    Ok(())
}

/// Write a restore marker to the object store that tells the startup code to
/// replay WAL records only from the given LSN forward.