Struct IcmpSocket 

pub struct IcmpSocket {
    icmp_layer: Weak<IcmpLayer>,
    identifier: u16,
    sequence: AtomicU16,
    expected_sequence: AtomicU16,
    local_addr: Mutex<Option<SocketAddress>>,
    remote_addr: RwLock<Option<SocketAddress>>,
    recv_queue: Mutex<VecDeque<(Vec<u8>, SocketAddress)>>,
    recv_waker: Waker,
    nonblocking: RwLock<bool>,
}

Fields

icmp_layer: Weak<IcmpLayer>

identifier: u16

sequence: AtomicU16

expected_sequence: AtomicU16

local_addr: Mutex<Option<SocketAddress>>

remote_addr: RwLock<Option<SocketAddress>>

recv_queue: Mutex<VecDeque<(Vec<u8>, SocketAddress)>>

recv_waker: Waker

nonblocking: RwLock<bool>

Implementations

impl IcmpSocket

fn new(icmp_layer: Weak<IcmpLayer>, identifier: u16) -> Arc<Self>

fn deliver_reply(&self, payload: Vec<u8>, src_ip: Ipv4Address, sequence: u16)

Trait Implementations

impl ControlOps for IcmpSocket

fn control(&self, command: u32, arg: usize) -> Result<i32, &'static str>

Perform a control operation

fn supported_control_commands(&self) -> Vec<(u32, &'static str)>

Get a list of supported control commands

impl SocketControl for IcmpSocket

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 IcmpSocket

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 as_control_ops(&self) -> Option<&dyn ControlOps>

Optional capability: expose control operations interface

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

impl StreamIpcOps for IcmpSocket

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 IcmpSocket

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