incorporating remarks

Author: r41d

core/dtn7/src/cla/ecla/processing.rs

@@ -208,7 +208,7 @@ pub fn handle_packet(connector_name: String, addr: String, packet: Packet) {
                 let service_block: ServiceBlock =
                     serde_cbor::from_slice(pdp.service_block.as_slice()).unwrap();
 
-                info!("Received beacon: ecla={} eid={} addr={} service_block={}", me.name, pdp.eid, pdp.addr, service_block);
+                debug!("Received beacon: ecla={} eid={} addr={} service_block={}", me.name, pdp.eid, pdp.addr, service_block);
 
                 peers_add(DtnPeer::new(
                     pdp.eid.clone(),

core/dtn7/src/dtnd/httpd.rs

@@ -38,9 +38,7 @@ use bp7::EndpointID;
 use http::StatusCode;
 use humansize::format_size;
 use humansize::DECIMAL;
-use log::info;
-use log::trace;
-use log::{debug, warn};
+use log::{trace, debug, info, warn};
 use serde::Serialize;
 use std::collections::HashMap;
 use std::convert::{TryFrom, TryInto};
@@ -450,7 +448,7 @@ async fn insert_get(extract::RawQuery(query): extract::RawQuery) -> Result<Strin
 async fn insert_post(body: bytes::Bytes) -> Result<String, (StatusCode, &'static str)> {
     let bytes = body.to_vec();
     let b_len = bytes.len();
-    debug!("Received: {:?} bytes", b_len);
+    trace!("Received: {:?} bytes", b_len);
     if let Ok(bndl) = bp7::Bundle::try_from(bytes.to_vec()) {
         debug!(
             "Sending bundle {} to {}",

core/dtn7/src/routing/epidemic.rs

@@ -2,7 +2,7 @@ use super::RoutingAgent;
 use crate::routing::{RoutingCmd, RoutingNotifcation};
 use crate::PEERS;
 use async_trait::async_trait;
-use log::debug;
+use log::{debug, trace};
 use std::collections::{HashMap, HashSet};
 use tokio::sync::mpsc;
 use tokio::sync::mpsc::Sender;
@@ -85,7 +85,7 @@ async fn handle_routing_cmd(mut rx: mpsc::Receiver<RoutingCmd>) {
                 let mut clas = Vec::new();
                 let mut delete_afterwards = false;
                 for (_, p) in (*PEERS.lock()).iter() {
-                    debug!("checking peer {:?} (node_name={})", p, p.node_name());
+                    trace!("checking peer {:?} (node_name={})", p, p.node_name());
                     if !core.contains(bp.id(), &p.node_name()) {
                         if let Some(cla) = p.first_cla() {
                             core.add(bp.id().to_string(), p.node_name().clone());

core/dtn7/src/routing/flooding.rs

@@ -2,7 +2,7 @@ use super::RoutingAgent;
 use crate::routing::RoutingCmd;
 use crate::PEERS;
 use async_trait::async_trait;
-use log::debug;
+use log::{debug, trace};
 use tokio::sync::mpsc;
 use tokio::sync::mpsc::Sender;
 
@@ -29,7 +29,7 @@ impl FloodingRoutingAgent {
                         let mut clas = Vec::new();
                         debug!("checking PEERS due to SenderForBundle request");
                         for (_, p) in (*PEERS.lock()).iter() {
-                            debug!("checking peer {:?} (p.first_cla={:?})", p, p.first_cla());
+                            trace!("checking peer {:?} (p.first_cla={:?})", p, p.first_cla());
                             if let Some(cla) = p.first_cla() {
                                 clas.push(cla);
                             }