Struct RootDirCache 

pub struct RootDirCache<S> { /* private fields */ }

RootDirCache is a cache of Arc<impl Deref<Target = RootDir>>s indexed by their hash.

The cache internally stores Weaks and drops the corresponding entry when the last Arc is dropped, so it is a cache of Arcs that are actively in use by its clients. This is useful for deduplicating the RootDirs used by VFS to serve package directory connections while also keeping track of which connections are open.

Due to RootDir’s VFS implementation, a package will have alive Arcs if there are fuchsia.io.Directory connections to the package’s root directory or any sub directory.

This does not keep track of fuchsia.io.File connections made to a RootDirs files (files under meta/, files not under meta/, and the meta file) but both Blobfs and Fxblob will wait to delete blobs that have open connections or VMOs until the last one closes, so it is safe to delete packages that are not in the RootDirCache.

Clients close connections to packages by closing their end of the Zircon channel over which the fuchsia.io.Directory messages were being sent. Some time after the client end of the channel is closed, the server (usually in a different process) will be notified by the kernel, and the VFS task serving the connection will finish, dropping its Arc. When the last Arc is dropped, the strong count of the corresponding std::sync::Weak in the RootDirCache will decrement to zero. At this point the RootDirCache will no longer report the package as open. All this is to say that there will be some delay between a package no longer being in use and clients of RootDirCache finding out about that.

Implementations

impl<S: NonMetaStorage + Clone> RootDirCache<S>

pub fn new(non_meta_storage: S) -> Self

Creates a RootDirCache that uses non_meta_storage as the backing for the internally managed crate::RootDirs.

pub async fn get_or_insert( &self, hash: Hash, root_dir: Option<RootDir<S>>, ) -> Result<Arc<CachedRootDir<S>>, Error>

Returns an Arc<CachedRootDir> corresponding to hash. If there is not already one in the cache, root_dir will be used if provided, otherwise a new one will be created using the non_meta_storage provided to Self::new.

If provided, root_dir must be backed by the same NonMetaStorage that Self::new was called with.

pub fn get(&self, hash: &Hash) -> Option<Arc<CachedRootDir<S>>>

Returns the Arc<CachedRootDir> with the given hash, if one exists in the cache. Otherwise returns None. Holding on to the returned Arc will keep the package open (as reported by Self::list).

pub fn list(&self) -> Vec<Arc<CachedRootDir<S>>>

Packages with live Arc<CachedRootDir>s. Holding on to the returned Arcs will keep the packages open.

pub fn record_lazy_inspect( &self, ) -> impl Fn() -> BoxFuture<'static, Result<Inspector, Error>> + Send + Sync + 'static

Returns a callback to be given to fuchsia_inspect::Node::record_lazy_child. Records the package hashes and their corresponding Arc<CachedRootDir> strong counts.

Trait Implementations

impl<S: Clone> Clone for RootDirCache<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug> Debug for RootDirCache<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.