From 915aea7d9e45a951d172d771d35cf1a40d3f2338 Mon Sep 17 00:00:00 2001
From: posvyatokum <posvyatokum@edu.hse.ru>
Date: Fri, 8 Mar 2024 16:00:42 +0000
Subject: [PATCH] remove tracing spans from network

---
 chain/network/src/peer/peer_actor.rs          | 31 -------------------
 .../src/peer_manager/peer_manager_actor.rs    |  6 ----
 2 files changed, 37 deletions(-)

diff --git a/chain/network/src/peer/peer_actor.rs b/chain/network/src/peer/peer_actor.rs
index 6c2517387bd..d7fe3ba1a0e 100644
--- a/chain/network/src/peer/peer_actor.rs
+++ b/chain/network/src/peer/peer_actor.rs
@@ -382,11 +382,6 @@ impl PeerActor {
 
     fn send_message_with_encoding(&self, msg: &PeerMessage, enc: Encoding) {
         let msg_type: &str = msg.msg_variant();
-        let _span = tracing::trace_span!(
-            target: "network",
-            "send_message_with_encoding",
-            msg_type)
-        .entered();
         // Skip sending block and headers if we received it or header from this peer.
         // Record block requests in tracker.
         match msg {
@@ -923,12 +918,6 @@ impl PeerActor {
         msg_hash: CryptoHash,
         body: RoutedMessageBody,
     ) -> Result<Option<RoutedMessageBody>, ReasonForBan> {
-        let _span = tracing::trace_span!(
-            target: "network",
-            "receive_routed_message",
-            "type" = <&RoutedMessageBody as Into<&'static str>>::into(&body)
-        )
-        .entered();
         Ok(match body {
             RoutedMessageBody::TxStatusRequest(account_id, tx_hash) => network_state
                 .client
@@ -1002,7 +991,6 @@ impl PeerActor {
         conn: &connection::Connection,
         msg: PeerMessage,
     ) {
-        let _span = tracing::trace_span!(target: "network", "receive_message").entered();
         // This is a fancy way to clone the message iff event_sink is non-null.
         // If you have a better idea on how to achieve that, feel free to improve this.
         let message_processed_event = self
@@ -1104,13 +1092,6 @@ impl PeerActor {
         conn: Arc<connection::Connection>,
         peer_msg: PeerMessage,
     ) {
-        let _span = tracing::trace_span!(
-            target: "network",
-            "handle_msg_ready",
-            "type" = <&PeerMessage as Into<&'static str>>::into(&peer_msg)
-        )
-        .entered();
-
         // Clones message iff someone is listening on the sink. Should be in tests only.
         let message_processed_event = self
             .network_state
@@ -1395,7 +1376,6 @@ impl PeerActor {
         conn: Arc<connection::Connection>,
         rtu: RoutingTableUpdate,
     ) {
-        let _span = tracing::trace_span!(target: "network", "handle_sync_routing_table").entered();
         if let Err(ban_reason) = network_state.add_edges(&clock, rtu.edges.clone()).await {
             conn.stop(Some(ban_reason));
         }
@@ -1435,8 +1415,6 @@ impl PeerActor {
         conn: Arc<connection::Connection>,
         distance_vector: DistanceVector,
     ) {
-        let _span = tracing::trace_span!(target: "network", "handle_distance_vector").entered();
-
         if conn.peer_info.id != distance_vector.root {
             conn.stop(Some(ReasonForBan::InvalidDistanceVector));
             return;
@@ -1581,15 +1559,6 @@ impl actix::Handler<stream::Frame> for PeerActor {
     type Result = ();
     #[perf]
     fn handle(&mut self, stream::Frame(msg): stream::Frame, ctx: &mut Self::Context) {
-        let _span = tracing::debug_span!(
-            target: "network",
-            "handle",
-            handler = "bytes",
-            actor = "PeerActor",
-            msg_len = msg.len(),
-            peer = %self.peer_info)
-        .entered();
-
         if self.closing_reason.is_some() {
             tracing::warn!(target: "network", "Received message from closing connection {:?}. Ignoring", self.peer_type);
             return;
diff --git a/chain/network/src/peer_manager/peer_manager_actor.rs b/chain/network/src/peer_manager/peer_manager_actor.rs
index e95f2ae12bd..e2e292b37d0 100644
--- a/chain/network/src/peer_manager/peer_manager_actor.rs
+++ b/chain/network/src/peer_manager/peer_manager_actor.rs
@@ -562,7 +562,6 @@ impl PeerManagerActor {
         mut interval: time::Duration,
         (default_interval, max_interval): (time::Duration, time::Duration),
     ) {
-        let _span = tracing::trace_span!(target: "network", "monitor_peers_trigger").entered();
         let _timer =
             metrics::PEER_MANAGER_TRIGGER_TIME.with_label_values(&["monitor_peers"]).start_timer();
 
@@ -700,7 +699,6 @@ impl PeerManagerActor {
     }
 
     fn push_network_info_trigger(&self, ctx: &mut actix::Context<Self>, interval: time::Duration) {
-        let _span = tracing::trace_span!(target: "network", "push_network_info_trigger").entered();
         let network_info = self.get_network_info();
         let _timer = metrics::PEER_MANAGER_TRIGGER_TIME
             .with_label_values(&["push_network_info"])
@@ -728,10 +726,6 @@ impl PeerManagerActor {
         msg: NetworkRequests,
         ctx: &mut actix::Context<Self>,
     ) -> NetworkResponses {
-        let msg_type: &str = msg.as_ref();
-        let _span =
-            tracing::trace_span!(target: "network", "handle_msg_network_requests", msg_type)
-                .entered();
         metrics::REQUEST_COUNT_BY_TYPE_TOTAL.with_label_values(&[msg.as_ref()]).inc();
         match msg {
             NetworkRequests::Block { block } => {