diff options
-rw-r--r-- | tvix/castore/src/directoryservice/grpc.rs | 4 | ||||
-rw-r--r-- | tvix/castore/src/directoryservice/utils.rs | 5 |
2 files changed, 5 insertions, 4 deletions
diff --git a/tvix/castore/src/directoryservice/grpc.rs b/tvix/castore/src/directoryservice/grpc.rs index fbb9cce64e88..fe410a38257d 100644 --- a/tvix/castore/src/directoryservice/grpc.rs +++ b/tvix/castore/src/directoryservice/grpc.rs @@ -234,6 +234,7 @@ impl GRPCPutter { #[async_trait] impl DirectoryPutter for GRPCPutter { + #[instrument(level = "trace", skip_all, fields(directory.digest=%directory.digest()), err)] async fn put(&mut self, directory: proto::Directory) -> Result<(), crate::Error> { match self.rq { // If we're not already closed, send the directory to directory_sender. @@ -253,7 +254,8 @@ impl DirectoryPutter for GRPCPutter { } } - /// Closes the stream for sending, and returns the value + /// Closes the stream for sending, and returns the value. + #[instrument(level = "trace", skip_all, ret, err)] async fn close(&mut self) -> Result<B3Digest, crate::Error> { // get self.rq, and replace it with None. // This ensures we can only close it once. diff --git a/tvix/castore/src/directoryservice/utils.rs b/tvix/castore/src/directoryservice/utils.rs index 52d227d60b59..6fa1a9e5fda0 100644 --- a/tvix/castore/src/directoryservice/utils.rs +++ b/tvix/castore/src/directoryservice/utils.rs @@ -9,7 +9,6 @@ use std::collections::{HashSet, VecDeque}; use tonic::async_trait; use tracing::instrument; use tracing::warn; -use tracing::Level; /// Traverses a [proto::Directory] from the root to the children. /// @@ -105,7 +104,7 @@ impl<DS: DirectoryService> SimplePutter<DS> { #[async_trait] impl<DS: DirectoryService + 'static> DirectoryPutter for SimplePutter<DS> { - #[instrument(skip_all, fields(directory.digest=%directory.digest()), err)] + #[instrument(level = "trace", skip_all, fields(directory.digest=%directory.digest()), err)] async fn put(&mut self, directory: proto::Directory) -> Result<(), Error> { if self.closed { return Err(Error::StorageError("already closed".to_string())); @@ -119,7 +118,7 @@ impl<DS: DirectoryService + 'static> DirectoryPutter for SimplePutter<DS> { Ok(()) } - #[instrument(skip_all, ret(Display, level=Level::TRACE), err)] + #[instrument(level = "trace", skip_all, ret, err)] async fn close(&mut self) -> Result<B3Digest, Error> { if self.closed { return Err(Error::StorageError("already closed".to_string())); |