Struct cros_async::sys::linux::tokio_source::TokioSource

pub struct TokioSource<T> {
    fd: FdType,
    inner: T,
    runtime: Handle,
}

Fields

fd: FdType

inner: T

runtime: Handle

Implementations

impl<T: AsRawDescriptor> TokioSource<T>

pub fn new(inner: T, runtime: Handle) -> Result<TokioSource<T>, Error>

pub fn as_source(&self) -> &T

pub fn as_source_mut(&mut self) -> &mut T

fn clone_fd(&self) -> Arc<OwnedFd>

pub async fn fdatasync(&self) -> AsyncResult<()>

pub async fn fsync(&self) -> AsyncResult<()>

pub fn into_source(self) -> T

pub async fn read_to_vec( &self, file_offset: Option<u64>, vec: Vec<u8> ) -> AsyncResult<(usize, Vec<u8>)>

pub async fn read_to_mem( &self, file_offset: Option<u64>, mem: Arc<dyn BackingMemory + Send + Sync>, mem_offsets: impl IntoIterator<Item = MemRegion> ) -> AsyncResult<usize>

pub async fn punch_hole(&self, file_offset: u64, len: u64) -> AsyncResult<()>

pub async fn wait_readable(&self) -> AsyncResult<()>

pub async fn write_from_mem( &self, file_offset: Option<u64>, mem: Arc<dyn BackingMemory + Send + Sync>, mem_offsets: impl IntoIterator<Item = MemRegion> ) -> AsyncResult<usize>

pub async fn write_from_vec( &self, file_offset: Option<u64>, vec: Vec<u8> ) -> AsyncResult<(usize, Vec<u8>)>

pub async fn write_zeroes_at( &self, file_offset: u64, len: u64 ) -> AsyncResult<()>