diff options
-rw-r--r-- | Cargo.lock | 5 | ||||
-rw-r--r-- | crates/core/tedge_api/Cargo.toml | 1 | ||||
-rw-r--r-- | crates/core/tedge_api/src/address.rs | 3 |
3 files changed, 7 insertions, 2 deletions
@@ -2871,6 +2871,7 @@ dependencies = [ "tokio", "tokio-util 0.7.0", "toml", + "tracing", ] [[package]] @@ -3299,9 +3300,9 @@ dependencies = [ [[package]] name = "tracing-attributes" -version = "0.1.18" +version = "0.1.21" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f4f480b8f81512e825f337ad51e94c1eb5d3bbdf2b363dcd01e2b19a9ffe3f8e" +checksum = "cc6b8ad3567499f98a1db7a752b07a7c8c7c7c34c332ec00effb2b0027974b7c" dependencies = [ "proc-macro2 1.0.38", "quote 1.0.18", diff --git a/crates/core/tedge_api/Cargo.toml b/crates/core/tedge_api/Cargo.toml index 619e769e..5546ed2b 100644 --- a/crates/core/tedge_api/Cargo.toml +++ b/crates/core/tedge_api/Cargo.toml @@ -20,6 +20,7 @@ termcolor = "1.1.3" termimad = "0.20.1" nu-ansi-term = "0.45.1" tedge_config_derive = { version = "0.1.0", path = "tedge_config_derive" } +tracing = "0.1" [dev-dependencies] pretty_assertions = "1.2.1" diff --git a/crates/core/tedge_api/src/address.rs b/crates/core/tedge_api/src/address.rs index 007be13f..5052d621 100644 --- a/crates/core/tedge_api/src/address.rs +++ b/crates/core/tedge_api/src/address.rs @@ -2,6 +2,7 @@ use std::{marker::PhantomData, sync::Arc, time::Duration}; use futures::future::BoxFuture; use tokio::sync::RwLock; +use tracing::{instrument, trace}; use crate::{ message::MessageType, @@ -48,8 +49,10 @@ impl InnerMessageSender { Self { send_provider } } + #[instrument(skip_all, level = "trace")] async fn send(&self, message: InternalMessage) -> Result<(), InternalMessage> { let lock = self.send_provider.read().await; + trace!(sender_exists = ?lock.is_some(), "Checking for internal sender"); if let Some(sender) = &*lock { let sender = (*sender)(message, ShouldWait::Wait); |