Struct BlobDirectory 

pub struct BlobDirectory { /* private fields */ }

A flat directory containing content-addressable blobs (names are their hashes). It is not possible to create sub-directories. It is not possible to write to an existing blob. It is not possible to open or read a blob until it is written and verified.

Implementations

impl BlobDirectory

pub fn directory(&self) -> &Arc<FxDirectory>

pub fn volume(&self) -> &Arc<FxVolume>

impl BlobDirectory

pub async fn get_blob_vmo(self: &Arc<Self>, hash: Hash) -> Result<Vmo, Error>

Get a pager-backed VMO for the blob identified by hash in this BlobDirectory. The blob cannot be purged until all VMOs returned by this function are destroyed.

Trait Implementations

impl Directory for BlobDirectory

Implements VFS entry container trait for directories, allowing manipulation of their contents.

fn deprecated_open( self: Arc<Self>, scope: ExecutionScope, flags: OpenFlags, path: Path, server_end: ServerEnd<NodeMarker>, )

DEPRECATED - Do not implement unless required for backwards compatibility. Called when handling a fuchsia.io/Directory.DeprecatedOpen request.

fn open( self: Arc<Self>, scope: ExecutionScope, path: Path, flags: Flags, object_request: ObjectRequestRef<'_>, ) -> Result<(), Status>

Opens a connection to this item if the path is “.” or a connection to an item inside this one otherwise. path will not contain any “.” or “..” components.

async fn open_async( self: Arc<Self>, scope: ExecutionScope, path: Path, flags: Flags, object_request: ObjectRequestRef<'_>, ) -> Result<(), Status>

Same as Self::open but the implementation is async. This may be more efficient if the directory needs to do async work to open the connection.

async fn read_dirents( &self, pos: &TraversalPosition, sink: Box<dyn Sink>, ) -> Result<(TraversalPosition, Box<dyn Sealed>), Status>

Reads directory entries starting from pos by adding them to sink. Once finished, should return a sealed sink.

fn register_watcher( self: Arc<Self>, scope: ExecutionScope, mask: WatchMask, watcher: DirectoryWatcher, ) -> Result<(), Status>

Register a watcher for this directory. Implementations will probably want to use a Watcher to manage watchers.

fn unregister_watcher(self: Arc<Self>, key: usize)

Unregister a watcher from this directory. The watcher should no longer receive events.

impl DirectoryEntry for BlobDirectory

Implementation of VFS pseudo-directory for blobs. Forks a task per connection.

fn open_entry(self: Arc<Self>, request: OpenRequest<'_>) -> Result<(), Status>

Opens this entry.

fn scope(&self) -> Option<ExecutionScope>

The scope that should own connections to this directory entry, or None if parent scope should be used (the default).

impl From<Directory<FxVolume>> for BlobDirectory

fn from(dir: Directory<FxVolume>) -> Self

Converts to this type from the input type.

impl FxNode for BlobDirectory

fn object_id(&self) -> u64

fn parent(&self) -> Option<Arc<FxDirectory>>

fn set_parent(&self, _parent: Arc<FxDirectory>)

fn open_count_add_one(&self)

fn open_count_sub_one(self: Arc<Self>)

Atomically check if this brought the count to zero while the node is marked for purge. If so, this must queue the node for tombstone the node.

fn object_descriptor(&self) -> ObjectDescriptor

fn mark_to_be_purged(&self)

Marks the object to be purged. Queues the node for tombstone if open count is zero.

fn terminate(&self)

Called when the filesystem is shutting down. Implementations should break any strong reference cycles that would prevent the node from being dropped.

impl GetEntryInfo for BlobDirectory

fn entry_info(&self) -> EntryInfo

This method is used to populate ReadDirents() output.

impl MutableDirectory for BlobDirectory

async fn unlink( self: Arc<Self>, name: &str, must_be_directory: bool, ) -> Result<(), Status>

Removes an entry from this directory.

async fn update_attributes( &self, attributes: MutableNodeAttributes, ) -> Result<(), Status>

Set the mutable attributes of this directory based on the values in attributes. If the directory does not support updating all of the specified attributes, implementations should fail with ZX_ERR_NOT_SUPPORTED.

async fn sync(&self) -> Result<(), Status>

Syncs the directory.

fn link<'a>( self: Arc<Self>, _name: String, _source_dir: Arc<dyn Any + Send + Sync>, _source_name: &'a str, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'a>>

Adds a child entry to this directory. If the target exists, it should fail with ZX_ERR_ALREADY_EXISTS.

fn rename( self: Arc<Self>, _src_dir: Arc<dyn MutableDirectory>, _src_name: Path, _dst_name: Path, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send>>

Renames into this directory.

fn create_symlink( &self, _name: String, _target: Vec<u8>, _connection: Option<ServerEnd<SymlinkMarker>>, ) -> impl Future<Output = Result<(), Status>> + Send

where Self: Sized,

Creates a symbolic link.

impl Node for BlobDirectory

async fn get_attributes( &self, requested_attributes: NodeAttributesQuery, ) -> Result<NodeAttributes2, Status>

Returns node attributes (io2).

fn query_filesystem(&self) -> Result<FilesystemInfo, Status>

Returns information about the filesystem and/or volume.

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

Called when the node is about to be opened as the node protocol. Implementers can use this to perform any initialization or reference counting. Errors here will result in the open failing. By default, this forwards to the infallible will_clone.

fn will_clone(&self)

Called when the node is about to be cloned (and also by the default implementation of will_open_as_node). Implementations that perform their own open count can use this. Each call to will_clone will be accompanied by an eventual call to close.

fn close(self: Arc<Self>)

Called when the node is closed.

fn link_into( self: Arc<Self>, _destination_dir: Arc<dyn MutableDirectory>, _name: Name, ) -> impl Future<Output = Result<(), Status>> + Send

where Self: Sized,

fn open_as_node( self: Arc<Self>, scope: ExecutionScope, options: NodeOptions, object_request: &mut ObjectRequest, ) -> Result<(), Status>

where Self: Sized,

Opens the node using the node protocol.

fn list_extended_attributes( &self, ) -> impl Future<Output = Result<Vec<Vec<u8>>, Status>> + Send

where Self: Sized,

List extended attributes.

fn get_extended_attribute( &self, _name: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, Status>> + Send

where Self: Sized,

Get the value for an extended attribute.

fn set_extended_attribute( &self, _name: Vec<u8>, _value: Vec<u8>, _mode: SetExtendedAttributeMode, ) -> impl Future<Output = Result<(), Status>> + Send

where Self: Sized,

Set the value for an extended attribute.

fn remove_extended_attribute( &self, _name: Vec<u8>, ) -> impl Future<Output = Result<(), Status>> + Send

where Self: Sized,

Remove the value for an extended attribute.

impl RootDir for BlobDirectory

fn as_directory_entry(self: Arc<Self>) -> Arc<dyn DirectoryEntry>

fn serve(self: Arc<Self>, flags: Flags, server_end: ServerEnd<DirectoryMarker>)

fn as_node(self: Arc<Self>) -> Arc<dyn FxNode>

fn register_additional_volume_services( self: Arc<Self>, svc_dir: &Simple, ) -> Result<(), Error>

impl ToWeakNode for BlobDirectory

fn to_weak_node(self: Arc<Self>) -> WeakNode