reivilibre
/
yama
1
0
Fork 0
Code Issues 27 Pull Requests Releases 16 Wiki Activity

Code formatting
continuous-integration/drone the build was successful Details

This commit is contained in:
Olivier 'reivilibre' 2021-11-16 07:34:40 +00:00
parent 066292b6fe
commit c3c0fdd240
3 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
datman/src/commands/backup.rs
View File

@ -158,7 +158,10 @@ pub fn backup_source_to_destination<PT: ProgressTracker>(
let pointer_name = get_pointer_name_at(&source_name, Utc::now()); let pointer_name = get_pointer_name_at(&source_name, Utc::now());
if pile.read_pointer(pointer_name.as_str())?.is_some() { if pile.read_pointer(pointer_name.as_str())?.is_some() {
bail!("Pointer by name {:?} already exists; refusing to overwrite.", pointer_name); bail!(
"Pointer by name {:?} already exists; refusing to overwrite.",
pointer_name
);
} }
info!("Will write as pointer {:?}.", pointer_name); info!("Will write as pointer {:?}.", pointer_name);
@ -221,7 +224,10 @@ pub fn backup_source_to_destination<PT: ProgressTracker>(
let pointer_name = get_pointer_name_at(&source_name, Utc::now()); let pointer_name = get_pointer_name_at(&source_name, Utc::now());
if pile.read_pointer(pointer_name.as_str())?.is_some() { if pile.read_pointer(pointer_name.as_str())?.is_some() {
bail!("Pointer by name {:?} already exists; refusing to overwrite.", pointer_name); bail!(
"Pointer by name {:?} already exists; refusing to overwrite.",
pointer_name
);
} }
info!("Will write as pointer {:?}.", pointer_name); info!("Will write as pointer {:?}.", pointer_name);

5
datman/src/remote/backup_source_requester.rs
View File

@ -183,7 +183,10 @@ pub fn backup_remote_source_to_destination<PT: ProgressTracker + Send + 'static>
let pointer_name = get_pointer_name_at(&source_name, Utc::now()); let pointer_name = get_pointer_name_at(&source_name, Utc::now());
if pile.read_pointer(pointer_name.as_str())?.is_some() { if pile.read_pointer(pointer_name.as_str())?.is_some() {
bail!("Pointer by name {:?} already exists; refusing to overwrite.", pointer_name); bail!(
"Pointer by name {:?} already exists; refusing to overwrite.",
pointer_name
);
} }
info!("Will write as pointer {:?}.", pointer_name); info!("Will write as pointer {:?}.", pointer_name);

4
yama/src/pile/local_sqlitebloblogs.rs
View File

@ -535,9 +535,7 @@ impl RawPile for SqliteBloblogPile {
if inner.writers_in_progress > 0 { if inner.writers_in_progress > 0 {
let _inner = self let _inner = self
.writers_reach_zero .writers_reach_zero
.wait_while(inner, |inner| { .wait_while(inner, |inner| inner.writers_in_progress != 0)
inner.writers_in_progress != 0
})
.unwrap(); .unwrap();
} }