packet forwarding spans

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,