Struct VmTaskDriver 

pub struct VmTaskDriver { /* private fields */ }

A driver returned by VmTaskDriverSource.

This can be used to spawn tasks (via [Spawn]) and issue async IO (via [Driver]).

Implementations

impl VmTaskDriver

pub fn retarget_vp(&self, target_vp: u32)

Updates the target VP for the task.

The effectiveness of this call, and when it would take effect, depends on the backend. For example, in the OpenHCL threadpool backend, this will cause new IO to target the new VP’s thread, but existing IO will continue to run on the original VP’s thread.

pub fn is_target_vp_ready(&self) -> bool

Returns whether the target VP is ready for tasks and IO.

A driver must be operable even if this is false, but the tasks and IO may run on a different target VP.

pub async fn wait_target_vp_ready(&self)

Waits for the target VP to be ready for tasks and IO.

Trait Implementations

impl Clone for VmTaskDriver

fn clone(&self) -> VmTaskDriver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Driver for VmTaskDriver

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 VmTaskDriver

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

Inspects the object.

impl Spawn for VmTaskDriver

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.