Struct SessionManager 

pub struct SessionManager<I: Interface + ?Sized> { /* private fields */ }

Implementations

impl<I: Interface + ?Sized> SessionManager<I>

pub fn new(interface: Arc<I>) -> Self

pub fn interface(&self) -> &I

pub async fn serve_session( self: Arc<Self>, stream: SessionRequestStream, offset_map: OffsetMap, block_size: u32, ) -> Result<(), Error>

Runs stream until completion.

Trait Implementations

impl<I: Interface + ?Sized> Drop for SessionManager<I>

fn drop(&mut self)

Executes the destructor for this type.

impl<I: Interface + ?Sized> SessionManager for SessionManager<I>

const SUPPORTS_DECOMPRESSION: bool = true

type Orchestrator = SessionManager<I>

The Orchestrator is an object that holds the SessionManager and any other state that needs to be shared between sessions. It is responsible for keeping the SessionManager alive. We use this type instead of directly holding an Arc in BlockServer, to avoid nested Arcs in concrete implementations which need to keep additional state.

type Session = usize

async fn on_attach_vmo( orchestrator: Arc<Self>, vmo: &Arc<Vmo>, ) -> Result<(), Status>

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

Creates a new session to handle stream. The returned future should run until the session completes, for example when the client end closes. offset_map, will be used to adjust the block offset/length of FIFO requests.

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

Called to get block/partition information for Block::GetInfo, Partition::GetTypeGuid, etc.

async fn get_volume_info( &self, ) -> Result<(VolumeManagerInfo, VolumeInfo), Status>

Called to handle the GetVolumeInfo FIDL call.

async fn query_slices( &self, start_slices: &[u64], ) -> Result<Vec<VsliceRange>, Status>

Called to handle the QuerySlices FIDL call.

async fn extend(&self, start_slice: u64, slice_count: u64) -> Result<(), Status>

Called to handle the Shrink FIDL call.

async fn shrink(&self, start_slice: u64, slice_count: u64) -> Result<(), Status>

Called to handle the Shrink FIDL call.

fn active_requests(&self) -> &ActiveRequests<Self::Session>

Returns the active requests.