ax-net 0.13.3

Unified network stack for TGOSKits (ArceOS, StarryOS, Axvisor)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! Fixed-owner notification for one network queue executor.

use ax_task::sync::irq::{IrqWaitCell, IrqWorkerWaiter};

/// Sticky hard-IRQ event consumed by one CPU-pinned queue executor.
pub(super) struct QueueNotification {
    event: IrqWaitCell,
}

impl QueueNotification {
    pub(super) const fn new() -> Self {
        Self {
            event: IrqWaitCell::new(),
        }
    }

    pub(super) fn notify(&self) {
        let _result = self.event.notify();
    }

    pub(super) fn wait(&self, waiter: &IrqWorkerWaiter) {
        waiter
            .wait(&self.event)
            .unwrap_or_else(|error| panic!("network queue executor notification failed: {error}"));
    }

    pub(super) fn wait_timeout(&self, waiter: &IrqWorkerWaiter, timeout: core::time::Duration) {
        let _timed_out = waiter
            .wait_timeout(&self.event, timeout)
            .unwrap_or_else(|error| panic!("network queue executor notification failed: {error}"));
    }
}