use core::{ cell::UnsafeCell, fmt::Debug, ops::{Deref, DerefMut}, }; use alloc::{ string::String, sync::{Arc, Weak}, }; use smoltcp::{phy, wire}; use virtio_drivers::{device::net::VirtIONet, transport::Transport}; use super::NetDriver; use crate::{ driver::{ base::{ device::{bus::Bus, driver::Driver, Device, IdTable}, kobject::{KObjType, KObject, KObjectState}, }, virtio::virtio_impl::HalImpl, }, kerror, kinfo, libs::spinlock::SpinLock, net::{generate_iface_id, NET_DRIVERS}, time::Instant, }; use system_error::SystemError; /// @brief Virtio网络设备驱动(加锁) pub struct VirtioNICDriver { pub inner: Arc>>, } impl Clone for VirtioNICDriver { fn clone(&self) -> Self { return VirtioNICDriver { inner: self.inner.clone(), }; } } /// @brief 网卡驱动的包裹器,这是为了获取网卡驱动的可变引用而设计的。 /// 由于smoltcp的设计,导致需要在poll的时候获取网卡驱动的可变引用, /// 同时需要在token的consume里面获取可变引用。为了避免双重加锁,所以需要这个包裹器。 struct VirtioNICDriverWrapper(UnsafeCell>); unsafe impl Send for VirtioNICDriverWrapper {} unsafe impl Sync for VirtioNICDriverWrapper {} impl Deref for VirtioNICDriverWrapper { type Target = VirtioNICDriver; fn deref(&self) -> &Self::Target { unsafe { &*self.0.get() } } } impl DerefMut for VirtioNICDriverWrapper { fn deref_mut(&mut self) -> &mut Self::Target { unsafe { &mut *self.0.get() } } } impl VirtioNICDriverWrapper { fn force_get_mut(&self) -> &mut VirtioNICDriver { unsafe { &mut *self.0.get() } } } impl Debug for VirtioNICDriver { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { f.debug_struct("VirtioNICDriver").finish() } } pub struct VirtioInterface { driver: VirtioNICDriverWrapper, iface_id: usize, iface: SpinLock, name: String, } impl Debug for VirtioInterface { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { f.debug_struct("VirtioInterface") .field("driver", self.driver.deref()) .field("iface_id", &self.iface_id) .field("iface", &"smoltcp::iface::Interface") .field("name", &self.name) .finish() } } impl VirtioInterface { pub fn new(mut driver: VirtioNICDriver) -> Arc { let iface_id = generate_iface_id(); let mut iface_config = smoltcp::iface::Config::new(); // todo: 随机设定这个值。 // 参见 https://docs.rs/smoltcp/latest/smoltcp/iface/struct.Config.html#structfield.random_seed iface_config.random_seed = 12345; iface_config.hardware_addr = Some(wire::HardwareAddress::Ethernet( smoltcp::wire::EthernetAddress(driver.inner.lock().mac_address()), )); let iface = smoltcp::iface::Interface::new(iface_config, &mut driver); let driver: VirtioNICDriverWrapper = VirtioNICDriverWrapper(UnsafeCell::new(driver)); let result = Arc::new(VirtioInterface { driver, iface_id, iface: SpinLock::new(iface), name: format!("eth{}", iface_id), }); return result; } } impl VirtioNICDriver { pub fn new(driver_net: VirtIONet) -> Self { let mut iface_config = smoltcp::iface::Config::new(); // todo: 随机设定这个值。 // 参见 https://docs.rs/smoltcp/latest/smoltcp/iface/struct.Config.html#structfield.random_seed iface_config.random_seed = 12345; iface_config.hardware_addr = Some(wire::HardwareAddress::Ethernet( smoltcp::wire::EthernetAddress(driver_net.mac_address()), )); let inner: Arc>> = Arc::new(SpinLock::new(driver_net)); let result = VirtioNICDriver { inner }; return result; } } pub struct VirtioNetToken { driver: VirtioNICDriver, rx_buffer: Option, } impl<'a, T: Transport> VirtioNetToken { pub fn new( driver: VirtioNICDriver, rx_buffer: Option, ) -> Self { return Self { driver, rx_buffer }; } } impl phy::Device for VirtioNICDriver { type RxToken<'a> = VirtioNetToken where Self: 'a; type TxToken<'a> = VirtioNetToken where Self: 'a; fn receive( &mut self, _timestamp: smoltcp::time::Instant, ) -> Option<(Self::RxToken<'_>, Self::TxToken<'_>)> { match self.inner.lock().receive() { Ok(buf) => Some(( VirtioNetToken::new(self.clone(), Some(buf)), VirtioNetToken::new(self.clone(), None), )), Err(virtio_drivers::Error::NotReady) => None, Err(err) => panic!("VirtIO receive failed: {}", err), } } fn transmit(&mut self, _timestamp: smoltcp::time::Instant) -> Option> { // kdebug!("VirtioNet: transmit"); if self.inner.lock_irqsave().can_send() { // kdebug!("VirtioNet: can send"); return Some(VirtioNetToken::new(self.clone(), None)); } else { // kdebug!("VirtioNet: can not send"); return None; } } fn capabilities(&self) -> phy::DeviceCapabilities { let mut caps = phy::DeviceCapabilities::default(); // 网卡的最大传输单元. 请与IP层的MTU进行区分。这个值应当是网卡的最大传输单元,而不是IP层的MTU。 caps.max_transmission_unit = 2000; /* Maximum burst size, in terms of MTU. The network device is unable to send or receive bursts large than the value returned by this function. If None, there is no fixed limit on burst size, e.g. if network buffers are dynamically allocated. */ caps.max_burst_size = Some(1); return caps; } } impl phy::TxToken for VirtioNetToken { fn consume(self, len: usize, f: F) -> R where F: FnOnce(&mut [u8]) -> R, { // // 为了线程安全,这里需要对VirtioNet进行加【写锁】,以保证对设备的互斥访问。 let mut driver_net = self.driver.inner.lock(); let mut tx_buf = driver_net.new_tx_buffer(len); let result = f(tx_buf.packet_mut()); driver_net.send(tx_buf).expect("virtio_net send failed"); return result; } } impl phy::RxToken for VirtioNetToken { fn consume(self, f: F) -> R where F: FnOnce(&mut [u8]) -> R, { // 为了线程安全,这里需要对VirtioNet进行加【写锁】,以保证对设备的互斥访问。 let mut rx_buf = self.rx_buffer.unwrap(); let result = f(rx_buf.packet_mut()); self.driver .inner .lock() .recycle_rx_buffer(rx_buf) .expect("virtio_net recv failed"); result } } /// @brief virtio-net 驱动的初始化与测试 pub fn virtio_net(transport: T) { let driver_net: VirtIONet = match VirtIONet::::new(transport, 4096) { Ok(net) => net, Err(_) => { kerror!("VirtIONet init failed"); return; } }; let mac = smoltcp::wire::EthernetAddress::from_bytes(&driver_net.mac_address()); let driver: VirtioNICDriver = VirtioNICDriver::new(driver_net); let iface = VirtioInterface::new(driver); let name = iface.name.clone(); // 将网卡的接口信息注册到全局的网卡接口信息表中 NET_DRIVERS .write_irqsave() .insert(iface.nic_id(), iface.clone()); kinfo!( "Virtio-net driver init successfully!\tNetDevID: [{}], MAC: [{}]", name, mac ); } impl Driver for VirtioInterface { fn id_table(&self) -> Option { todo!() } fn add_device(&self, _device: Arc) { todo!() } fn delete_device(&self, _device: &Arc) { todo!() } fn devices(&self) -> alloc::vec::Vec> { todo!() } fn bus(&self) -> Option> { todo!() } fn set_bus(&self, _bus: Option>) { todo!() } } impl NetDriver for VirtioInterface { fn mac(&self) -> smoltcp::wire::EthernetAddress { let mac: [u8; 6] = self.driver.inner.lock().mac_address(); return smoltcp::wire::EthernetAddress::from_bytes(&mac); } #[inline] fn nic_id(&self) -> usize { return self.iface_id; } #[inline] fn name(&self) -> String { return self.name.clone(); } fn update_ip_addrs(&self, ip_addrs: &[wire::IpCidr]) -> Result<(), SystemError> { if ip_addrs.len() != 1 { return Err(SystemError::EINVAL); } self.iface.lock().update_ip_addrs(|addrs| { let dest = addrs.iter_mut().next(); if let None = dest { addrs.push(ip_addrs[0]).expect("Push ipCidr failed: full"); } else { let dest = dest.unwrap(); *dest = ip_addrs[0]; } }); return Ok(()); } fn poll(&self, sockets: &mut smoltcp::iface::SocketSet) -> Result<(), SystemError> { let timestamp: smoltcp::time::Instant = Instant::now().into(); let mut guard = self.iface.lock(); let poll_res = guard.poll(timestamp, self.driver.force_get_mut(), sockets); // todo: notify!!! // kdebug!("Virtio Interface poll:{poll_res}"); if poll_res { return Ok(()); } return Err(SystemError::EAGAIN_OR_EWOULDBLOCK); } #[inline(always)] fn inner_iface(&self) -> &SpinLock { return &self.iface; } // fn as_any_ref(&'static self) -> &'static dyn core::any::Any { // return self; // } } impl KObject for VirtioInterface { fn as_any_ref(&self) -> &dyn core::any::Any { self } fn set_inode(&self, _inode: Option>) { todo!() } fn inode(&self) -> Option> { todo!() } fn parent(&self) -> Option> { todo!() } fn set_parent(&self, _parent: Option>) { todo!() } fn kset(&self) -> Option> { todo!() } fn set_kset(&self, _kset: Option>) { todo!() } fn kobj_type(&self) -> Option<&'static dyn crate::driver::base::kobject::KObjType> { todo!() } fn name(&self) -> String { self.name.clone() } fn set_name(&self, _name: String) { todo!() } fn kobj_state( &self, ) -> crate::libs::rwlock::RwLockReadGuard { todo!() } fn kobj_state_mut( &self, ) -> crate::libs::rwlock::RwLockWriteGuard { todo!() } fn set_kobj_state(&self, _state: KObjectState) { todo!() } fn set_kobj_type(&self, _ktype: Option<&'static dyn KObjType>) { todo!() } } // 向编译器保证,VirtioNICDriver在线程之间是安全的. // 由于smoltcp只会在token内真正操作网卡设备,并且在VirtioNetToken的consume // 方法内,会对VirtioNet进行加【写锁】,因此,能够保证对设备操作的的互斥访问, // 因此VirtioNICDriver在线程之间是安全的。 // unsafe impl Sync for VirtioNICDriver {} // unsafe impl Send for VirtioNICDriver {}