Struct AsyncBlockService 

pub struct AsyncBlockService<I: Interface> { /* private fields */ }

A generic adapter that presents any [async_interface::Interface] backend as a BlockService, using BufferAllocator for concurrent read buffer management and fasync::ScopeHandle for thread-safe task spawning.

Implementations

impl<I: Interface> AsyncBlockService<I>

pub async fn new( interface: Arc<I>, block_size: u32, pool_capacity: usize, scope: ScopeHandle, ) -> Result<Self, Status>

pub fn new_with_allocator( interface: Arc<I>, block_size: u32, allocator: Arc<BufferAllocator>, scope: ScopeHandle, ) -> Self

pub fn interface(&self) -> &Arc<I>

pub fn allocator(&self) -> &Arc<BufferAllocator>

Trait Implementations

impl<I: Interface> BlockService for AsyncBlockService<I>

fn allocate_buffer(&self, max_len: usize) -> OwnedBuffer

Allocates a read buffer of at most max_len bytes (OwnedBuffer).

fn read_blocks( &self, device_offset: u64, dest_buffer: OwnedBuffer, on_complete: Box<dyn FnOnce(Result<OwnedBuffer, Error>) + Send>, ) -> Result<(), Error>

Submits a read for the specified range from device_offset into dest_buffer. When the read completes, on_complete is invoked with the result containing the buffer.