Deuxfleurs/garage
48
56
Fork 73
Code Issues 100 Pull requests 13 Releases 30 Wiki Activity

Background task manager #332

Merged
lx merged 35 commits from background-task-manager into main 2022-07-08 11:30:32 +00:00
Conversation 0 Commits 35 Files changed 27 +11 -5
1 changed files with 11 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 0200eae679 - Show all commits

16
src/block/manager.rs
View file

@ -494,11 +494,7 @@ impl BlockManager {
fn spawn_background_workers(self: Arc<Self>) { fn spawn_background_workers(self: Arc<Self>) {
// Launch a background workers for background resync loop processing // Launch a background workers for background resync loop processing
let background = self.system.background.clone(); let background = self.system.background.clone();
let worker = ResyncWorker { let worker = ResyncWorker::new(self.clone());
manager: self.clone(),
tranquilizer: Tranquilizer::new(30),
next_delay: Duration::from_secs(10),
};
tokio::spawn(async move { tokio::spawn(async move {
tokio::time::sleep(Duration::from_secs(10)).await; tokio::time::sleep(Duration::from_secs(10)).await;
background.spawn_worker(worker); background.spawn_worker(worker);
@ -744,6 +740,16 @@ struct ResyncWorker {
next_delay: Duration, next_delay: Duration,
} }
impl ResyncWorker {
fn new(manager: Arc<BlockManager>) -> Self {
Self {
manager,
tranquilizer: Tranquilizer::new(30),
next_delay: Duration::from_secs(10),
}
}
}
#[async_trait] #[async_trait]
impl Worker for ResyncWorker { impl Worker for ResyncWorker {
fn name(&self) -> String { fn name(&self) -> String {