&mut chunk_reader,
tgt_store.clone(),
snapshot,
- &item,
+ item,
downloaded_chunks.clone(),
)
.await?;
snapshot: &BackupDir,
downloaded_chunks: Arc<Mutex<HashSet<[u8; 32]>>>,
) -> Result<(), Error> {
- let (_path, is_new, _snap_lock) = tgt_store.create_locked_backup_dir(&snapshot)?;
+ let (_path, is_new, _snap_lock) = tgt_store.create_locked_backup_dir(snapshot)?;
if is_new {
task_log!(worker, "sync snapshot {:?}", snapshot.relative_path());
worker,
reader,
tgt_store.clone(),
- &snapshot,
+ snapshot,
downloaded_chunks,
)
.await
{
- if let Err(cleanup_err) = tgt_store.remove_backup_dir(&snapshot, true) {
+ if let Err(cleanup_err) = tgt_store.remove_backup_dir(snapshot, true) {
task_log!(worker, "cleanup error - {}", cleanup_err);
}
return Err(err);
worker,
reader,
tgt_store.clone(),
- &snapshot,
+ snapshot,
downloaded_chunks,
)
.await?;
let list:Vec<BackupGroup> = list
.into_iter()
.filter(|group| {
- apply_filters(&group, group_filter)
+ apply_filters(group, group_filter)
})
.collect();
task_log!(worker, "found {} groups to sync (out of {} total)", list.len(), unfiltered_count);