dope-uring 0.25.0

Owned io_uring backend for dope
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
34
35
36
37
38

use std::net;

use dope_sys::{
    io::reactor::complete::message::{Cut, Output as _},
    probe::receive::{self, Corrupt, Failure},
};

use crate::reactor::cq::{Capacity, Length, Output};

pub struct Payload;

impl receive::Receive for Payload {
    type Capacity = Capacity;
    type Length = Length;

    fn bytes(actual: &[u8], want: &[u8]) -> Result<(), Corrupt> {
        if actual == want { Ok(()) } else { Err(Corrupt) }
    }

    fn message<const NAME: usize, E>(
        bytes: &[u8],
        want: &[u8],
        parse: impl FnOnce(&[u8]) -> Result<net::SocketAddr, E>,
    ) -> Result<(), Failure<Self::Capacity, Self::Length, E>> {
        let output = Output::<NAME, 0>::parse(bytes).map_err(Failure::Frame)?;
        match (output.payload_cut(), output.name_cut()) {
            (Cut::Complete, Cut::Complete) => {}
            (Cut::Complete, Cut::Truncated)
            | (Cut::Truncated, Cut::Complete)
            | (Cut::Truncated, Cut::Truncated) => return Err(Failure::Truncated),
        }
        let source = parse(output.name()).map_err(Failure::Address)?;
        if !source.ip().is_loopback() {
            return Err(Failure::Payload(Corrupt));
        }
        Self::bytes(output.payload(), want).map_err(Failure::Payload)
    }
}