s2n-quic-platform 0.88.0

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

// depending on the platform, some of these implementations aren't used
#![allow(dead_code)]

mod simple;
#[cfg(unix)]
mod unix;

cfg_if::cfg_if! {
    if #[cfg(s2n_quic_platform_socket_mmsg)] {
        pub use mmsg::{rx, tx};
    } else if #[cfg(s2n_quic_platform_socket_msg)] {
        pub use msg::{rx, tx};
    } else {
        pub use simple::{rx, tx};
    }
}

macro_rules! libc_msg {
    ($message:ident, $cfg:ident) => {
        #[cfg($cfg)]
        mod $message {
            use super::unix;
            use crate::{
                features::Gso,
                message::$message::Message,
                socket::{ring, stats},
            };
            use s2n_quic_core::task::cooldown::Cooldown;

            pub async fn rx<S: Into<std::net::UdpSocket>>(
                socket: S,
                socket_low: Option<S>,
                producer: ring::Producer<Message>,
                cooldown: Cooldown,
                stats: stats::Sender,
            ) -> std::io::Result<()> {
                unix::rx(socket, socket_low, producer, cooldown, stats).await
            }

            pub async fn tx<S: Into<std::net::UdpSocket>>(
                socket: S,
                consumer: ring::Consumer<Message>,
                gso: Gso,
                cooldown: Cooldown,
                stats: stats::Sender,
            ) -> std::io::Result<()> {
                unix::tx(socket, consumer, gso, cooldown, stats).await
            }
        }
    };
}

libc_msg!(msg, s2n_quic_platform_socket_msg);
libc_msg!(mmsg, s2n_quic_platform_socket_mmsg);