tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

server: refactor abort_local_worker

Browse Source 
we'll need this outside the module

Signed-off-by: Dominik Csapak <d.csapak@proxmox.com>
Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
This commit is contained in:
Dominik Csapak 2021-09-21 12:11:12 +02:00 committed by Thomas Lamprecht
parent 84af82e8cf
commit 3f742f952a
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/server/worker_task.rs
View File

@ -100,9 +100,8 @@ pub fn register_task_control_commands(
commando_sock.register_command("worker-task-abort".into(), move |args| { commando_sock.register_command("worker-task-abort".into(), move |args| {
let upid = get_upid(args)?; let upid = get_upid(args)?;
if let Some(ref worker) = WORKER_TASK_LIST.lock().unwrap().get(&upid.task_id) { abort_local_worker(upid);
worker.request_abort();
}
Ok(Value::Null) Ok(Value::Null)
})?; })?;
commando_sock.register_command("worker-task-status".into(), move |args| { commando_sock.register_command("worker-task-status".into(), move |args| {
@ -828,3 +827,10 @@ pub async fn wait_for_local_worker(upid_str: &str) -> Result<(), Error> {
} }
Ok(()) Ok(())
} }
/// Request abort of a local worker (if existing and running)
pub fn abort_local_worker(upid: UPID) {
if let Some(ref worker) = WORKER_TASK_LIST.lock().unwrap().get(&upid.task_id) {
worker.request_abort();
}
}