diff --git a/aquatic_udp/src/workers/socket/uring/mod.rs b/aquatic_udp/src/workers/socket/uring/mod.rs index 779ec4e..14fc2a2 100644 --- a/aquatic_udp/src/workers/socket/uring/mod.rs +++ b/aquatic_udp/src/workers/socket/uring/mod.rs @@ -34,7 +34,8 @@ use super::storage::PendingScrapeResponseSlab; use super::validator::ConnectionValidator; use super::{create_socket, EXTRA_PACKET_SIZE_IPV4, EXTRA_PACKET_SIZE_IPV6}; -const BUF_LEN: usize = 8192; +const RESPONSE_BUF_LEN: usize = 8192; +const REQUEST_BUF_LEN: usize = 4096; const USER_DATA_RECV: u64 = u64::MAX; const USER_DATA_PULSE_TIMEOUT: u64 = u64::MAX - 1; @@ -119,7 +120,7 @@ impl SocketWorker { let buf_ring = buf_ring::Builder::new(0) .ring_entries(ring_entries) - .buf_len(BUF_LEN) + .buf_len(REQUEST_BUF_LEN) .build() .unwrap(); diff --git a/aquatic_udp/src/workers/socket/uring/send_buffers.rs b/aquatic_udp/src/workers/socket/uring/send_buffers.rs index b6fdd21..bb23573 100644 --- a/aquatic_udp/src/workers/socket/uring/send_buffers.rs +++ b/aquatic_udp/src/workers/socket/uring/send_buffers.rs @@ -6,7 +6,7 @@ use io_uring::opcode::SendMsg; use crate::config::Config; -use super::{BUF_LEN, SOCKET_IDENTIFIER}; +use super::{RESPONSE_BUF_LEN, SOCKET_IDENTIFIER}; pub enum Error { NoBuffers, @@ -35,7 +35,7 @@ impl ResponseType { struct SendBuffer { name_v4: UnsafeCell, name_v6: UnsafeCell, - bytes: UnsafeCell<[u8; BUF_LEN]>, + bytes: UnsafeCell<[u8; RESPONSE_BUF_LEN]>, iovec: UnsafeCell, msghdr: UnsafeCell, free: bool, @@ -61,7 +61,7 @@ impl SendBuffer { sin6_addr: libc::in6_addr { s6_addr: [0; 16] }, sin6_scope_id: 0, }), - bytes: UnsafeCell::new([0; BUF_LEN]), + bytes: UnsafeCell::new([0; RESPONSE_BUF_LEN]), iovec: UnsafeCell::new(libc::iovec { iov_base: null_mut(), iov_len: 0,