Struct PartitionBackend

pub struct PartitionBackend { /* private fields */ }

PartitionBackend is an implementation of block_server’s Interface which is backed by a windowed view of the underlying GPT device.

Implementations

impl PartitionBackend

pub fn new(partition: Arc<GptPartition>) -> Arc<Self>

Trait Implementations

impl Drop for PartitionBackend

fn drop(&mut self)

Executes the destructor for this type.

impl Interface for PartitionBackend

async fn open_session( &self, session_manager: Arc<SessionManager<Self>>, stream: SessionRequestStream, offset_map: OffsetMap, block_size: u32, ) -> Result<(), Error>

Runs stream to completion.

async fn on_attach_vmo(&self, vmo: &Vmo) -> Result<(), Status>

Called whenever a VMO is attached, prior to the VMO’s usage in any other methods. Whilst the VMO is attached, vmo will keep the same address so it is safe to use the pointer value (as, say, a key into a HashMap).

async fn get_info(&self) -> Result<Cow<'_, DeviceInfo>, Status>

Called to get block/partition information.

fn barrier(&self) -> Result<(), Status>

Indicates that all previously completed write operations should be made persistent prior to any write operations issued after this call. It is not specified how the barrier affects currently in-flight write operations. This corresponds to the use of the PRE_BARRIER flag that can be used on a write request. Requests with that flag will be converted into separate barrier and write calls, and the write call above will not ever include the WriteOptions::PRE_BARRIER within opts.

async fn read( &self, device_block_offset: u64, block_count: u32, vmo: &Arc<Vmo>, vmo_offset: u64, trace_flow_id: Option<NonZero<u64>>, ) -> Result<(), Status>

Called for a request to read bytes.

async fn write( &self, device_block_offset: u64, length: u32, vmo: &Arc<Vmo>, vmo_offset: u64, opts: WriteOptions, trace_flow_id: Option<NonZero<u64>>, ) -> Result<(), Status>

Called for a request to write bytes. WriteOptions::PRE_BARRIER should never be seen for this call. See barrier().

async fn flush(&self, trace_flow_id: Option<NonZero<u64>>) -> Result<(), Status>

Called to flush the device.

async fn trim( &self, device_block_offset: u64, block_count: u32, trace_flow_id: Option<NonZero<u64>>, ) -> Result<(), Status>

Called to trim a region.

fn on_detach_vmo(&self, _vmo: &Vmo)

Called whenever a VMO is detached.

fn get_volume_info( &self, ) -> impl Future<Output = Result<(VolumeManagerInfo, VolumeInfo), Status>> + Send

Called to handle the GetVolumeInfo FIDL call.

fn query_slices( &self, _start_slices: &[u64], ) -> impl Future<Output = Result<Vec<VsliceRange>, Status>> + Send

Called to handle the QuerySlices FIDL call.

fn extend( &self, _start_slice: u64, _slice_count: u64, ) -> impl Future<Output = Result<(), Status>> + Send

Called to handle the Extend FIDL call.

fn shrink( &self, _start_slice: u64, _slice_count: u64, ) -> impl Future<Output = Result<(), Status>> + Send

Called to handle the Shrink FIDL call.