Struct UdpLayer 

pub struct UdpLayer {
    port_map: RwLock<BTreeMap<u16, Weak<UdpSocket>>>,
    next_ephemeral_port: Mutex<u16>,
    stats: RwLock<NetworkLayerStats>,
    self_weak: Weak<UdpLayer>,
}

UDP layer

Manages UDP port bindings and handles UDP datagrams.

Fields

port_map: RwLock<BTreeMap<u16, Weak<UdpSocket>>>

Port-to-socket mapping for receiving datagrams

next_ephemeral_port: Mutex<u16>

Port allocation (ephemeral ports start from 49152)

stats: RwLock<NetworkLayerStats>

Statistics

self_weak: Weak<UdpLayer>

Implementations

impl UdpLayer

pub fn new() -> Arc<Self>

Create a new UDP layer

pub fn init(network_manager: &NetworkManager)

Initialize and register the UDP layer with NetworkManager

Registers with NetworkManager and registers itself with Ipv4Layer for protocol number 17 (UDP).

Panics

Panics if Ipv4Layer is not registered (must be initialized first).

pub fn create_socket(&self) -> Arc<UdpSocket>

Create a new UDP socket

pub fn allocate_port(&self) -> u16

Allocate an ephemeral port

pub fn register_port(&self, port: u16, socket: Weak<UdpSocket>)

Register a socket for a specific port

pub fn unregister_socket(&self, port: u16, socket: &Weak<UdpSocket>)

Unregister a specific socket from a port

Only removes the port entry if the registered socket matches.

pub fn find_socket(&self, port: u16) -> Option<Arc<UdpSocket>>

Find socket for a destination port

pub fn configure_socket( &self, socket: Weak<UdpSocket>, config: &SocketConfig, ) -> Result<(), SocketError>

Configure a UDP socket (bind)

pub fn send_datagram( &self, socket: &UdpSocket, dest_ip: [u8; 4], dest_port: u16, data: Vec<u8>, ) -> Result<(), SocketError>

Send a UDP datagram

pub fn receive_datagram( &self, src_ip: Ipv4Address, src_port: u16, dst_port: u16, data: Vec<u8>, )

Receive a UDP datagram

impl UdpLayer

pub fn receive_packet( &self, src_ip: Ipv4Address, _dst_ip: Ipv4Address, packet: &[u8], ) -> Result<(), SocketError>

Receive a UDP datagram

Trait Implementations

impl NetworkLayer for UdpLayer

fn register_protocol(&self, _proto_num: u16, _handler: Arc<dyn NetworkLayer>)

Register a protocol handler for this layer

fn send( &self, _packet: &[u8], _context: &LayerContext, _next_layers: &[Arc<dyn NetworkLayer>], ) -> Result<(), SocketError>

Send a packet through this layer

fn receive( &self, packet: &[u8], context: Option<&LayerContext>, ) -> Result<(), SocketError>

Receive and process a packet at this layer

fn name(&self) -> &'static str

Get layer name for debugging

fn stats(&self) -> NetworkLayerStats

Get layer statistics

fn as_any(&self) -> &dyn Any

Cast to Any for safe downcasting

fn configure( &self, config: &SocketConfig, next_layers: &[Arc<dyn NetworkLayer>], ) -> Result<(), SocketError>

Configure this layer with socket-specific parameters