Struct TcpLayer 

pub struct TcpLayer {
    port_map: RwLock<BTreeMap<u16, Vec<Weak<TcpSocket>>>>,
    stats: RwLock<NetworkLayerStats>,
    self_weak: Weak<TcpLayer>,
}

TCP layer

Manages TCP port bindings and routes packets to sockets.

Fields

port_map: RwLock<BTreeMap<u16, Vec<Weak<TcpSocket>>>>

Port-to-socket mapping for receiving packets

stats: RwLock<NetworkLayerStats>

Statistics

self_weak: Weak<TcpLayer>

Implementations

impl TcpLayer

pub fn new() -> Arc<Self>

Create a new TCP layer

pub fn init(network_manager: &NetworkManager)

Initialize and register the TCP layer with NetworkManager

Registers with NetworkManager and registers itself with Ipv4Layer for protocol number 6 (TCP).

Panics

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

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

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

Register a socket for a specific port

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

Unregister a specific socket from a port

Only removes the given socket from the port’s socket list. The port entry itself is removed only when no sockets remain.

pub fn find_socket( &self, port: u16, src_ip: Ipv4Address, src_port: u16, ) -> Option<Arc<TcpSocket>>

Find socket for a destination port

pub fn find_listening_socket(&self, port: u16) -> Option<Arc<TcpSocket>>

pub fn receive_segment( &self, src_ip: Ipv4Address, header: TcpHeader, data: &[u8], )

Process incoming TCP segment

impl TcpLayer

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

Receive a TCP segment with IPv4 addressing information

Trait Implementations

impl NetworkLayer for TcpLayer

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