diff --git a/src/runtime/mod.rs b/src/runtime/mod.rs index ba664998818ec5995e083ac074dc2eab9a78310b..1d8a9841ca0c7ec58c62c60d59f4dd9d7e189dcb 100644 --- a/src/runtime/mod.rs +++ b/src/runtime/mod.rs @@ -261,7 +261,7 @@ struct IdManager { } // Newtype wrapper around a byte buffer, used for UDP mediators to receive incoming datagrams. -struct UdpInBuffer { +struct IoByteBuffer { byte_vec: Vec, } @@ -285,7 +285,7 @@ struct EndpointManager { undelayed_messages: Vec<(usize, Msg)>, // ready to yield net_endpoint_store: EndpointStore, udp_endpoint_store: EndpointStore, - udp_in_buffer: UdpInBuffer, + io_byte_buffer: IoByteBuffer, } // A storage of endpoints, which keeps track of which components have raised @@ -902,7 +902,7 @@ impl Debug for SpecVal { self.0.fmt(f) } } -impl Default for UdpInBuffer { +impl Default for IoByteBuffer { fn default() -> Self { let mut byte_vec = Vec::with_capacity(Self::CAPACITY); unsafe { @@ -912,15 +912,15 @@ impl Default for UdpInBuffer { Self { byte_vec } } } -impl UdpInBuffer { - const CAPACITY: usize = u16::MAX as usize; +impl IoByteBuffer { + const CAPACITY: usize = u16::MAX as usize + 1000; fn as_mut_slice(&mut self) -> &mut [u8] { self.byte_vec.as_mut_slice() } } -impl Debug for UdpInBuffer { +impl Debug for IoByteBuffer { fn fmt(&self, f: &mut Formatter) -> std::fmt::Result { - write!(f, "UdpInBuffer") + write!(f, "IoByteBuffer") } }