Struct NetworkManager 

pub struct NetworkManager {
    socket_factories: RwLock<BTreeMap<SocketDomain, SocketFactory>>,
    protocol_stacks: ProtocolStackManager,
    protocol_layers: RwLock<BTreeMap<String, Arc<dyn NetworkLayer>>>,
    named_sockets: RwLock<BTreeMap<String, Weak<dyn SocketObject>>>,
    connections: RwLock<BTreeMap<SocketId, Arc<dyn SocketObject>>>,
    socket_to_id: RwLock<BTreeMap<usize, SocketId>>,
    next_socket_id: AtomicUsize,
    interfaces: RwLock<BTreeMap<String, Arc<dyn NetworkInterface>>>,
    default_interface: RwLock<Option<String>>,
    arp_cache: RwLock<BTreeMap<u32, ArpCacheEntry>>,
    network_config: RwLock<NetworkConfig>,
}

Network Manager - Global socket and connection manager

Fields

socket_factories: RwLock<BTreeMap<SocketDomain, SocketFactory>>

Socket factories per domain (registered by ABI modules)

protocol_stacks: ProtocolStackManager

Protocol stacks for network protocols (TCP/IP, UDP, etc.)

protocol_layers: RwLock<BTreeMap<String, Arc<dyn NetworkLayer>>>

Protocol layers registry (shared instances like VFS filesystems)

named_sockets: RwLock<BTreeMap<String, Weak<dyn SocketObject>>>

Named sockets namespace (path/name -> socket)

connections: RwLock<BTreeMap<SocketId, Arc<dyn SocketObject>>>

Active socket connections by ID

socket_to_id: RwLock<BTreeMap<usize, SocketId>>

Reverse mapping: socket pointer address -> socket ID for O(1) lookups

next_socket_id: AtomicUsize

Next socket ID counter

interfaces: RwLock<BTreeMap<String, Arc<dyn NetworkInterface>>>

Registered network interfaces

default_interface: RwLock<Option<String>>

Default interface name

arp_cache: RwLock<BTreeMap<u32, ArpCacheEntry>>

ARP cache

network_config: RwLock<NetworkConfig>

Network configuration

Implementations

impl NetworkManager

fn new() -> Self

Create a new NetworkManager instance

pub fn get_manager() -> &'static NetworkManager

Get the global NetworkManager instance

pub fn init() -> &'static NetworkManager

Initialize the global NetworkManager

Initializes all protocol layers in dependency order:

1. Ethernet (no dependencies)
2. IPv4, ARP (depend on Ethernet)
3. ICMP, UDP, TCP (depend on IPv4)

pub fn register_interface( &self, name: &str, interface: Arc<dyn NetworkInterface>, ) -> Result<(), &'static str>

pub fn get_interface(&self, name: &str) -> Option<Arc<dyn NetworkInterface>>

pub fn get_default_interface(&self) -> Option<Arc<dyn NetworkInterface>>

pub fn set_default_interface(&self, name: &str)

pub fn list_interfaces(&self) -> Vec<String>

fn configure_protocol_layers_with_interface( &self, interface: Arc<dyn NetworkInterface>, )

pub fn arp_lookup(&self, ip: &Ipv4Address) -> Option<MacAddress>

pub fn arp_cache_add(&self, ip: Ipv4Address, mac: MacAddress)

pub fn send_arp_request( &self, target_ip: Ipv4Address, ) -> Result<(), &'static str>

pub fn resolve_mac(&self, ip: Ipv4Address) -> Result<MacAddress, &'static str>

pub fn get_config(&self) -> NetworkConfig

pub fn set_config(&self, config: NetworkConfig)

pub fn set_default_gateway(&self, gateway: Ipv4Address)

pub fn get_default_gateway(&self) -> Option<Ipv4Address>

pub fn handle_received_packet( &self, _interface_name: &str, packet: &DevicePacket, )

fn handle_arp_packet(&self, packet: &DevicePacket)

fn handle_ipv4_packet(&self, packet: &DevicePacket)

pub fn register_socket_factory( &self, domain: SocketDomain, factory: SocketFactory, )

pub fn create_socket( &self, domain: SocketDomain, socket_type: SocketType, protocol: SocketProtocol, ) -> Result<KernelObject, SocketError>

pub fn register_protocol_stack(&self, stack: Arc<dyn ProtocolStack>)

pub fn register_layer(&self, name: &str, layer: Arc<dyn NetworkLayer>)

pub fn unregister_layer(&self, name: &str) -> Option<Arc<dyn NetworkLayer>>

pub fn get_layer(&self, name: &str) -> Option<Arc<dyn NetworkLayer>>

pub fn list_layers(&self) -> Vec<String>

pub fn layer_count(&self) -> usize

pub fn has_layer(&self, name: &str) -> bool

pub fn register_named_socket( &self, name: &str, socket: Arc<dyn SocketObject>, ) -> Result<(), SocketError>

pub fn lookup_named_socket( &self, name: &str, ) -> Result<Arc<dyn SocketObject>, SocketError>

pub fn unregister_named_socket(&self, name: &str)

pub fn get_socket(&self, socket_id: SocketId) -> Option<Arc<dyn SocketObject>>

pub fn register_socket_with_id( &self, socket_id: SocketId, socket: Arc<dyn SocketObject>, ) -> Result<(), SocketError>

pub fn remove_socket(&self, socket_id: SocketId)

pub fn allocate_socket_id( &self, socket: Arc<dyn SocketObject>, ) -> Result<SocketId, SocketError>

pub fn get_socket_id(&self, socket: &Arc<dyn SocketObject>) -> Option<SocketId>

pub fn connection_count(&self) -> usize

pub fn named_socket_count(&self) -> usize