WorkerTaskContext: make it Send + Sync

diff --git a/pbs-tools/src/task.rs b/pbs-tools/src/task.rs
index 9e5d5b8fb9c075ce3c713bf0444674c7ed4ae857..a0d755aa394d519b500e502aa393b338e38926b4 100644 (file)
--- a/pbs-tools/src/task.rs
+++ b/pbs-tools/src/task.rs
@@ -3,7 +3,7 @@ use anyhow::{bail, Error};
 /// Worker task abstraction
 ///
 /// A worker task is a long running task, which usually logs output into a separate file.
-pub trait WorkerTaskContext {
+pub trait WorkerTaskContext: Send + Sync {
 
     /// Test if there was a request to abort the task.
     fn abort_requested(&self) -> bool;

diff --git a/src/backup/verify.rs b/src/backup/verify.rs
index cdc48ed2d2ba3aea6d8fd85a4d3cba27ff25fcd9..17179c13a424240b73ab1d0cbdfeea58cf5cb0de 100644 (file)
--- a/src/backup/verify.rs
+++ b/src/backup/verify.rs
@@ -19,7 +19,7 @@ use crate::tools::ParallelHandler;
 /// A VerifyWorker encapsulates a task worker, datastore and information about which chunks have
 /// already been verified or detected as corrupt.
 pub struct VerifyWorker {
-    worker: Arc<dyn WorkerTaskContext + Send + Sync>,
+    worker: Arc<dyn WorkerTaskContext>,
     datastore: Arc<DataStore>,
     verified_chunks: Arc<Mutex<HashSet<[u8; 32]>>>,
     corrupt_chunks: Arc<Mutex<HashSet<[u8; 32]>>>,
@@ -27,7 +27,7 @@ pub struct VerifyWorker {
 
 impl VerifyWorker {
     /// Creates a new VerifyWorker for a given task worker and datastore.
-    pub fn new(worker: Arc<dyn WorkerTaskContext + Send + Sync>, datastore: Arc<DataStore>) -> Self {
+    pub fn new(worker: Arc<dyn WorkerTaskContext>, datastore: Arc<DataStore>) -> Self {
         Self {
             worker,
             datastore,