linux-aio-tokio 0.4.1

Tokio bindings for Linux kernel AIO
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

#![allow(missing_docs)]

use intrusive_collections::{
    Adapter, DefaultLinkOps, DefaultPointerOps, intrusive_adapter, linked_list,
};
use lock_api::RawMutex;

use crate::requests::Request;
use crate::{AtomicLink, NoopLock};

intrusive_adapter!(pub SyncRequestAdapter = Box<Request<parking_lot::RawMutex, AtomicLink>>: Request<parking_lot::RawMutex, AtomicLink> { link: AtomicLink });
intrusive_adapter!(pub LocalRequestAdapter = Box<Request<NoopLock, linked_list::Link>>: Request<NoopLock, linked_list::Link> { link: linked_list::Link });

/// Intrusive adapter suitable for storing `Request`
pub trait IntrusiveAdapter<M, L>:
    Adapter<PointerOps = DefaultPointerOps<Box<Request<M, L>>>>
where
    M: RawMutex,
    L: DefaultLinkOps + Default,
{
    /// Create new intrusive adapter
    fn new() -> Self;
}

impl IntrusiveAdapter<parking_lot::RawMutex, AtomicLink> for SyncRequestAdapter {
    fn new() -> Self {
        Self::new()
    }
}

impl IntrusiveAdapter<NoopLock, linked_list::Link> for LocalRequestAdapter {
    fn new() -> Self {
        Self::new()
    }
}