proxmox-mirrors/proxmox
1
0
Fork 1
mirror of https://git.proxmox.com/git/proxmox synced 2025-08-05 07:35:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

cleanup WorkerTaskContext

Browse Source
This commit is contained in:
Dietmar Maurer 2021-09-24 11:39:30 +02:00
parent 020c8e6980
commit 42dae7e1fb
1 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
proxmox-rest-server/src/worker_task.rs
View File

@ -829,19 +829,6 @@ impl WorkerTask {
} }
} }
/// Test if abort was requested.
pub fn abort_requested(&self) -> bool {
self.abort_requested.load(Ordering::SeqCst)
}
/// Fail if abort was requested.
pub fn check_abort(&self) -> Result<(), Error> {
if self.abort_requested() {
bail!("abort requested - aborting task");
}
Ok(())
}
/// Get a future which resolves on task abort /// Get a future which resolves on task abort
pub fn abort_future(&self) -> oneshot::Receiver<()> { pub fn abort_future(&self) -> oneshot::Receiver<()> {
let (tx, rx) = oneshot::channel::<()>(); let (tx, rx) = oneshot::channel::<()>();
@ -861,8 +848,9 @@ impl WorkerTask {
} }
impl WorkerTaskContext for WorkerTask { impl WorkerTaskContext for WorkerTask {
fn check_abort(&self) -> Result<(), Error> {
self.check_abort() fn abort_requested(&self) -> bool {
self.abort_requested.load(Ordering::SeqCst)
} }
fn log(&self, level: log::Level, message: &std::fmt::Arguments) { fn log(&self, level: log::Level, message: &std::fmt::Arguments) {