Struct CurrentThreadDriver 

pub struct CurrentThreadDriver { /* private fields */ }

A driver that dispatches to the current thread’s registered executor.

If the current thread has no registered executor (i.e., it is not a thread spawned by ThreadDriverBackend), falls back to a default driver.

Trait Implementations

impl Driver for CurrentThreadDriver

fn new_dyn_timer(&self) -> PollImpl<dyn PollTimer>

Returns a new timer.

fn new_dyn_fd_ready(&self, fd: RawFd) -> Result<PollImpl<dyn PollFdReady>>

Returns a new object for polling file descriptor readiness.

fn new_dyn_socket_ready( &self, socket: RawFd, ) -> Result<PollImpl<dyn PollSocketReady>>

Creates a new object for polling socket readiness.

fn new_dyn_wait( &self, fd: RawFd, read_size: usize, ) -> Result<PollImpl<dyn PollWait>>

Creates a new wait.

fn io_uring_probe(&self, opcode: u8) -> bool

Returns whether the given opcode is supported by the ring.

unsafe fn io_uring_submit( &self, sqe: Entry, ) -> Pin<Box<dyn Future<Output = Result<i32>> + Send + '_>>

Submits an io-uring SQE for asynchronous execution.

impl Inspect for CurrentThreadDriver

fn inspect(&self, req: Request<'_>)

Inspects the object.

impl Spawn for CurrentThreadDriver

fn scheduler(&self, metadata: &TaskMetadata) -> Arc<dyn Schedule>

Gets a scheduler for a new task.

fn spawn<T>( &self, name: impl Into<Arc<str>>, fut: impl Future<Output = T> + Send + 'static, ) -> Task<T, TaskMetadata>

where T: 'static + Send, Self: Sized,

Spawns a task.

impl TargetedDriver for CurrentThreadDriver

fn spawner(&self) -> &dyn Spawn

Returns the implementation to use for spawning tasks.

fn driver(&self) -> &dyn Driver

Returns the implementation to use for driving IO.

fn retarget_vp(&self, _target_vp: u32)

Retargets the driver to the specified virtual processor.

fn is_target_vp_ready(&self) -> bool

Returns whether a driver’s target VP is ready for tasks and IO.

fn wait_target_vp_ready(&self) -> impl Future<Output = ()> + Send

Waits for this driver’s target VP to be ready for tasks and IO.