dswd
/
zvault
mirror of https://github.com/dswd/zvault
1
0
Fork 0
Code Issues Releases Wiki Activity

Repair bundle map too (re #3)

This commit is contained in:
Dennis Schwerdel 2017-04-13 07:46:16 +02:00
parent df30f7a8fe
commit aadcea678d
2 changed files with 25 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/cli/mod.rs
View File

@ -422,7 +422,7 @@ pub fn run() -> Result<(), ErrorCode> {
}, },
Arguments::Check{repo_path, backup_name, inode, bundles, index, bundle_data, repair} => { Arguments::Check{repo_path, backup_name, inode, bundles, index, bundle_data, repair} => {
let mut repo = try!(open_repository(&repo_path)); let mut repo = try!(open_repository(&repo_path));
checked!(repo.check_repository(), "check repository", ErrorCode::CheckRun); checked!(repo.check_repository(repair), "check repository", ErrorCode::CheckRun);
if bundles { if bundles {
checked!(repo.check_bundles(bundle_data, repair), "check bundles", ErrorCode::CheckRun); checked!(repo.check_bundles(bundle_data, repair), "check bundles", ErrorCode::CheckRun);
} }

22
src/repository/integrity.rs
View File

@ -276,19 +276,39 @@ impl Repository {
Ok(()) Ok(())
} }
pub fn check_repository(&mut self) -> Result<(), RepositoryError> { pub fn check_repository(&mut self, repair: bool) -> Result<(), RepositoryError> {
info!("Checking repository integrity..."); info!("Checking repository integrity...");
let mut rebuild = false;
for (_id, bundle_id) in self.bundle_map.bundles() { for (_id, bundle_id) in self.bundle_map.bundles() {
if self.bundles.get_bundle_info(&bundle_id).is_none() { if self.bundles.get_bundle_info(&bundle_id).is_none() {
if repair {
warn!("Problem detected: bundle map contains unknown bundle {}", bundle_id);
rebuild = true;
} else {
return Err(IntegrityError::MissingBundle(bundle_id).into()) return Err(IntegrityError::MissingBundle(bundle_id).into())
} }
} }
}
if self.bundle_map.len() < self.bundles.len() { if self.bundle_map.len() < self.bundles.len() {
if repair {
warn!("Problem detected: bundle map does not contain all remote bundles");
rebuild = true;
} else {
return Err(IntegrityError::RemoteBundlesNotInMap.into()) return Err(IntegrityError::RemoteBundlesNotInMap.into())
} }
}
if self.bundle_map.len() > self.bundles.len() { if self.bundle_map.len() > self.bundles.len() {
if repair {
warn!("Problem detected: bundle map contains bundles multiple times");
rebuild = true;
} else {
return Err(IntegrityError::MapContainsDuplicates.into()) return Err(IntegrityError::MapContainsDuplicates.into())
} }
}
if rebuild {
try!(self.rebuild_bundle_map());
try!(self.rebuild_index());
}
Ok(()) Ok(())
} }