diff options
| author | tv <tv@krebsco.de> | 2026-10-25 13:38:59 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-25 13:38:59 +0100 |
| commit | f52ae6973299fa3c1d81758838951e39904e1d84 (patch) | |
| tree | eeadc6f698d1fa99d33268f997e8def5ee403038 /src/swarm/bootstrap.rs | |
| parent | 022ddb4bf167a12cd45b4a5cac27739f92449eff (diff) | |
add files module to consistently track stats
Diffstat (limited to 'src/swarm/bootstrap.rs')
| -rw-r--r-- | src/swarm/bootstrap.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/swarm/bootstrap.rs b/src/swarm/bootstrap.rs index 3be462e..f41a00b 100644 --- a/src/swarm/bootstrap.rs +++ b/src/swarm/bootstrap.rs @@ -26,6 +26,7 @@ use uuid::Uuid; use crate::document::replica::Epoch; use crate::document::store; +use crate::files::{FileKind, Files}; use crate::remake::snapshot::{self, META_ROOT, SWARM}; use crate::state::AppState; use crate::swarm::peer::{remember_peer, send_hello_once}; @@ -148,14 +149,14 @@ pub(crate) struct Backup { pub(crate) doc: AutoCommit, pub(crate) epoch: Epoch, pub(crate) swarm_id: String, - /// The file's size (`swarm::stats`, disk). - pub(crate) bytes: u64, } /// Loads a backup to recover from, as `GET /admin/document` saves it. -pub(crate) fn load_backup(path: &Path) -> Result<Backup> { - let bytes = - std::fs::read(path).with_context(|| format!("Reading the backup {}", path.display()))?; +pub(crate) fn load_backup(path: &Path, files: &Files) -> Result<Backup> { + let bytes = files + .read(FileKind::Backup, path) + .with_context(|| format!("Reading the backup {}", path.display()))? + .with_context(|| format!("The backup {} doesn't exist", path.display()))?; let mut doc = AutoCommit::load(&bytes) .with_context(|| format!("Loading the backup {}", path.display()))? .with_actor(ActorId::random()); @@ -171,7 +172,6 @@ pub(crate) fn load_backup(path: &Path) -> Result<Backup> { doc, epoch, swarm_id, - bytes: bytes.len() as u64, }) } |
