Skip to content

Commit

Permalink
clean up unused async
Browse files Browse the repository at this point in the history
  • Loading branch information
gjcolombo committed Jul 2, 2024
1 parent 9f23e19 commit 64bcf94
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions lib/propolis/src/block/crucible.rs
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,7 @@ impl CrucibleBackend {
.map_err(CrucibleError::into)
}

async fn spawn_workers(&self) {
fn spawn_workers(&self) {
// TODO: make this tunable?
let worker_count = 8;
self.workers.extend((0..worker_count).map(|n| {
Expand All @@ -283,7 +283,7 @@ impl CrucibleBackend {
tokio::spawn(
async move { worker_state.process_loop(worker_acc).await },
)
}));
}))
}

pub async fn volume_is_active(&self) -> Result<bool, CrucibleError> {
Expand All @@ -302,7 +302,7 @@ impl block::Backend for CrucibleBackend {
async fn start(&self) -> anyhow::Result<()> {
self.state.volume.activate().await?;
self.state.attachment.start();
self.spawn_workers().await;
self.spawn_workers();
Ok(())
}
async fn stop(&self) -> () {
Expand Down

0 comments on commit 64bcf94

Please sign in to comment.