safer-ring 0.0.1

A safe Rust wrapper around io_uring with zero-cost abstractions and compile-time memory safety guarantees
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
39
40
41
42
43
44
45
46

//! Future implementations for async/await support.
//!
//! This module provides Future implementations that integrate io_uring operations
//! with Rust's async/await ecosystem. The futures handle polling the completion
//! queue and managing wakers for efficient async operation.
//!
//! # Example
//!
//! ```rust,no_run
//! use safer_ring::{Ring, PinnedBuffer, Operation};
//! use std::pin::Pin;
//!
//! # async fn example() -> Result<(), Box<dyn std::error::Error>> {
//! let mut buffer = PinnedBuffer::with_capacity(1024);
//! let ring = Ring::new(32)?;
//!
//! // Create a read operation
//! let operation = Operation::read()
//!     .fd(0)
//!     .buffer(buffer.as_mut_slice());
//!
//! // Example usage - actual async processing would be more complex
//! # Ok(())
//! # }
//! ```

mod batch_future;
mod io_futures;
mod operation_future;
mod standalone_batch_future;
pub(crate) mod waker;

#[cfg(test)]
mod tests;

// Re-export public types
pub use batch_future::BatchFuture;
pub use io_futures::{
    AcceptFuture, ReadFuture, RecvFuture, SendFuture, VectoredReadFuture, VectoredWriteFuture,
    WriteFuture,
};
pub use operation_future::OperationFuture;
pub use standalone_batch_future::StandaloneBatchFuture;

// Re-export internal types for crate use
pub(crate) use waker::WakerRegistry;