feat(net): prepare the poller task for network interfaces (#636)

Signed-off-by: Yuuki Takano <ytakanoster@gmail.com>

Author: ytakano

applications/awkernel_services/src/network_service.rs

@@ -8,6 +8,7 @@ use awkernel_async_lib::{
 const NETWORK_SERVICE_RENDEZVOUS: &str = "/awkernel/network_service";
 
 const GARBAGE_COLLECTOR_NAME: &str = "[Awkernel] TCP garbage collector";
+const NETWORK_IF_POLLER_NAME: &str = "[Awkernel] Network interface poller";
 
 type ProtoInterruptHandler = Recv<(), Send<(), Eps>>;
 type ChanProtoInterruptHandlerDual = Chan<(), <ProtoInterruptHandler as HasDual>::Dual>;
@@ -22,6 +23,13 @@ pub async fn run() {
     )
     .await;
 
+    awkernel_async_lib::spawn(
+        NETWORK_IF_POLLER_NAME.into(),
+        network_interface_poller(),
+        SchedulerType::PrioritizedFIFO(0),
+    )
+    .await;
+
     let mut ch_irq_handlers = BTreeMap::new();
     let mut ch_poll_handlers = BTreeMap::new();
     let mut ch_tick_handlers = BTreeMap::new();
@@ -101,6 +109,18 @@ pub async fn run() {
     }
 }
 
+async fn network_interface_poller() {
+    loop {
+        let n = awkernel_lib::net::poll(); // Poll network devices.
+
+        if n == 0 {
+            awkernel_async_lib::sleep(Duration::from_secs(1)).await;
+        } else {
+            awkernel_async_lib::r#yield().await;
+        }
+    }
+}
+
 async fn spawn_handlers(
     if_status: awkernel_lib::net::IfStatus,
     ch_irq_handlers: &mut BTreeMap<u16, ChanProtoInterruptHandlerDual>,

awkernel_lib/src/net.rs

@@ -604,11 +604,14 @@ pub fn poll_interface(interface_id: u64) -> bool {
 ///
 /// 1. `NetManager.read()`
 /// 2. `POLL_WAKERS.lock()`
-pub fn poll() {
+pub fn poll() -> usize {
     let net_manager = NET_MANAGER.read();
 
+    let mut n = 0;
+
     for (interface_id, if_net) in net_manager.interfaces.iter() {
         if if_net.is_poll_mode && if_net.net_device.poll() {
+            n += 1;
             let mut node = MCSNode::new();
             let mut w = POLL_WAKERS.lock(&mut node);
 
@@ -628,6 +631,8 @@ pub fn poll() {
             }
         }
     }
+
+    n
 }
 
 /// If some packets are processed, true is returned.

kernel/src/main.rs

@@ -81,7 +81,6 @@ fn main<Info: Debug>(kernel_info: KernelInfo<Info>) {
             }
 
             let dur = wake_task(); // Wake executable tasks periodically.
-            awkernel_lib::net::poll(); // Poll network devices.
 
             #[cfg(feature = "std")]
             {