YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp: lower log level from info to debug for several mio statements

Browse source
This commit is contained in:
Joakim Frostegård 2024-01-02 17:00:00 +01:00
parent 4249a7f48d
commit 6870a9e9c4
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
crates/udp/src/workers/socket/mio.rs
View file

@ -125,7 +125,7 @@ impl SocketWorker {
self.read_and_handle_requests(pending_scrape_valid_until); self.read_and_handle_requests(pending_scrape_valid_until);
} }
PollMode::SkipReceiving => { PollMode::SkipReceiving => {
::log::info!("Postponing receiving requests because swarm worker channel is full. This means that the OS will be relied on to buffer incoming packets. To prevent this, raise config.worker_channel_size."); ::log::debug!("Postponing receiving requests because swarm worker channel is full. This means that the OS will be relied on to buffer incoming packets. To prevent this, raise config.worker_channel_size.");
self.polling_mode = PollMode::SkipPolling; self.polling_mode = PollMode::SkipPolling;
} }
@ -192,7 +192,7 @@ impl SocketWorker {
match self.socket.recv_from(&mut self.buffer[..]) { match self.socket.recv_from(&mut self.buffer[..]) {
Ok((bytes_read, src)) => { Ok((bytes_read, src)) => {
if src.port() == 0 { if src.port() == 0 {
::log::info!("Ignored request from {} because source port is zero", src); ::log::debug!("Ignored request from {} because source port is zero", src);
continue; continue;
} }
@ -501,7 +501,7 @@ impl SocketWorker {
|| (err.kind() == ErrorKind::WouldBlock) => || (err.kind() == ErrorKind::WouldBlock) =>
{ {
if resend_buffer.len() < config.network.resend_buffer_max_len { if resend_buffer.len() < config.network.resend_buffer_max_len {
::log::info!("Adding response to resend queue, since sending it to {} failed with: {:#}", addr, err); ::log::debug!("Adding response to resend queue, since sending it to {} failed with: {:#}", addr, err);
resend_buffer.push((response.into_owned(), canonical_addr)); resend_buffer.push((response.into_owned(), canonical_addr));
} else { } else {