rename span

input-output-hk · Sep 24, 2021 · 32072d2 · 32072d2
1 parent 1513501
commit 32072d2
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/jormungandr/src/fragment/pool.rs b/jormungandr/src/fragment/pool.rs
@@ -119,7 +119,7 @@ impl Pool {
         for fragment in fragments.by_ref() {
             let id = fragment.id();
 
-            let span = tracing::debug_span!("fragment", %id);
+            let span = tracing::debug_span!("pool_filter_fragment", %id);
             let _enter = span.enter();
 
             if self.logs.exists(id) {
@@ -201,10 +201,8 @@ impl Pool {
         if fail_fast {
             for fragment in fragments {
                 let id = fragment.id();
-                let span = tracing::debug_span!("fragment", %id);
-                let _enter = span.enter();
                 tracing::error!(
-                    "rejected due to fail_fast and one of previous fragments being invalid"
+                    fragment_id=%id, "rejected due to fail_fast and one of previous fragments being invalid"
                 );
                 rejected.push(RejectedFragmentInfo {
                     id,
@@ -222,11 +220,7 @@ impl Pool {
         tracing::debug!("{} of the received fragments were added to the pool", count);
         let fragment_logs: Vec<_> = new_fragments
             .iter()
-            .map(move |fragment| {
-                let id = fragment.id();
-                tracing::debug!(fragment_id=?id, "inserted fragment to the pool");
-                FragmentLog::new(id, origin)
-            })
+            .map(move |fragment| FragmentLog::new(fragment.id(), origin))
             .collect();
         self.logs.insert_all_pending(fragment_logs);