tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/backup/chunk_store.rs: create lock file with correct owner

Browse Source
This commit is contained in:
Dietmar Maurer 2019-12-19 06:49:03 +01:00
parent 4897426cea
commit 7e210bd0b4
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/backup/chunk_store.rs
View File

@ -113,6 +113,10 @@ impl ChunkStore {
bail!("unable to create chunk store '{}' subdir {:?} - {}", name, chunk_dir, err); bail!("unable to create chunk store '{}' subdir {:?} - {}", name, chunk_dir, err);
} }
// create lock file with correct owner/group
let lockfile_path = Self::lockfile_path(&base);
proxmox::tools::fs::replace_file(lockfile_path, b"", options.clone())?;
// create 64*1024 subdirs // create 64*1024 subdirs
let mut last_percentage = 0; let mut last_percentage = 0;
@ -129,12 +133,22 @@ impl ChunkStore {
} }
} }
Self::open(name, base) Self::open(name, base)
} }
pub fn open<P: Into<PathBuf>>(name: &str, path: P) -> Result<Self, Error> { fn lockfile_path<P: Into<PathBuf>>(base: P) -> PathBuf {
let base: PathBuf = base.into();
let base: PathBuf = path.into(); let mut lockfile_path = base.clone();
lockfile_path.push(".lock");
lockfile_path
}
pub fn open<P: Into<PathBuf>>(name: &str, base: P) -> Result<Self, Error> {
let base: PathBuf = base.into();
if !base.is_absolute() { if !base.is_absolute() {
bail!("expected absolute path - got {:?}", base); bail!("expected absolute path - got {:?}", base);
@ -146,8 +160,7 @@ impl ChunkStore {
bail!("unable to open chunk store '{}' at {:?} - {}", name, chunk_dir, err); bail!("unable to open chunk store '{}' at {:?} - {}", name, chunk_dir, err);
} }
let mut lockfile_path = base.clone(); let lockfile_path = Self::lockfile_path(&base);
lockfile_path.push(".lock");
let locker = tools::ProcessLocker::new(&lockfile_path)?; let locker = tools::ProcessLocker::new(&lockfile_path)?;