From 12856c687d92157134f5c73bd69c1c32d414f11e Mon Sep 17 00:00:00 2001 From: soruh Date: Sat, 18 Mar 2023 22:17:24 +0100 Subject: [PATCH] change log levels --- src/main.rs | 10 +++++----- src/packets.rs | 6 +++--- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src/main.rs b/src/main.rs index dfa6baa..90bcdab 100644 --- a/src/main.rs +++ b/src/main.rs @@ -21,7 +21,7 @@ use tokio::{ sync::Mutex, time::{sleep, timeout, Instant}, }; -use tracing::{debug, error, info, warn, Level}; +use tracing::{error, info, trace, warn, Level}; use crate::packets::{dyn_ip_update, PacketKind, REJECT_OOP, REJECT_TIMEOUT}; use crate::ports::{AllowedPorts, PortHandler, PortStatus}; @@ -447,13 +447,13 @@ async fn connection_handler( let mut last_ping_received_at = Instant::now(); let result = loop { - debug!( + trace!( seconds = SEND_PING_INTERVAL .saturating_sub(last_ping_sent_at.elapsed()) .as_secs(), "next ping in" ); - debug!( + trace!( seconds = PING_TIMEOUT .saturating_sub(last_ping_received_at.elapsed()) .as_secs(), @@ -472,14 +472,14 @@ async fn connection_handler( packet.recv_into(&mut reader).await?; if packet.kind() == PacketKind::Ping { - debug!("received ping"); + trace!("received ping"); last_ping_received_at = Instant::now(); } else { break Result::Packet { packet } } }, _ = sleep(send_next_ping_in) => { - debug!("sending ping"); + trace!("sending ping"); writer.write_all(bytemuck::bytes_of(& Header { kind: PacketKind::Ping.raw(), length: 0 })).await?; last_ping_sent_at = Instant::now(); } diff --git a/src/packets.rs b/src/packets.rs index c81fc9b..b506e2c 100644 --- a/src/packets.rs +++ b/src/packets.rs @@ -6,7 +6,7 @@ use tokio::{ io::{AsyncReadExt, AsyncWriteExt}, net::tcp::{ReadHalf, WriteHalf}, }; -use tracing::info; +use tracing::debug; pub const REJECT_OOP: &[u8; 6] = b"\x04\x04oop\x00"; pub const REJECT_TIMEOUT: &[u8; 10] = b"\x04\x08timeout\x00"; @@ -184,7 +184,7 @@ pub async fn dyn_ip_update( pin: u16, port: u16, ) -> anyhow::Result { - info!(%number, %port, "starting dyn ip update"); + debug!(%number, %port, "starting dyn ip update"); let mut packet = Packet::default(); packet.header = Header { @@ -235,7 +235,7 @@ pub async fn dyn_ip_update( _ => bail!("server returned unexpected packet"), }; - info!(?result, "finished dyn ip update"); + debug!(?result, "finished dyn ip update"); result }