_lock: std::fs::File,
mut config: SectionConfigData,
datastore: DataStoreConfig,
+ worker: Option<&dyn crate::task::TaskState>,
) -> Result<(), Error> {
let path: PathBuf = datastore.path.clone().into();
let backup_user = crate::backup::backup_user()?;
- let _store = ChunkStore::create(&datastore.name, path, backup_user.uid, backup_user.gid)?;
+ let _store = ChunkStore::create(&datastore.name, path, backup_user.uid, backup_user.gid, worker)?;
config.set_data(&datastore.name, "datastore", &datastore)?;
Some(datastore.name.to_string()),
auth_id,
false,
- move |_worker| do_create_datastore(lock, config, datastore),
+ move |worker| do_create_datastore(lock, config, datastore, Some(&worker)),
)
}
use proxmox::tools::fs::{CreateOptions, create_path, create_dir};
+use crate::task_log;
use crate::tools;
use crate::api2::types::GarbageCollectionStatus;
chunk_dir
}
- pub fn create<P>(name: &str, path: P, uid: nix::unistd::Uid, gid: nix::unistd::Gid) -> Result<Self, Error>
+ pub fn create<P>(name: &str, path: P, uid: nix::unistd::Uid, gid: nix::unistd::Gid, worker: Option<&dyn TaskState>) -> Result<Self, Error>
where
P: Into<PathBuf>,
{
}
let percentage = (i*100)/(64*1024);
if percentage != last_percentage {
- // eprintln!("ChunkStore::create {}%", percentage);
+ if let Some(worker) = worker {
+ task_log!(worker, "Chunkstore create: {}%", percentage)
+ }
last_percentage = percentage;
}
}
assert!(chunk_store.is_err());
let user = nix::unistd::User::from_uid(nix::unistd::Uid::current()).unwrap().unwrap();
- let chunk_store = ChunkStore::create("test", &path, user.uid, user.gid).unwrap();
+ let chunk_store = ChunkStore::create("test", &path, user.uid, user.gid, None).unwrap();
let (chunk, digest) = super::DataChunkBuilder::new(&[0u8, 1u8]).build().unwrap();
assert!(exists);
- let chunk_store = ChunkStore::create("test", &path, user.uid, user.gid);
+ let chunk_store = ChunkStore::create("test", &path, user.uid, user.gid, None);
assert!(chunk_store.is_err());
if let Err(_e) = std::fs::remove_dir_all(".testdir") { /* ignore */ }