about summary refs log tree commit diff
path: root/tvix/store/src
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2023-12-28T12·36+0100
committerclbot <clbot@tvl.fyi>2023-12-29T15·57+0000
commit22427dc8d07b5f90e28c956e984a8386643bef3d (patch)
tree99650b2c2b089de5a6aeda8d485fa15614c24b31 /tvix/store/src
parent46a372d5d73e3b600944489cc210163368eada2f (diff)
refactor(tvix/castore/bin/tvix-store) don't import std::io r/7268
Make it more clear this is not tokio::io.

Change-Id: Ic2fa56f0baf1c200b6631098d556388a19629a45
Reviewed-on: https://cl.tvl.fyi/c/depot/+/10452
Autosubmit: flokli <flokli@flokli.de>
Tested-by: BuildkiteCI
Reviewed-by: raitobezarius <tvl@lahfa.xyz>
Diffstat (limited to 'tvix/store/src')
-rw-r--r--tvix/store/src/bin/tvix-store.rs9
1 files changed, 4 insertions, 5 deletions
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<dyn std::error::Error>> {
         .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<dyn std::error::Error>> {
         .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<dyn std::error::Error>> {
             let tasks = paths
                 .into_iter()
                 .map(|path| {
-                    let task: JoinHandle<io::Result<()>> = tokio::task::spawn({
+                    let task: JoinHandle<std::io::Result<()>> = 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<dyn std::error::Error>> {
                 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??;
         }