solana-net-utils 4.2.0-beta.1

Solana Network Utilities
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
33

//! This module defines [`PinnedXdpSender`] which is a convenience wrapper around
//! [`agave_xdp::transmitter::XdpSender`] for the case when source address is fixed.
use {
    agave_xdp::transmitter as tx, bytes::Bytes, crossbeam_channel::TrySendError,
    std::net::SocketAddrV4,
};

/// [`PinnedXdpSender`] simplifies sending packets over XDP
/// when source address is fixed for all items.
#[derive(Clone)]
pub struct PinnedXdpSender {
    sender: tx::XdpSender,
    src_addr: SocketAddrV4,
}

impl PinnedXdpSender {
    pub fn new(sender: tx::XdpSender, src_addr: SocketAddrV4) -> Self {
        Self { sender, src_addr }
    }

    #[inline]
    pub fn try_send(
        &self,
        sender_index: usize,
        addr: impl Into<tx::XdpAddrs>,
        payload: Bytes,
    ) -> Result<(), TrySendError<tx::BytesTxPacket>> {
        self.sender.try_send(
            sender_index,
            tx::BytesTxPacket::new(self.src_addr, addr, None, payload),
        )
    }
}