proxmox-mirrors/proxmox-backup-qemu
1
0
Fork 0
mirror of https://git.proxmox.com/git/proxmox-backup-qemu synced 2025-10-04 14:38:47 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

src/worker_task.rs: use runtime.block_on() inside backup_worker_task

Browse Source
This commit is contained in:
Dietmar Maurer 2020-02-13 08:15:05 +01:00
parent 74363b4cdd
commit a79ce5d618
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/worker_task.rs
View File

@ -92,7 +92,7 @@ fn backup_worker_task(
builder.core_threads(4); builder.core_threads(4);
builder.thread_name("proxmox-backup-qemu-worker"); builder.thread_name("proxmox-backup-qemu-worker");
let runtime = match builder.build() { let mut runtime = match builder.build() {
Ok(runtime) => runtime, Ok(runtime) => runtime,
Err(err) => { Err(err) => {
connect_tx.send(Err(format_err!("create runtime failed: {}", err)))?; connect_tx.send(Err(format_err!("create runtime failed: {}", err)))?;
@ -122,7 +122,7 @@ fn backup_worker_task(
let client = Arc::new(Mutex::new(None)); let client = Arc::new(Mutex::new(None));
runtime.spawn(async move { runtime.block_on(async move {
let registry = Arc::new(Mutex::new(ImageRegistry::new())); let registry = Arc::new(Mutex::new(ImageRegistry::new()));
@ -260,9 +260,6 @@ fn backup_worker_task(
println!("worker end loop"); println!("worker end loop");
}); });
//runtime.shutdown_on_idle();
// fixme: stats is always 0 here
let stats = BackupTaskStats { written_bytes: written_bytes.fetch_add(0, Ordering::SeqCst) }; let stats = BackupTaskStats { written_bytes: written_bytes.fetch_add(0, Ordering::SeqCst) };
Ok(stats) Ok(stats)
} }