Struct UdpSocket 

pub struct UdpSocket<const TIMER_HZ: u32, const L: usize> { /* private fields */ }

A User Datagram Protocol socket.

A UDP socket is bound to a specific endpoint, and owns transmit and receive packet buffers.

Implementations

impl<const TIMER_HZ: u32, const L: usize> UdpSocket<TIMER_HZ, L>

pub fn new(socket_id: u8) -> UdpSocket<TIMER_HZ, L>

Create an UDP socket with the given buffers.

pub fn handle(&self) -> SocketHandle

Return the socket handle.

pub fn update_handle(&mut self, handle: SocketHandle)

pub fn endpoint(&self) -> Option<SocketAddr>

Return the bound endpoint.

pub fn state(&self) -> State

Return the connection state, in terms of the UDP connection.

pub fn set_state(&mut self, state: State)

pub fn should_update_available_data(&mut self, ts: Instant<TIMER_HZ>) -> bool

pub fn recycle(&self, ts: Instant<TIMER_HZ>) -> bool

pub fn closed_by_remote(&mut self, ts: Instant<TIMER_HZ>)

pub fn set_available_data(&mut self, available_data: usize)

Set available data.

pub fn get_available_data(&self) -> usize

Get the number of bytes available to ingress.

pub fn rx_window(&self) -> usize

pub fn bind<T: Into<SocketAddr>>(&mut self, endpoint: T) -> Result<(), Error>

Bind the socket to the given endpoint.

This function returns Err(Error::Illegal) if the socket was open (see is_open), and Err(Error::Unaddressable) if the port in the given endpoint is zero.

pub fn is_open(&self) -> bool

Check whether the socket is open.

pub fn can_recv(&self) -> bool

Check whether the receive buffer is full.

pub fn recv<'b, F, R>(&'b mut self, f: F) -> Result<R, Error>

where F: FnOnce(&'b mut [u8]) -> (usize, R),

Dequeue a packet received from a remote endpoint, and return the endpoint as well as a pointer to the payload.

This function returns Err(Error::Exhausted) if the receive buffer is empty.

pub fn recv_slice(&mut self, data: &mut [u8]) -> Result<usize, Error>

Dequeue a packet received from a remote endpoint, copy the payload into the given slice, and return the amount of octets copied as well as the endpoint.

See also recv.

pub fn rx_enqueue_slice(&mut self, data: &[u8]) -> usize

pub fn peek(&mut self, size: usize) -> Result<&[u8], Error>

Peek at a packet received from a remote endpoint, and return the endpoint as well as a pointer to the payload without removing the packet from the receive buffer. This function otherwise behaves identically to recv.

It returns Err(Error::Exhausted) if the receive buffer is empty.

pub fn peek_slice(&mut self, data: &mut [u8]) -> Result<usize, Error>

Peek at a packet received from a remote endpoint, copy the payload into the given slice, and return the amount of octets copied as well as the endpoint without removing the packet from the receive buffer. This function otherwise behaves identically to recv_slice.

See also peek.

pub fn close(&mut self)

Trait Implementations

impl<const TIMER_HZ: u32, const L: usize> AnySocket<TIMER_HZ, L> for UdpSocket<TIMER_HZ, L>

fn downcast( ref_: SocketRef<'_, Socket<TIMER_HZ, L>>, ) -> Result<SocketRef<'_, Self>, Error>

impl<const TIMER_HZ: u32, const L: usize> Debug for UdpSocket<TIMER_HZ, L>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<const TIMER_HZ: u32, const L: usize> Into<Socket<TIMER_HZ, L>> for UdpSocket<TIMER_HZ, L>

fn into(self) -> Socket<TIMER_HZ, L>

Converts this type into the (usually inferred) input type.