diff --git a/examples/multi_login.rs b/examples/multi_login.rs index 122a3d2..39aecdf 100644 --- a/examples/multi_login.rs +++ b/examples/multi_login.rs @@ -12,7 +12,7 @@ async fn main() { .with(console_layer) .with( tracing_subscriber::fmt::layer() - .with_filter(tracing_subscriber::EnvFilter::new("debug")), + .with_filter(tracing_subscriber::EnvFilter::new("trace")), ) .init(); tracing::info!("tokio-tracing initialized."); diff --git a/mania/src/core/business.rs b/mania/src/core/business.rs index a754e3c..d25d659 100644 --- a/mania/src/core/business.rs +++ b/mania/src/core/business.rs @@ -77,7 +77,7 @@ static LOGIC_MAP: Lazy = Lazy::new(|| { map.entry(tid) .or_insert_with(Vec::new) .push(item.event_handle_fn); - tracing::debug!( + tracing::trace!( "Registered event handler {:?} for type: {:?}", item.event_handle_fn, tid @@ -93,12 +93,12 @@ pub async fn dispatch_logic( ) -> &dyn ServerEvent { let tid = event.as_any().type_id(); if let Some(fns) = LOGIC_MAP.get(&tid) { - tracing::debug!("[{}] Found {} handlers for {:?}.", flow, fns.len(), event); + tracing::trace!("[{}] Found {} handlers for {:?}.", flow, fns.len(), event); for handle_fn in fns.iter() { handle_fn(event, handle.to_owned(), flow).await; } } else { - tracing::debug!("[{}] No handler found for {:?}", flow, event); + tracing::trace!("[{}] No handler found for {:?}", flow, event); } event } @@ -153,6 +153,8 @@ impl Business { continue; } }; + tracing::debug!("Incoming packet: {}", packet.command()); + tracing::trace!("Full: {:?}", packet); let handle = self.handle.clone(); tokio::spawn(async move { if let Err(e) = handle.dispatch_sso_packet(packet).await { @@ -285,12 +287,13 @@ impl BusinessHandle { } async fn post_packet(&self, packet: SsoPacket) -> BusinessResult<()> { + tracing::debug!("Outgoing packet: {}", packet.command()); + tracing::trace!("Full: {:?}", packet); let packet = packet.build(&self.context); Ok(self.sender.load().send(packet).await?) } async fn send_packet(&self, packet: SsoPacket) -> BusinessResult { - tracing::debug!("sending packet: {:?}", packet); let sequence = packet.sequence(); let (tx, rx) = oneshot::channel::>(); self.pending_requests.insert(sequence, tx); diff --git a/mania/src/core/business/messaging_logic.rs b/mania/src/core/business/messaging_logic.rs index fad66ed..8335965 100644 --- a/mania/src/core/business/messaging_logic.rs +++ b/mania/src/core/business/messaging_logic.rs @@ -20,7 +20,7 @@ async fn messaging_logic( handle: Arc, flow: LogicFlow, ) -> &dyn ServerEvent { - tracing::debug!("[{}] Handling event: {:?}", flow, event); + tracing::trace!("[{}] Handling event: {:?}", flow, event); match flow { LogicFlow::InComing => messaging_logic_incoming(event, handle).await, LogicFlow::OutGoing => messaging_logic_outgoing(event, handle).await, diff --git a/mania/src/core/business/wt_logic.rs b/mania/src/core/business/wt_logic.rs index e616b28..d1cb709 100644 --- a/mania/src/core/business/wt_logic.rs +++ b/mania/src/core/business/wt_logic.rs @@ -13,7 +13,6 @@ async fn messaging_logic( handle: Arc, flow: LogicFlow, ) -> &dyn ServerEvent { - tracing::debug!("[{}] Handling event: {:?}", flow, event); match flow { LogicFlow::InComing => messaging_logic_incoming(event, handle).await, LogicFlow::OutGoing => event, diff --git a/mania/src/core/event.rs b/mania/src/core/event.rs index 964347b..cf129ae 100644 --- a/mania/src/core/event.rs +++ b/mania/src/core/event.rs @@ -73,11 +73,6 @@ static EVENT_MAP: Lazy = Lazy::new(|| { pub async fn resolve_event(packet: SsoPacket, context: &Arc) -> CEParseResult { // Lagrange.Core.Internal.Context.ServiceContext.ResolveEventByPacket let payload = PacketReader::new(packet.payload()).section(|p| p.bytes()); - tracing::debug!( - "receive SSO event: {}, payload: {:?}", - packet.command(), - hex::encode(&payload) - ); let Some(parse) = EVENT_MAP.get(packet.command()) else { return Err(EventError::UnsupportedEvent(packet.command().to_string())); }; diff --git a/mania/src/core/socket.rs b/mania/src/core/socket.rs index 2d2d6e1..5282749 100644 --- a/mania/src/core/socket.rs +++ b/mania/src/core/socket.rs @@ -4,7 +4,6 @@ use std::sync::{Arc, Weak}; use byteorder::{BigEndian, ByteOrder}; use bytes::{Bytes, BytesMut}; -use log::debug; use tokio::io::{AsyncReadExt, AsyncWriteExt}; use tokio::net::tcp::{OwnedReadHalf, OwnedWriteHalf}; use tokio::sync::mpsc::{Receiver, Sender}; @@ -103,7 +102,7 @@ async fn recv_loop(mut stream: OwnedReadHalf, channel: Sender) -> Result< buffer.resize(packet_length as usize, 0); BigEndian::write_u32(&mut buffer, packet_length); stream.read_exact(&mut buffer[4..]).await?; - debug!("Received packet (len= {:?})", buffer.len()); + tracing::trace!("Received packet (len= {:?})", buffer.len()); if channel.send(buffer.split().freeze()).await.is_err() { return Ok(()); // dropped diff --git a/mania/src/core/tlv/t106.rs b/mania/src/core/tlv/t106.rs index 2824203..54b87c8 100644 --- a/mania/src/core/tlv/t106.rs +++ b/mania/src/core/tlv/t106.rs @@ -36,7 +36,6 @@ impl TlvSer for T106 { } fn serialize(&self, p: PacketBuilder) -> PacketBuilder { - tracing::warn!("T106: &self.temp = {}", hex::encode(&self.temp)); p.tlv(0x106, |p| p.bytes(&self.temp)) } }