net_backend/
null.rs

1// Copyright (c) Microsoft Corporation.
2// Licensed under the MIT License.
3
4//! Null (disconnected) endpoint.
5
6use crate::BufferAccess;
7use crate::Endpoint;
8use crate::MultiQueueSupport;
9use crate::Queue;
10use crate::QueueConfig;
11use crate::RssConfig;
12use crate::RxId;
13use crate::TxError;
14use crate::TxId;
15use crate::TxOffloadSupport;
16use crate::TxSegment;
17use crate::resolve::ResolveEndpointParams;
18use crate::resolve::ResolvedEndpoint;
19use async_trait::async_trait;
20use inspect::InspectMut;
21use net_backend_resources::null::NullHandle;
22use std::convert::Infallible;
23use std::task::Context;
24use std::task::Poll;
25use vm_resource::ResolveResource;
26use vm_resource::declare_static_resolver;
27use vm_resource::kind::NetEndpointHandleKind;
28
29pub struct NullResolver;
30
31declare_static_resolver! {
32    NullResolver,
33    (NetEndpointHandleKind, NullHandle),
34}
35
36impl ResolveResource<NetEndpointHandleKind, NullHandle> for NullResolver {
37    type Output = ResolvedEndpoint;
38    type Error = Infallible;
39
40    fn resolve(
41        &self,
42        _resource: NullHandle,
43        _input: ResolveEndpointParams,
44    ) -> Result<Self::Output, Self::Error> {
45        Ok(NullEndpoint::new().into())
46    }
47}
48
49/// An endpoint that never sends or receives any data.
50#[non_exhaustive]
51#[derive(InspectMut)]
52pub struct NullEndpoint {}
53
54impl NullEndpoint {
55    pub fn new() -> Self {
56        Self {}
57    }
58}
59
60#[async_trait]
61impl Endpoint for NullEndpoint {
62    fn endpoint_type(&self) -> &'static str {
63        "null"
64    }
65
66    async fn get_queues(
67        &mut self,
68        config: Vec<QueueConfig<'_>>,
69        _rss: Option<&RssConfig<'_>>,
70        queues: &mut Vec<Box<dyn Queue>>,
71    ) -> anyhow::Result<()> {
72        queues.extend(config.iter().map(|_| Box::new(NullQueue) as _));
73        Ok(())
74    }
75
76    async fn stop(&mut self) {}
77
78    fn is_ordered(&self) -> bool {
79        true
80    }
81
82    fn tx_offload_support(&self) -> TxOffloadSupport {
83        TxOffloadSupport {
84            ipv4_header: true,
85            tcp: true,
86            udp: true,
87            tso: true,
88        }
89    }
90
91    fn multiqueue_support(&self) -> MultiQueueSupport {
92        MultiQueueSupport {
93            max_queues: u16::MAX,
94            indirection_table_size: 128,
95        }
96    }
97}
98
99/// A queue that never sends or receives data.
100#[derive(InspectMut)]
101struct NullQueue;
102
103impl Queue for NullQueue {
104    fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<()> {
105        Poll::Pending
106    }
107
108    fn rx_avail(&mut self, _done: &[RxId]) {}
109
110    fn rx_poll(&mut self, _packets: &mut [RxId]) -> anyhow::Result<usize> {
111        Ok(0)
112    }
113
114    fn tx_avail(&mut self, packets: &[TxSegment]) -> anyhow::Result<(bool, usize)> {
115        Ok((true, packets.len()))
116    }
117
118    fn tx_poll(&mut self, _done: &mut [TxId]) -> Result<usize, TxError> {
119        Ok(0)
120    }
121
122    fn buffer_access(&mut self) -> Option<&mut dyn BufferAccess> {
123        None
124    }
125}
net_backend/null.rs

net_backend/
null.rs
