From 22427dc8d07b5f90e28c956e984a8386643bef3d Mon Sep 17 00:00:00 2001 From: Florian Klink Date: Thu, 28 Dec 2023 13:36:21 +0100 Subject: refactor(tvix/castore/bin/tvix-store) don't import std::io Make it more clear this is not tokio::io. Change-Id: Ic2fa56f0baf1c200b6631098d556388a19629a45 Reviewed-on: https://cl.tvl.fyi/c/depot/+/10452 Autosubmit: flokli Tested-by: BuildkiteCI Reviewed-by: raitobezarius --- tvix/store/src/bin/tvix-store.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'tvix/store/src') diff --git a/tvix/store/src/bin/tvix-store.rs b/tvix/store/src/bin/tvix-store.rs index 445515b9c08f..3efe6c098274 100644 --- a/tvix/store/src/bin/tvix-store.rs +++ b/tvix/store/src/bin/tvix-store.rs @@ -3,7 +3,6 @@ use data_encoding::BASE64; use futures::future::try_join_all; use nix_compat::store_path; use nix_compat::store_path::StorePath; -use std::io; use std::path::Path; use std::path::PathBuf; use std::sync::Arc; @@ -169,7 +168,7 @@ async fn main() -> Result<(), Box> { .with(if cli.json { Some( tracing_subscriber::fmt::Layer::new() - .with_writer(io::stderr.with_max_level(level)) + .with_writer(std::io::stderr.with_max_level(level)) .json(), ) } else { @@ -178,7 +177,7 @@ async fn main() -> Result<(), Box> { .with(if !cli.json { Some( tracing_subscriber::fmt::Layer::new() - .with_writer(io::stderr.with_max_level(level)) + .with_writer(std::io::stderr.with_max_level(level)) .pretty(), ) } else { @@ -265,7 +264,7 @@ async fn main() -> Result<(), Box> { let tasks = paths .into_iter() .map(|path| { - let task: JoinHandle> = tokio::task::spawn({ + let task: JoinHandle> = tokio::task::spawn({ let blob_service = blob_service.clone(); let directory_service = directory_service.clone(); let path_info_service = path_info_service.clone(); @@ -384,7 +383,7 @@ async fn main() -> Result<(), Box> { info!("interrupt received, unmounting…"); tokio::task::spawn_blocking(move || fuse_daemon.unmount()).await??; info!("unmount occured, terminating…"); - Ok::<_, io::Error>(()) + Ok::<_, std::io::Error>(()) }) .await??; } -- cgit 1.4.1