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            uso: true,
89        }
90    }
91
92    fn multiqueue_support(&self) -> MultiQueueSupport {
93        MultiQueueSupport {
94            max_queues: u16::MAX,
95            indirection_table_size: 128,
96        }
97    }
98}
99
100/// A queue that never sends or receives data.
101#[derive(InspectMut)]
102struct NullQueue;
103
104impl Queue for NullQueue {
105    fn poll_ready(&mut self, _cx: &mut Context<'_>, _pool: &mut dyn BufferAccess) -> Poll<()> {
106        Poll::Pending
107    }
108
109    fn rx_avail(&mut self, _pool: &mut dyn BufferAccess, _done: &[RxId]) {}
110
111    fn rx_poll(
112        &mut self,
113        _pool: &mut dyn BufferAccess,
114        _packets: &mut [RxId],
115    ) -> anyhow::Result<usize> {
116        Ok(0)
117    }
118
119    fn tx_avail(
120        &mut self,
121        _pool: &mut dyn BufferAccess,
122        packets: &[TxSegment],
123    ) -> anyhow::Result<(bool, usize)> {
124        Ok((true, packets.len()))
125    }
126
127    fn tx_poll(
128        &mut self,
129        _pool: &mut dyn BufferAccess,
130        _done: &mut [TxId],
131    ) -> Result<usize, TxError> {
132        Ok(0)
133    }
134}
net_backend/null.rs

net_backend/
null.rs
