YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-01 18:25:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp: uring: improve log messages

Browse source
This commit is contained in:
Joakim Frostegård 2023-03-08 14:23:59 +01:00
parent d862da2aef
commit 1be6d4fa61
1 changed files with 13 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

20
aquatic_udp/src/workers/socket/uring/mod.rs
View file

@ -196,7 +196,7 @@ impl SocketWorker {
break; break;
} }
Err(send_buffers::Error::SerializationFailed(err)) => { Err(send_buffers::Error::SerializationFailed(err)) => {
::log::error!("write response to buffer: {:#}", err); ::log::error!("Failed serializing response: {:#}", err);
} }
} }
} else { } else {
@ -245,7 +245,7 @@ impl SocketWorker {
break; break;
} }
Err(send_buffers::Error::SerializationFailed(err)) => { Err(send_buffers::Error::SerializationFailed(err)) => {
::log::error!("write response to buffer: {:#}", err); ::log::error!("Failed serializing response: {:#}", err);
} }
} }
} }
@ -291,7 +291,7 @@ impl SocketWorker {
if result < 0 { if result < 0 {
::log::error!( ::log::error!(
"send: {:#}", "Couldn't send response: {:#}",
::std::io::Error::from_raw_os_error(-result) ::std::io::Error::from_raw_os_error(-result)
); );
} else if self.config.statistics.active() { } else if self.config.statistics.active() {
@ -337,8 +337,14 @@ impl SocketWorker {
let result = cqe.result(); let result = cqe.result();
if result < 0 { if result < 0 {
// Will produce ENOBUFS if there were no free buffers if -result == libc::ENOBUFS {
::log::warn!("recv: {:#}", ::std::io::Error::from_raw_os_error(-result)); ::log::warn!("recv failed due to lack of buffers, try increasing ring size");
} else {
::log::warn!(
"recv failed: {:#}",
::std::io::Error::from_raw_os_error(-result)
);
}
return; return;
} }
@ -347,12 +353,12 @@ impl SocketWorker {
match self.buf_ring.get_buf(result as u32, cqe.flags()) { match self.buf_ring.get_buf(result as u32, cqe.flags()) {
Ok(Some(buffer)) => buffer, Ok(Some(buffer)) => buffer,
Ok(None) => { Ok(None) => {
::log::error!("Couldn't get buffer"); ::log::error!("Couldn't get recv buffer");
return; return;
} }
Err(err) => { Err(err) => {
::log::error!("Couldn't get buffer: {:#}", err); ::log::error!("Couldn't get recv buffer: {:#}", err);
return; return;
} }