Struct Files 

pub struct Files<S: ?Sized, D: DeliveryHandler> { /* private fields */ }

A thread-safe registry of active File instances indexed by their Zircon pager port key.

Implementations

impl<S: BlockService + ?Sized, D: DeliveryHandler> Files<S, D>

pub fn new(service: Arc<S>, delivery_handler: D, port: Port) -> Self

Creates a new file registry with the provided block service, delivery handler, and port.

pub fn spawn_pager_thread(self: &Arc<Self>) -> PagerThread<S, D>

where S: 'static,

Spawns a background thread to service pager requests for self.

pub fn service(&self) -> &Arc<S>

Returns a reference to the block service.

pub fn register_blob( &self, key: u64, merkle_leaves: &[[u8; 32]], ) -> Result<(), Error>

Registers a blob’s Merkle tree leaf hashes with the downstream delivery handler.

pub fn begin_loading(&self, key: u64)

Marks key as currently loading metadata, preserving any page requests that arrived prior to the mapping command.

pub fn get_file(&self, key: u64) -> Option<Arc<File>>

Returns the loaded File registered under key, if present.

pub async fn wait_for_file(&self, key: u64) -> Result<Arc<File>, Error>

Returns a future that completes with the loaded File registered under key, waiting asynchronously if the file is currently loading or hasn’t arrived yet.

pub fn remove(&self, key: u64)

Removes the file registered under key.

impl<S: BlockService + ?Sized> Files<S, NoopDeliveryHandler>

pub fn new_without_pager(service: Arc<S>) -> Self

Creates a file registry without a pager for intermediate (e.g. partition) sessions.