Struct UdpSocket 

pub struct UdpSocket {
    local_addr: RwLock<Option<SocketAddress>>,
    remote_addr: RwLock<Option<SocketAddress>>,
    send_buffer: Mutex<Vec<Vec<u8>>>,
    recv_buffer: Mutex<Vec<Vec<u8>>>,
    state: RwLock<SocketState>,
    udp_layer: Arc<UdpLayer>,
    self_weak: Weak<UdpSocket>,
    recv_waker: Mutex<Option<Arc<Waker>>>,
    send_waker: Mutex<Option<Arc<Waker>>>,
    blocking_mode: Mutex<bool>,
}

UDP socket

Implements SocketObject for UDP datagram communication.

Fields

local_addr: RwLock<Option<SocketAddress>>

Local address

remote_addr: RwLock<Option<SocketAddress>>

Remote address (for connected sockets)

send_buffer: Mutex<Vec<Vec<u8>>>

Send buffer

recv_buffer: Mutex<Vec<Vec<u8>>>

Receive buffer

state: RwLock<SocketState>

Socket state

udp_layer: Arc<UdpLayer>

Reference to UDP layer

self_weak: Weak<UdpSocket>

Weak self reference for registration

recv_waker: Mutex<Option<Arc<Waker>>>

Receive waker for blocking I/O

send_waker: Mutex<Option<Arc<Waker>>>

Send waker for blocking I/O

blocking_mode: Mutex<bool>

Blocking mode (default: true)

Implementations

impl UdpSocket

pub fn new(udp_layer: Arc<UdpLayer>) -> Arc<Self>

Create a new UDP socket

pub fn deliver_datagram(&self, data: Vec<u8>)

Deliver received datagram to this socket

Trait Implementations

impl CloneOps for UdpSocket

fn custom_clone(&self) -> KernelObject

Perform a custom clone operation and return the cloned object

impl Selectable for UdpSocket

fn current_ready(&self, interest: ReadyInterest) -> ReadySet

Return current readiness for the given interest set.

fn wait_until_ready( &self, interest: ReadyInterest, trapframe: &mut Trapframe, timeout_ticks: Option<u64>, ) -> SelectWaitOutcome

Block the current task using the provided trapframe until the interest becomes ready or the optional timeout (in ticks) expires.

fn set_nonblocking(&self, enabled: bool)

Enable or disable non-blocking I/O semantics on this object.

fn is_nonblocking(&self) -> bool

Query whether non-blocking I/O semantics are enabled on this object.

impl SocketControl for UdpSocket

fn bind(&self, address: &SocketAddress) -> Result<(), SocketError>

Bind socket to an address

fn connect(&self, address: &SocketAddress) -> Result<(), SocketError>

Connect to a remote address

fn listen(&self, _backlog: usize) -> Result<(), SocketError>

Listen for incoming connections (for stream sockets)

fn accept(&self) -> Result<Arc<dyn SocketObject>, SocketError>

Accept an incoming connection (for listening sockets) Returns a new socket for the accepted connection

fn getpeername(&self) -> Result<SocketAddress, SocketError>

Get socket peer address

fn getsockname(&self) -> Result<SocketAddress, SocketError>

Get socket local address

fn shutdown(&self, _how: ShutdownHow) -> Result<(), SocketError>

Shutdown socket for reading, writing, or both

fn is_connected(&self) -> bool

Check if socket is connected

fn state(&self) -> SocketState

Get socket state

impl SocketObject for UdpSocket

fn socket_type(&self) -> SocketType

Get socket type (Stream, Datagram, etc.)

fn socket_domain(&self) -> SocketDomain

Get socket domain (Local, Inet, Inet6, etc.)

fn socket_protocol(&self) -> SocketProtocol

Get socket protocol

fn as_any(&self) -> &dyn Any

Cast to Any for safe downcasting

fn sendto( &self, data: &[u8], address: &SocketAddress, _flags: u32, ) -> Result<usize, SocketError>

Send data to a specific address (for datagram sockets) For stream sockets, address is ignored and data is sent to connected peer

fn recvfrom( &self, buffer: &mut [u8], _flags: u32, ) -> Result<(usize, SocketAddress), SocketError>

Receive data with source address (for datagram sockets) For stream sockets, returns Unspecified address

fn as_selectable(&self) -> Option<&dyn Selectable>

Optional capability: expose select/pselect readiness/wait interface

fn as_control_ops(&self) -> Option<&dyn ControlOps>

Optional capability: expose control operations interface

impl StreamIpcOps for UdpSocket

fn is_connected(&self) -> bool

Check if the stream IPC object is still connected/valid

fn peer_count(&self) -> usize

Get the number of active peers (readers/writers/endpoints)

fn description(&self) -> String

Get a human-readable description of this IPC object

impl StreamOps for UdpSocket

fn read(&self, buffer: &mut [u8]) -> Result<usize, StreamError>

Read data from the stream

fn write(&self, data: &[u8]) -> Result<usize, StreamError>

Write data to the stream