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 a36cca984d10bf04095ece23c92aa61772f9d641..736ae65951e44af4ff57700953f5ca3e7c86b95f 100644 (file)
--- 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();
+             }
         }
     });