reactor
/
JKHKQKJV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

reduce logging

main
_ 2025-02-23 20:55:29 +00:00
parent 40e4a30166
commit 4548f9daee
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/server.rs
View File

@ -73,7 +73,7 @@ impl App {
} }
Poll::Ready(Ok(None)) => client.closed = true, Poll::Ready(Ok(None)) => client.closed = true,
Poll::Ready(Ok(Some(ToServer::ChatLine { line, sequence }))) => { Poll::Ready(Ok(Some(ToServer::ChatLine { line, sequence }))) => {
tracing::info!(id = client.id, ?line); tracing::debug!(id = client.id, ?line);
if sequence != client.sequence { if sequence != client.sequence {
tracing::error!( tracing::error!(
expected = client.sequence, expected = client.sequence,
@ -82,6 +82,7 @@ impl App {
); );
return Poll::Ready(Err(anyhow!("Sequence mismatch"))); return Poll::Ready(Err(anyhow!("Sequence mismatch")));
} }
tracing::info!(?sequence, id = client.id);
client.sequence += 1; client.sequence += 1;
new_messages.push(Rc::new(ToClient::ChatLine { new_messages.push(Rc::new(ToClient::ChatLine {
id: client.id, id: client.id,
@ -151,7 +152,7 @@ impl Client {
}; };
cx.waker().wake_by_ref(); cx.waker().wake_by_ref();
tracing::info!("Got network data"); tracing::debug!("Got network data");
let frame = match frame { let frame = match frame {
Err(err) => return Poll::Ready(Err(err).context("Network framing decode error")), Err(err) => return Poll::Ready(Err(err).context("Network framing decode error")),