netstack3_base/

frame.rs

// Copyright 2024 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

//! Common traits and types for dealing with abstracted frames.

use net_types::ethernet::Mac;
use net_types::ip::{Ip, IpVersionMarker};
use net_types::{BroadcastAddr, MulticastAddr};

use core::convert::Infallible as Never;
use core::fmt::Debug;
use packet::{BufferMut, SerializeError};
use thiserror::Error;

use crate::error::ErrorAndSerializer;
use crate::socket::SocketInfo;
use crate::{ChecksumOffloadResult, NetworkParsingContext, NetworkSerializer};

/// A context for receiving frames.
///
/// Note: Use this trait as trait bounds, but always implement
/// [`ReceivableFrameMeta`] instead, which generates a `RecvFrameContext`
/// implementation.
pub trait RecvFrameContext<Meta, BC> {
    /// Receive a frame.
    ///
    /// `receive_frame` receives a frame with the given metadata.
    fn receive_frame<B: BufferMut + Debug>(
        &mut self,
        bindings_ctx: &mut BC,
        metadata: Meta,
        frame: B,
    );
}

impl<CC, BC> ReceivableFrameMeta<CC, BC> for Never {
    fn receive_meta<B: BufferMut + Debug>(
        self,
        _core_ctx: &mut CC,
        _bindings_ctx: &mut BC,
        _frame: B,
    ) {
        match self {}
    }
}

/// A trait providing the receive implementation for some frame identified by a
/// metadata type.
///
/// This trait sidesteps orphan rules by allowing [`RecvFrameContext`] to be
/// implemented by the multiple core crates, given it can always be implemented
/// for a local metadata type. `ReceivableFrameMeta` should always be used for
/// trait implementations, while [`RecvFrameContext`] is used for trait bounds.
pub trait ReceivableFrameMeta<CC, BC> {
    /// Receives this frame using the provided contexts.
    fn receive_meta<B: BufferMut + Debug>(self, core_ctx: &mut CC, bindings_ctx: &mut BC, frame: B);
}

impl<CC, BC, Meta> RecvFrameContext<Meta, BC> for CC
where
    Meta: ReceivableFrameMeta<CC, BC>,
{
    fn receive_frame<B: BufferMut + Debug>(
        &mut self,
        bindings_ctx: &mut BC,
        metadata: Meta,
        frame: B,
    ) {
        metadata.receive_meta(self, bindings_ctx, frame)
    }
}

/// The error type for [`SendFrameError`].
#[derive(Error, Debug, PartialEq)]
pub enum SendFrameErrorReason {
    /// Serialization failed due to failed size constraints.
    #[error("size constraints violated")]
    SizeConstraintsViolation,
    /// Couldn't allocate space to serialize the frame.
    #[error("failed to allocate")]
    Alloc,
    /// The transmit queue is full.
    #[error("transmit queue is full")]
    QueueFull,
    /// The link layer address for the frame could not be resolved.
    #[error("address resolution failed")]
    AddressResolutionFailed,
}

impl<A> From<SerializeError<A>> for SendFrameErrorReason {
    fn from(e: SerializeError<A>) -> Self {
        match e {
            SerializeError::Alloc(_) => Self::Alloc,
            SerializeError::SizeLimitExceeded => Self::SizeConstraintsViolation,
        }
    }
}

/// Errors returned by [`SendFrameContext::send_frame`].
pub type SendFrameError<S> = ErrorAndSerializer<SendFrameErrorReason, S>;

/// A context for sending frames.
pub trait SendFrameContext<BC, Meta> {
    /// Send a frame.
    ///
    /// `send_frame` sends a frame with the given metadata. The frame itself is
    /// passed as a [`Serializer`] which `send_frame` is responsible for
    /// serializing. If serialization fails for any reason, the original,
    /// unmodified `Serializer` is returned.
    ///
    /// [`Serializer`]: packet::Serializer
    fn send_frame<S>(
        &mut self,
        bindings_ctx: &mut BC,
        metadata: Meta,
        frame: S,
    ) -> Result<(), SendFrameError<S>>
    where
        S: NetworkSerializer,
        S::Buffer: BufferMut;
}

/// A trait providing the send implementation for some frame identified by a
/// metadata type.
///
/// This trait sidesteps orphan rules by allowing [`SendFrameContext`] to be
/// implemented by the multiple core crates, given it can always be implemented
/// for a local metadata type. `SendableFrameMeta` should always be used for
/// trait implementations, while [`SendFrameContext`] is used for trait bounds.
pub trait SendableFrameMeta<CC, BC> {
    /// Sends this frame metadata to the provided contexts.
    fn send_meta<S>(
        self,
        core_ctx: &mut CC,
        bindings_ctx: &mut BC,
        frame: S,
    ) -> Result<(), SendFrameError<S>>
    where
        S: NetworkSerializer,
        S::Buffer: BufferMut;
}

impl<CC, BC, Meta> SendFrameContext<BC, Meta> for CC
where
    Meta: SendableFrameMeta<CC, BC>,
{
    fn send_frame<S>(
        &mut self,
        bindings_ctx: &mut BC,
        metadata: Meta,
        frame: S,
    ) -> Result<(), SendFrameError<S>>
    where
        S: NetworkSerializer,
        S::Buffer: BufferMut,
    {
        metadata.send_meta(self, bindings_ctx, frame)
    }
}

/// The type of address used as the destination address in a device-layer frame.
///
/// `FrameDestination` is used to implement RFC 1122 section 3.2.2 and RFC 4443
/// section 2.4.e, which govern when to avoid sending an ICMP error message for
/// ICMP and ICMPv6 respectively.
#[derive(Copy, Clone, Debug, Eq, PartialEq)]
pub enum FrameDestination<L = bool> {
    /// A unicast address - one which is neither multicast nor broadcast.
    Individual {
        /// Whether the frame's destination address belongs to the receiver.
        local: L,
    },
    /// A multicast address; if the addressing scheme supports overlap between
    /// multicast and broadcast, then broadcast addresses should use the
    /// `Broadcast` variant.
    Multicast,
    /// A broadcast address; if the addressing scheme supports overlap between
    /// multicast and broadcast, then broadcast addresses should use the
    /// `Broadcast` variant.
    Broadcast,
}

/// A `FrameDestination` that is guaranteed to be destined to this host if it is
/// an individual address.
pub type LocalFrameDestination = FrameDestination<()>;

impl<L> FrameDestination<L> {
    /// Is this `FrameDestination::Broadcast`?
    pub fn is_broadcast(self) -> bool {
        matches!(self, FrameDestination::Broadcast)
    }
}

impl FrameDestination<bool> {
    /// Creates a `FrameDestination` from a `mac` and `local_mac` destination.
    pub fn from_dest(destination: Mac, local_mac: Mac) -> Self {
        BroadcastAddr::new(destination)
            .map(Into::into)
            .or_else(|| MulticastAddr::new(destination).map(Into::into))
            .unwrap_or_else(|| FrameDestination::Individual { local: destination == local_mac })
    }

    /// Converts this `FrameDestination` to a `LocalFrameDestination`.
    ///
    /// Returns `None` if the destination is `Individual { local: false }`,
    /// indicating the packet is not for this host and should be dropped.
    pub fn check_local(self) -> Option<LocalFrameDestination> {
        match self {
            FrameDestination::Individual { local: true } => {
                Some(FrameDestination::Individual { local: () })
            }
            FrameDestination::Individual { local: false } => None,
            FrameDestination::Multicast => Some(FrameDestination::Multicast),
            FrameDestination::Broadcast => Some(FrameDestination::Broadcast),
        }
    }
}

impl<L> From<BroadcastAddr<Mac>> for FrameDestination<L> {
    fn from(_value: BroadcastAddr<Mac>) -> Self {
        Self::Broadcast
    }
}

impl<L> From<MulticastAddr<Mac>> for FrameDestination<L> {
    fn from(_value: MulticastAddr<Mac>) -> Self {
        Self::Multicast
    }
}

/// The metadata required for a packet to get into the IP layer.
pub struct RecvIpFrameMeta<D, M, I: Ip> {
    /// The device on which the IP frame was received.
    pub device: D,
    /// The link-layer destination address from the link-layer frame, if any.
    /// `None` if the IP frame originated above the link-layer (e.g. pure IP
    /// devices).
    // NB: In the future, this field may also be `None` to represent link-layer
    // protocols without destination addresses (i.e. PPP), but at the moment no
    // such protocols are supported.
    pub frame_dst: Option<LocalFrameDestination>,
    /// Metadata that is produced and consumed by the IP layer but which traverses
    /// the device layer through the loopback device.
    pub ip_layer_metadata: M,
    /// A marker for the Ip version in this frame.
    pub marker: IpVersionMarker<I>,
    /// The parsing context for the received frame.
    pub parsing_context: NetworkParsingContext,
}

impl<D, M, I: Ip> RecvIpFrameMeta<D, M, I> {
    /// Creates a new `RecvIpFrameMeta` originating from `device` and `frame_dst`
    /// option.
    pub fn new(
        device: D,
        frame_dst: Option<LocalFrameDestination>,
        ip_layer_metadata: M,
        parsing_context: NetworkParsingContext,
    ) -> RecvIpFrameMeta<D, M, I> {
        RecvIpFrameMeta {
            device,
            frame_dst,
            ip_layer_metadata,
            marker: IpVersionMarker::new(),
            parsing_context,
        }
    }
}

/// A trait for the metadata associated with a TX frame.
///
/// The `Default` impl yields the default, i.e. unspecified, metadata
/// instance.
pub trait TxMetadata: Default + Debug + Send + Sync + 'static {
    /// Returns [`SocketInfo`] for the socket associated with the packet.
    /// `None` is returned if the packet is not associated with a local socket.
    fn socket_info(&self) -> Option<SocketInfo>;

    /// Returns the result of TX checksum offloading, if any was performed.
    fn checksum_offload_result(&self) -> Option<ChecksumOffloadResult>;

    /// Sets the TX checksum offload result. Replaces the previous result if
    /// called multiple times.
    fn set_checksum_offload_result(&mut self, result: Option<ChecksumOffloadResult>);
}

/// A trait abstracting TX frame metadata when traversing the stack.
///
/// This trait allows for stack integration crate to define a single concrete
/// enumeration for all the types of transport metadata that a socket can
/// generate. Metadata is carried with all TX frames until they hit the device
/// layer.
///
/// NOTE: This trait is implemented by *bindings*. Although the tx metadata
/// never really leaves core, abstraction over bindings types are substantially
/// more common so delegating this implementation to bindings avoids type
/// parameter explosion.
pub trait TxMetadataBindingsTypes {
    /// The metadata associated with a TX frame.
    type TxMetadata: TxMetadata;
}

/// A core context providing tx metadata type conversion.
///
/// This trait is used to convert from a core-internal tx metadata type `T` to
/// the metadata supported by bindings in `BT::TxMetadata`.
pub trait CoreTxMetadataContext<T, BT: TxMetadataBindingsTypes> {
    /// Converts the tx metadata `T` into the type set by bindings.
    ///
    /// Note that this method takes a `self` receiver so it's easily
    /// implementable with uninstantiable types. The conversion is expected to
    /// be stateless otherwise in all implementers.
    fn convert_tx_meta(&self, tx_meta: T) -> BT::TxMetadata;
}

/// A buffer that is never used.
///
/// Note that this is needed because of the [`AsMut<[u8]>`] bound required.
/// It is not possible work around this with a local trait. That approach
/// requires a blanket impl which the compiler will complain that the core
/// crate can eventually add a impl for the `Infallible` type. When that
/// happens, we can remove this local type.
pub struct NeverBuffer(core::convert::Infallible);

impl packet::FragmentedBuffer for NeverBuffer {
    fn len(&self) -> usize {
        match self.0 {}
    }

    fn with_bytes<'a, R, F>(&'a self, _f: F) -> R
    where
        F: for<'b> FnOnce(packet::FragmentedBytes<'b, 'a>) -> R,
    {
        match self.0 {}
    }
}

impl AsMut<[u8]> for NeverBuffer {
    fn as_mut(&mut self) -> &mut [u8] {
        match self.0 {}
    }
}

#[cfg(any(test, feature = "testutils"))]
pub(crate) mod testutil {
    use super::*;
    use alloc::boxed::Box;
    use alloc::vec::Vec;

    use crate::packet::NetworkSerializationContext;
    use crate::testutil::FakeBindingsCtx;

    /// A fake [`FrameContext`].
    pub struct FakeFrameCtx<Meta> {
        frames: Vec<(Meta, Vec<u8>)>,
        should_error_for_frame:
            Option<Box<dyn FnMut(&Meta) -> Option<SendFrameErrorReason> + Send>>,
    }

    impl<Meta> FakeFrameCtx<Meta> {
        /// Closure which can decide to cause an error to be thrown when
        /// handling a frame, based on the metadata.
        pub fn set_should_error_for_frame<
            F: Fn(&Meta) -> Option<SendFrameErrorReason> + Send + 'static,
        >(
            &mut self,
            f: F,
        ) {
            self.should_error_for_frame = Some(Box::new(f));
        }
    }

    impl<Meta> Default for FakeFrameCtx<Meta> {
        fn default() -> FakeFrameCtx<Meta> {
            FakeFrameCtx { frames: Vec::new(), should_error_for_frame: None }
        }
    }

    impl<Meta> FakeFrameCtx<Meta> {
        /// Take all frames sent so far.
        pub fn take_frames(&mut self) -> Vec<(Meta, Vec<u8>)> {
            core::mem::take(&mut self.frames)
        }

        /// Get the frames sent so far.
        pub fn frames(&self) -> &[(Meta, Vec<u8>)] {
            self.frames.as_slice()
        }

        /// Pushes a frame to the context.
        pub fn push(&mut self, meta: Meta, frame: Vec<u8>) {
            self.frames.push((meta, frame))
        }
    }

    impl<Meta, BC> SendableFrameMeta<FakeFrameCtx<Meta>, BC> for Meta {
        fn send_meta<S>(
            self,
            core_ctx: &mut FakeFrameCtx<Meta>,
            _bindings_ctx: &mut BC,
            frame: S,
        ) -> Result<(), SendFrameError<S>>
        where
            S: NetworkSerializer,
            S::Buffer: BufferMut,
        {
            if let Some(error) = core_ctx.should_error_for_frame.as_mut().and_then(|f| f(&self)) {
                return Err(SendFrameError { serializer: frame, error });
            }

            let buffer = frame
                .serialize_vec_outer(&mut NetworkSerializationContext::default())
                .map_err(|(e, serializer)| SendFrameError { error: e.into(), serializer })?;
            core_ctx.push(self, buffer.as_ref().to_vec());
            Ok(())
        }
    }

    /// A trait for abstracting contexts that may contain a [`FakeFrameCtx`].
    pub trait WithFakeFrameContext<SendMeta> {
        /// Calls the callback with a mutable reference to the [`FakeFrameCtx`].
        fn with_fake_frame_ctx_mut<O, F: FnOnce(&mut FakeFrameCtx<SendMeta>) -> O>(
            &mut self,
            f: F,
        ) -> O;
    }

    impl<SendMeta> WithFakeFrameContext<SendMeta> for FakeFrameCtx<SendMeta> {
        fn with_fake_frame_ctx_mut<O, F: FnOnce(&mut FakeFrameCtx<SendMeta>) -> O>(
            &mut self,
            f: F,
        ) -> O {
            f(self)
        }
    }

    impl<TimerId, Event: Debug, State, FrameMeta> TxMetadataBindingsTypes
        for FakeBindingsCtx<TimerId, Event, State, FrameMeta>
    {
        type TxMetadata = FakeTxMetadata;
    }

    /// The fake metadata supported by [`FakeBindingsCtx`].
    #[derive(Default, Debug, Copy, Clone, Eq, PartialEq, Ord, PartialOrd)]
    pub struct FakeTxMetadata;

    impl TxMetadata for FakeTxMetadata {
        fn socket_info(&self) -> Option<SocketInfo> {
            None
        }

        fn checksum_offload_result(&self) -> Option<ChecksumOffloadResult> {
            None
        }

        fn set_checksum_offload_result(&mut self, _result: Option<ChecksumOffloadResult>) {}
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    use net_declare::net_mac;
    use net_types::{UnicastAddr, Witness as _};

    #[test]
    fn frame_destination_from_dest() {
        const LOCAL_ADDR: Mac = net_mac!("88:88:88:88:88:88");

        assert_eq!(
            FrameDestination::from_dest(
                UnicastAddr::new(net_mac!("00:11:22:33:44:55")).unwrap().get(),
                LOCAL_ADDR
            ),
            FrameDestination::Individual { local: false }
        );
        assert_eq!(
            FrameDestination::from_dest(LOCAL_ADDR, LOCAL_ADDR),
            FrameDestination::Individual { local: true }
        );
        assert_eq!(
            FrameDestination::from_dest(Mac::BROADCAST, LOCAL_ADDR),
            FrameDestination::Broadcast,
        );
        assert_eq!(
            FrameDestination::from_dest(
                MulticastAddr::new(net_mac!("11:11:11:11:11:11")).unwrap().get(),
                LOCAL_ADDR
            ),
            FrameDestination::Multicast
        );
    }
}