Struct AckUdp

pub struct AckUdp {
    pub sock: Arc<UdpSocket>,
    pub ready_to_read_datagrams: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>,
    pub pending_in_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>,
    pub pending_out_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>,
    pub out_datagrams_status_links: Arc<Mutex<HashMap<[u8; 5], Arc<Mutex<AckUdpDatagramOutStatus>>>>>,
    pub kill_listener_channel_sender: Sender<()>,
    pub kill_income_checker_channel_sender: Sender<()>,
    pub kill_outcome_checker_listener_channel_sender: Sender<()>,
    pub kill_incoming_queue_channel_sender: Sender<()>,
    pub incoming_queue: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>,
}

Fields

sock: Arc<UdpSocket>

ready_to_read_datagrams: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>

pending_in_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>

pending_out_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>

out_datagrams_status_links: Arc<Mutex<HashMap<[u8; 5], Arc<Mutex<AckUdpDatagramOutStatus>>>>>

kill_listener_channel_sender: Sender<()>

kill_income_checker_channel_sender: Sender<()>

kill_outcome_checker_listener_channel_sender: Sender<()>

kill_incoming_queue_channel_sender: Sender<()>

incoming_queue: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>

Implementations

impl AckUdp

pub async fn check_dropped_income( income_checker_receiver: Receiver<()>, pending_in_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>, ) -> Result<()>

impl AckUdp

pub async fn check_dropped_outcome( outcome_checker_receiver: Receiver<()>, pending_out_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>, socket: Arc<UdpSocket>, out_datagrams_status_links: Arc<Mutex<HashMap<[u8; 5], Arc<Mutex<AckUdpDatagramOutStatus>>>>>, )

impl AckUdp

pub async fn listen_packets( listener_receiver: Receiver<()>, socket: Arc<UdpSocket>, incoming_queue: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>, )

impl AckUdp

pub async fn process_packets( incoming_queue_receiver: Receiver<()>, incoming_queue: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>, socket: Arc<UdpSocket>, ready_to_read_datagrams: Arc<Mutex<VecDeque<(SocketAddr, Vec<u8>)>>>, pending_in_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>, pending_out_datagrams: Arc<Mutex<HashMap<[u8; 5], AckUdpDatagram>>>, out_datagrams_status_links: Arc<Mutex<HashMap<[u8; 5], Arc<Mutex<AckUdpDatagramOutStatus>>>>>, )

impl AckUdp

pub async fn new(address: SocketAddr) -> Result<AckUdp>

pub fn recv(&mut self) -> Option<(SocketAddr, Vec<u8>)>

pub fn send( &mut self, buf: &[u8], address: SocketAddr, ) -> Result<Arc<Mutex<AckUdpDatagramOutStatus>>>