diff --git a/iroh-cli/src/commands/blob.rs b/iroh-cli/src/commands/blob.rs index 6e4c0aeba2..d128640917 100644 --- a/iroh-cli/src/commands/blob.rs +++ b/iroh-cli/src/commands/blob.rs @@ -277,8 +277,10 @@ impl BlobCommands { Some(OutputTarget::Stdout) => { // we asserted above that `OutputTarget::Stdout` is only permitted if getting a // single hash and not a hashseq. + tracing::debug!("starting blobs read {}", hash); let mut blob_read = iroh.blobs().read(hash).await?; tokio::io::copy(&mut blob_read, &mut tokio::io::stdout()).await?; + tracing::debug!("finished blobs read {}", hash); } Some(OutputTarget::Path(path)) => { let absolute = std::env::current_dir()?.join(&path); diff --git a/iroh/src/node.rs b/iroh/src/node.rs index 13b038ae51..ea2d722d53 100644 --- a/iroh/src/node.rs +++ b/iroh/src/node.rs @@ -331,16 +331,19 @@ impl NodeInner { } // Abort rpc tasks. + debug!("shutting down RPC tasks ({})", rpc_join_set.len()); rpc_join_set.shutdown().await; self.shutdown(protocols).await; // Abort remaining tasks. + debug!("shutting down remaining tasks ({})", join_set.len()); join_set.shutdown().await; } /// Shutdown the different parts of the node concurrently. async fn shutdown(&self, protocols: Arc) { + debug!("shutting down node"); let error_code = Closed::ProviderTerminating; // Shutdown future for the docs engine, if enabled.