From: Dietmar Maurer <dietmar@proxmox.com>
Date: Tue, 14 Sep 2021 08:42:44 +0000 (+0200)
Subject: fix tests/worker-task-abort.rs - correctly spawn command socket
X-Git-Tag: v2.0.10~34
X-Git-Url: https://git.proxmox.com/?a=commitdiff_plain;h=36c6e7bb82fddedd31902ee155cbcc15860dde11;p=proxmox-backup.git

fix tests/worker-task-abort.rs - correctly spawn command socket

And wait for the task.

Note: The test is still ignored (but works now when run a root)
---

diff --git a/tests/worker-task-abort.rs b/tests/worker-task-abort.rs
index a36cca98..736ae659 100644
--- a/tests/worker-task-abort.rs
+++ b/tests/worker-task-abort.rs
@@ -31,7 +31,8 @@ fn garbage_collection(worker: &server::WorkerTask) -> Result<(), Error> {
 }
 
 
-#[test] #[ignore]
+#[test]
+#[ignore]
 fn worker_task_abort() -> Result<(), Error> {
 
     server::create_task_log_dirs()?;
@@ -57,6 +58,11 @@ fn worker_task_abort() -> Result<(), Error> {
             return;
         }
 
+       if let Err(err) = commando_sock.spawn() {
+            eprintln!("unable to spawn command socket - {}", err);
+            return;
+        }
+
         let errmsg = errmsg1.clone();
         let res = server::WorkerTask::new_thread(
             "garbage_collection",
@@ -87,7 +93,8 @@ fn worker_task_abort() -> Result<(), Error> {
             Ok(wid) => {
                 println!("WORKER: {}", wid);
                 server::abort_worker_async(wid.parse::<UPID>().unwrap());
-            }
+                server::wait_for_local_worker(&wid).await.unwrap();
+             }
         }
     });