src/api2/admin/datastore.rs: use new WorkerTask::new_thread()

diff --git a/src/api2/admin/datastore.rs b/src/api2/admin/datastore.rs
index 98e4f509161ee478f1a0c7468c47e007bb5418eb..ca7fe09cb851fc1c96c720c51758ed4734d26f78 100644 (file)
--- a/src/api2/admin/datastore.rs
+++ b/src/api2/admin/datastore.rs
@@ -16,6 +16,7 @@ use std::sync::Arc;
 use crate::config::datastore;
 
 use crate::backup::*;
+use crate::server::WorkerTask;
 
 mod pxar;
 mod upload;
@@ -285,7 +286,7 @@ fn api_method_prune() -> ApiMethod {
 fn start_garbage_collection(
     param: Value,
     _info: &ApiMethod,
-    _rpcenv: &mut RpcEnvironment,
+    rpcenv: &mut RpcEnvironment,
 ) -> Result<Value, Error> {
 
     let store = param["store"].as_str().unwrap().to_string();
@@ -294,13 +295,16 @@ fn start_garbage_collection(
 
     println!("Starting garbage collection on store {}", store);
 
-    std::thread::spawn(move || {
-        if let Err(err) = datastore.garbage_collection() {
-            println!("Garbage collection error on store {} - {}", store, err);
-        }
-    });
+    let to_stdout = if rpcenv.env_type() == RpcEnvironmentType::CLI { true } else { false };
 
-    Ok(json!(null))
+    let upid_str = WorkerTask::new_thread(
+        "garbage_collection", Some(store.clone()), "root@pam", to_stdout, move |worker|
+        {
+            worker.log(format!("starting garbage collection on store {}", store));
+            datastore.garbage_collection()
+        })?;
+
+    Ok(json!(upid_str))
 }
 
 pub fn api_method_start_garbage_collection() -> ApiMethod {