From fa02376403d06d86a956fd4b0a3f133044ee6611 Mon Sep 17 00:00:00 2001
From: Floriane TUERNAL SABOTINOV <ftuertinov@proton.me>
Date: Tue, 26 Aug 2025 13:44:59 +0200
Subject: [PATCH] packet forwarding spans

---
 nym-node/src/node/mixnet/packet_forwarding/mod.rs | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/nym-node/src/node/mixnet/packet_forwarding/mod.rs b/nym-node/src/node/mixnet/packet_forwarding/mod.rs
index e397124ee0..9e9271fb28 100644
--- a/nym-node/src/node/mixnet/packet_forwarding/mod.rs
+++ b/nym-node/src/node/mixnet/packet_forwarding/mod.rs
@@ -13,7 +13,7 @@ use nym_sphinx_forwarding::packet::MixPacket;
 use nym_task::ShutdownToken;
 use std::io;
 use tokio::time::Instant;
-use tracing::{debug, error, trace, warn};
+use tracing::{debug, error, instrument, trace, warn};
 
 pub(crate) mod global;
 
@@ -53,6 +53,7 @@ impl<C, F> PacketForwarder<C, F> {
         self.packet_sender.clone()
     }
 
+    #[instrument(skip_all)]
     fn forward_packet(&mut self, packet: MixPacket)
     where
         C: SendWithoutResponse,
@@ -76,6 +77,7 @@ impl<C, F> PacketForwarder<C, F> {
     }
 
     /// Upon packet being finished getting delayed, forward it to the mixnet.
+    #[instrument(skip_all)]
     fn handle_done_delaying(&mut self, packet: Expired<MixPacket>)
     where
         C: SendWithoutResponse,
@@ -85,6 +87,7 @@ impl<C, F> PacketForwarder<C, F> {
         self.forward_packet(delayed_packet);
     }
 
+    #[instrument(skip_all)]
     fn handle_new_packet(&mut self, new_packet: PacketToForward)
     where
         C: SendWithoutResponse,
@@ -127,6 +130,9 @@ impl<C, F> PacketForwarder<C, F> {
             .update_packet_forwarder_queue_size(channel_size)
     }
 
+    #[instrument(skip_all, name = "run_packet_forwarder",
+        level = "debug"
+    )]
     pub async fn run(&mut self)
     where
         C: SendWithoutResponse,