Struct RetargetableDriver

pub struct RetargetableDriver { /* private fields */ }

A driver for AffinitizedThreadpool that can be retargeted to different CPUs.

Implementations

impl RetargetableDriver

pub fn new(threadpool: AffinitizedThreadpool, target_cpu: u32) -> Self

Returns a new driver, initially targeted to target_cpu.

pub fn retarget(&self, target_cpu: u32)

Retargets the driver to target_cpu.

In-flight IOs will not be retargeted.

pub fn current_target_cpu(&self) -> u32

Returns the current target CPU.

pub fn current_driver(&self) -> &ThreadpoolDriver

Returns the current driver.

Trait Implementations

impl Clone for RetargetableDriver

fn clone(&self) -> RetargetableDriver

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RetargetableDriver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FdReadyDriver for RetargetableDriver

type FdReady = FdReady<RetargetableDriver>

The file descriptor ready type.

fn new_fd_ready(&self, fd: RawFd) -> Result<Self::FdReady>

Returns a new object for polling file descriptor readiness.

impl Initiate for RetargetableDriver

fn initiator(&self) -> &IoInitiator

Returns a reference to the initiator to use for IO operations.

impl Spawn for RetargetableDriver

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 TimerDriver for RetargetableDriver

type Timer = Timer<RetargetableDriver>

The timer type.

fn new_timer(&self) -> Self::Timer

Returns a new timer.

impl WaitDriver for RetargetableDriver

type Wait = FdWait<RetargetableDriver>

The wait object.

fn new_wait(&self, fd: RawFd, read_size: usize) -> Result<Self::Wait>

Creates a new wait.