Struct Proactor 

pub struct Proactor { /* private fields */ }

Low-level actions of completion-based IO. It owns the operations to keep the driver safe.

Implementations

impl Proactor

pub fn new() -> Result<Self>

Create Proactor with 1024 entries.

pub fn builder() -> ProactorBuilder

Create ProactorBuilder to config the proactor.

pub fn default_extra(&self) -> Extra

Get a default Extra for underlying driver.

pub fn driver_type(&self) -> DriverType

The current driver type.

pub fn attach(&mut self, fd: RawFd) -> Result<()>

Attach an fd to the driver.

Platform specific

• IOCP: it will be attached to the completion port. An fd could only be attached to one driver, and could only be attached once, even if you try_clone it.
• io-uring & polling: it will do nothing but return Ok(()).

pub fn cancel<T: OpCode>(&mut self, key: Key<T>) -> Option<BufResult<usize, T>>

Cancel an operation with the pushed Key.

The cancellation is not reliable. The underlying operation may continue, but just don’t return from Proactor::poll.

pub fn push<T: OpCode + 'static>( &mut self, op: T, ) -> PushEntry<Key<T>, BufResult<usize, T>>

Push an operation into the driver, and return the unique key Key, associated with it.

pub fn push_with_extra<T: OpCode + 'static>( &mut self, op: T, extra: Extra, ) -> PushEntry<Key<T>, BufResult<usize, T>>

Push an operation into the driver with user-defined Extra, and return the unique key Key, associated with it.

pub fn poll(&mut self, timeout: Option<Duration>) -> Result<()>

Poll the driver and get completed entries. You need to call Proactor::pop to get the pushed operations.

pub fn pop<T>(&mut self, key: Key<T>) -> PushEntry<Key<T>, BufResult<usize, T>>

Get the pushed operations from the completion entries.

Panics

This function will panic if the requested operation has not been completed.

pub fn pop_with_extra<T>( &mut self, key: Key<T>, ) -> PushEntry<Key<T>, (BufResult<usize, T>, Extra)>

Get the pushed operations from the completion entries along the Extra associated.

Panics

This function will panic if the requested operation has not been completed.

pub fn update_waker<T>(&mut self, op: &mut Key<T>, waker: &Waker)

Update the waker of the specified op.

pub fn waker(&self) -> Waker

Create a waker to interrupt the inner driver.

pub fn create_buffer_pool( &mut self, buffer_len: u16, buffer_size: usize, ) -> Result<BufferPool>

Create buffer pool with given buffer_size and buffer_len

Notes

If buffer_len is not a power of 2, it will be rounded up with u16::next_power_of_two.

pub unsafe fn release_buffer_pool( &mut self, buffer_pool: BufferPool, ) -> Result<()>

Release the buffer pool

Safety

Caller must make sure to release the buffer pool with the correct driver, i.e., the one they created the buffer pool with.

pub fn register_personality(&self) -> Result<u16>

Register a new personality in io-uring driver.

Returns the personality id, which can be used with Extra::set_personality to set the personality for an operation.

This only works on io_uring driver. It will return an Unsupported error on other drivers. See Submitter::register_personality for more.

pub fn unregister_personality(&self, personality: u16) -> Result<()>

Unregister the given personality in io-uring driver.

This only works on io_uring driver. It will return an Unsupported error on other drivers. See Submitter::unregister_personality for more.

Trait Implementations

impl AsRawFd for Proactor

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.