ic_backup/ops/persistence/execution_progress/
mod.rs

1//! Original retained plan/journal admission for local progress and guarded reservations.
2
3use super::{AttemptJournalError, BackupLayoutGuard, OperationPlanPersistenceError};
4use crate::{
5    model::{
6        artifacts::ArtifactChecksumRecord, attempt_journal::AttemptJournalRecord,
7        operation_plan::OperationPlanError,
8    },
9    policy::execution_progress::{ExecutionProgressError, ExecutionProgressView, admit_progress},
10};
11use thiserror::Error;
12
13/// Read complete original retained execution evidence without remote effects or artifact reads.
14///
15/// Requires the exact persisted plan and every original attempt journal. Missing
16/// journals never supply zero consumption. Journal locks are taken sequentially;
17/// hold no attempt guards when calling this function. The layout retains cooperating
18/// exclusion, while noncooperating byte custody remains integration-owned.
19/// This grants no fresh permission, executable call, authenticated receipt or release.
20/// # Errors
21/// Rejects missing/unsafe/changed originals, contention and invalid retained causality.
22pub fn read_execution_progress(
23    layout: &BackupLayoutGuard,
24    expected_plan: &ArtifactChecksumRecord,
25) -> Result<ExecutionProgressView, ExecutionProgressPersistenceError> {
26    let (plan, journals) = super::attempt_journal::read_original_plan_journals::<
27        ExecutionProgressPersistenceError,
28    >(layout, expected_plan, None)?;
29    Ok(admit_progress(&plan, journals.iter())?.project(&plan)?)
30}
31
32pub(super) fn admit_with_current(
33    layout: &BackupLayoutGuard,
34    expected_plan: &ArtifactChecksumRecord,
35    current: &AttemptJournalRecord,
36    require_dependencies: bool,
37) -> Result<(), ExecutionProgressPersistenceError> {
38    let (plan, journals) = super::attempt_journal::read_original_plan_journals::<
39        ExecutionProgressPersistenceError,
40    >(layout, expected_plan, Some(current))?;
41    let admitted = admit_progress(&plan, journals.iter())?;
42    let sequence = current.authority().binding().operation_sequence();
43    if require_dependencies
44        && !admitted.dependencies_applied(plan.operation(sequence)?.depends_on())
45    {
46        return Err(ExecutionProgressPersistenceError::DependenciesUnapplied(
47            sequence,
48        ));
49    }
50    Ok(())
51}
52
53/// Typed local evidence or reservation rejection; no failure resets original spending.
54#[derive(Debug, Error)]
55pub enum ExecutionProgressPersistenceError {
56    /// Exact original persisted plan cannot be admitted.
57    #[error(transparent)]
58    Plan(#[from] OperationPlanPersistenceError),
59    /// Original bulk authority derivation failed.
60    #[error(transparent)]
61    Authority(#[from] OperationPlanError),
62    /// Original journal admission or durable reservation failed.
63    #[error(transparent)]
64    Journal(#[from] AttemptJournalError),
65    /// Complete retained accounting/causality cannot be projected.
66    #[error(transparent)]
67    Policy(#[from] ExecutionProgressError),
68    /// The selected operation has a prerequisite without retained Applied evidence.
69    #[error("operation {0} has unapplied prerequisites")]
70    DependenciesUnapplied(u64),
71}
72
73#[cfg(all(test, unix))]
74mod tests;
ic_backup/ops/persistence/execution_progress/mod.rs

ic_backup/ops/persistence/execution_progress/
mod.rs
