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 complete_request(&self, request_id: RequestId, status: Status)

Reports the given task as complete with a given status.

pub fn terminate(&self)

Terminates the session manager. Blocks until all sessions have terminated.

Trait Implementations

impl Borrow<SessionManager<InterfaceAdapter>> for Orchestrator

fn borrow(&self) -> &SessionManager<InterfaceAdapter>

Immutably borrows from an owned value.

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 = false

type Orchestrator = <I as Interface>::Orchestrator

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 = Arc<Session<I>>

async fn on_attach_vmo( _orchestrator: Arc<Self::Orchestrator>, _vmo: &Arc<Vmo>, ) -> Result<(), Status>

async fn open_session( orchestrator: Arc<Self::Orchestrator>, 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.

fn active_requests(&self) -> &ActiveRequests<Arc<Session<I>>>

Returns the active requests.

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 Shrink FIDL call.

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

Called to handle the Shrink FIDL call.