dope 0.4.6

The manifold runtime
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

use io_uring::{opcode::SetSockOpt, types::Fixed};

use super::Driver;
use crate::backend::token::{ROUTE_FRAMEWORK, Token};
use crate::{PushError, Sockopt};

impl Sockopt for Driver {
    fn set(&mut self, fixed_idx: u32, level: u32, optname: u32, value: i32) -> Result<(), crate::backend::PushError> {
        let Some(key) = self.setsockopt.alloc(Box::new(value)) else {
            return Err(crate::backend::PushError);
        };
        let optval_ptr =
            (&**self.setsockopt.get(key).unwrap() as *const libc::c_int).cast::<libc::c_void>();
        let ud = Token::from_key(ROUTE_FRAMEWORK, key);
        let sqe = SetSockOpt::new(
            Fixed(fixed_idx),
            level,
            optname,
            optval_ptr,
            size_of::<libc::c_int>() as u32,
        )
        .build()
        .user_data(ud.raw());
        if self.try_push(&sqe).is_ok() {
            Ok(())
        } else {
            self.setsockopt.remove(key);
            Err(PushError)
        }
    }
}