From 425614caaf60b7c6629108f94889f2210c5ef3df Mon Sep 17 00:00:00 2001 From: rsdy Date: Mon, 11 Dec 2023 20:50:04 +0100 Subject: [PATCH] Eek --- zerostash-fuse/src/mount.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/zerostash-fuse/src/mount.rs b/zerostash-fuse/src/mount.rs index 50a9f04..1089cef 100644 --- a/zerostash-fuse/src/mount.rs +++ b/zerostash-fuse/src/mount.rs @@ -150,7 +150,7 @@ impl OpenFileHandle { commit_queue, }; - tokio::spawn(ingester.start()) + parent.runtime.spawn(ingester.start()) }; let commit_task = { @@ -162,12 +162,12 @@ impl OpenFileHandle { reader: parent.stash.storage_reader().unwrap(), hasher: parent.stash.hasher().unwrap(), }; - tokio::spawn(committer.start()) + parent.runtime.spawn(committer.start()) }; Some({ let entry = shared_entry.clone(Ordering::Relaxed, &Guard::new()); - tokio::spawn(async move { + parent.runtime.spawn(async move { _ = tokio::join!(merger_task, commit_task); entry })