diff options
| author | Marcel Müller <m.mueller@ifm.com> | 2022-05-20 10:35:08 +0200 |
|---|---|---|
| committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-20 12:54:00 +0200 |
| commit | a42bd5ad94527f7a30523ea78b440228127107b8 (patch) | |
| tree | 2c2f08ae9cb4741b63d7814ea059d41ea1fbd00c | |
| parent | 43ed68145e7044c0d8f170af794d71c2fa93599a (diff) | |
Add tracing to send in tedge_api
Signed-off-by: Marcel Müller <m.mueller@ifm.com>
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
Reviewed-by: Matthias Beyer <matthias.beyer@ifm.com>
| -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); |