Struct tvix_castore::fs::TvixStoreFs

pub struct TvixStoreFs<BS, DS, RN> {
    blob_service: BS,
    directory_service: DS,
    root_nodes_provider: RN,
    list_root: bool,
    show_xattr: bool,
    root_nodes: RwLock<HashMap<PathComponent, u64>>,
    inode_tracker: RwLock<InodeTracker>,
    dir_handles: RwLock<HashMap<u64, (Span, Arc<Mutex<Receiver<(usize, Result<(PathComponent, Node), Error>)>>>)>>,
    next_dir_handle: AtomicU64,
    file_handles: RwLock<HashMap<u64, (Span, Arc<Mutex<Box<dyn BlobReader>>>)>>,
    next_file_handle: AtomicU64,
    tokio_handle: Handle,
}

This implements a read-only FUSE filesystem for a tvix-store with the passed BlobService, DirectoryService and RootNodes.

Linux uses inodes in filesystems. When implementing FUSE, most calls are for a given inode.

This means, we need to have a stable mapping of inode numbers to the corresponding store nodes.

We internally delegate all inode allocation and state keeping to the inode tracker. We store a mapping from currently “explored” names in the root to their inode.

There’s some places where inodes are allocated / data inserted into the inode tracker, if not allocated before already:

• Processing a lookup request, either in the mount root, or somewhere deeper.
• Processing a readdir request

Things pointing to the same contents get the same inodes, irrespective of their own location. This means:

• Symlinks with the same target will get the same inode.
• Regular/executable files with the same contents will get the same inode
• Directories with the same contents will get the same inode.

Due to the above being valid across the whole store, and considering the merkle structure is a DAG, not a tree, this also means we can’t do “bucketed allocation”, aka reserve Directory.size inodes for each directory node we explore. Tests for this live in the tvix-store crate.

Fields

blob_service: BS

directory_service: DS

root_nodes_provider: RN

list_root: bool

Whether to (try) listing elements in the root.

show_xattr: bool

Whether to expose blob and directory digests as extended attributes.

root_nodes: RwLock<HashMap<PathComponent, u64>>

This maps a given basename in the root to the inode we allocated for the node.

inode_tracker: RwLock<InodeTracker>

This keeps track of inodes and data alongside them.

dir_handles: RwLock<HashMap<u64, (Span, Arc<Mutex<Receiver<(usize, Result<(PathComponent, Node), Error>)>>>)>>

Maps from the handle returned from an opendir to This holds all opendir handles (for the root inode) They point to the rx part of the channel producing the listing.

next_dir_handle: AtomicU64

file_handles: RwLock<HashMap<u64, (Span, Arc<Mutex<Box<dyn BlobReader>>>)>>

This holds all open file handles

next_file_handle: AtomicU64

tokio_handle: Handle

Implementations

impl<BS, DS, RN> TvixStoreFs<BS, DS, RN>

where BS: AsRef<dyn BlobService> + Clone + Send, DS: AsRef<dyn DirectoryService> + Clone + Send + 'static, RN: RootNodes + Clone + 'static,

pub fn new( blob_service: BS, directory_service: DS, root_nodes_provider: RN, list_root: bool, show_xattr: bool ) -> Self

fn get_inode_for_root_name(&self, name: &PathComponent) -> Option<u64>

Retrieves the inode for a given root node basename, if present. This obtains a read lock on self.root_nodes.

fn get_directory_children( &self, ino: u64 ) -> Result<(B3Digest, Vec<(u64, PathComponent, Node)>)>

For a given inode, look up the given directory behind it (from self.inode_tracker), and return its children. The inode_tracker MUST know about this inode already, and it MUST point to a InodeData::Directory. It is ok if it’s a DirectoryInodeData::Sparse - in that case, a lookup in self.directory_service is performed, and self.inode_tracker is updated with the DirectoryInodeData::Populated.

fn name_in_root_to_ino_and_data( &self, name: &PathComponent ) -> Result<(u64, Arc<InodeData>)>

This will turn a lookup request for a name in the root to a ino and InodeData. It will peek in [self.root_nodes], and then either look it up from [self.inode_tracker], or otherwise fetch from [self.root_nodes], and then insert into [self.inode_tracker]. In the case the name can’t be found, a libc::ENOENT is returned.

Trait Implementations

impl<BS, DS, RN> FileSystem for TvixStoreFs<BS, DS, RN>

where BS: AsRef<dyn BlobService> + Clone + Send + 'static, DS: AsRef<dyn DirectoryService> + Send + Clone + 'static, RN: RootNodes + Clone + 'static,

type Handle = u64

Represents a file or directory that is open for reading/writing.

type Inode = u64

Represents a location in the filesystem tree and can be used to perform operations that act on the metadata of a file/directory (e.g., getattr and setattr). Can also be used as the starting point for looking up paths in the filesystem tree. An Inode may support operating directly on the content of the path that to which it points. FileSystem implementations that support this should set the FsOptions::ZERO_MESSAGE_OPEN option in the return value of the init function. On linux based systems, an Inode is equivalent to opening a file or directory with the libc::O_PATH flag.

fn init(&self, _capable: FsOptions) -> Result<FsOptions>

Initialize the file system.

fn getattr( &self, _ctx: &Context, inode: Self::Inode, _handle: Option<Self::Handle> ) -> Result<(stat64, Duration)>

Get attributes for a file / directory.

fn lookup( &self, _ctx: &Context, parent: Self::Inode, name: &CStr ) -> Result<Entry>

Look up a directory entry by name and get its attributes.

fn opendir( &self, _ctx: &Context, inode: Self::Inode, _flags: u32 ) -> Result<(Option<Self::Handle>, OpenOptions)>

Open a directory for reading.

fn readdir( &self, _ctx: &Context, inode: Self::Inode, handle: Self::Handle, _size: u32, offset: u64, add_entry: &mut dyn FnMut(DirEntry<'_>) -> Result<usize> ) -> Result<()>

Read a directory.

fn readdirplus( &self, _ctx: &Context, inode: Self::Inode, handle: Self::Handle, _size: u32, offset: u64, add_entry: &mut dyn FnMut(DirEntry<'_>, Entry) -> Result<usize> ) -> Result<()>

Read a directory with entry attributes.

fn releasedir( &self, _ctx: &Context, inode: Self::Inode, _flags: u32, handle: Self::Handle ) -> Result<()>

Release an open directory.

fn open( &self, _ctx: &Context, inode: Self::Inode, _flags: u32, _fuse_flags: u32 ) -> Result<(Option<Self::Handle>, OpenOptions)>

Open a file.

fn release( &self, _ctx: &Context, inode: Self::Inode, _flags: u32, handle: Self::Handle, _flush: bool, _flock_release: bool, _lock_owner: Option<u64> ) -> Result<()>

Release an open file.

fn read( &self, _ctx: &Context, inode: Self::Inode, handle: Self::Handle, w: &mut dyn ZeroCopyWriter, size: u32, offset: u64, _lock_owner: Option<u64>, _flags: u32 ) -> Result<usize>

Read data from a file.

fn readlink(&self, _ctx: &Context, inode: Self::Inode) -> Result<Vec<u8>>

Read a symbolic link.

fn getxattr( &self, _ctx: &Context, inode: Self::Inode, name: &CStr, size: u32 ) -> Result<GetxattrReply>

Get an extended attribute.

fn listxattr( &self, _ctx: &Context, inode: Self::Inode, size: u32 ) -> Result<ListxattrReply>

List extended attribute names.

fn destroy(&self)

Clean up the file system.

fn forget(&self, ctx: &Context, inode: Self::Inode, count: u64)

Forget about an inode.

fn batch_forget(&self, ctx: &Context, requests: Vec<(Self::Inode, u64)>)

Forget about multiple inodes.

fn setattr( &self, ctx: &Context, inode: Self::Inode, attr: stat64, handle: Option<Self::Handle>, valid: SetattrValid ) -> Result<(stat64, Duration), Error>

Set attributes for a file / directory.

fn symlink( &self, ctx: &Context, linkname: &CStr, parent: Self::Inode, name: &CStr ) -> Result<Entry, Error>

Create a symbolic link.

fn mknod( &self, ctx: &Context, inode: Self::Inode, name: &CStr, mode: u32, rdev: u32, umask: u32 ) -> Result<Entry, Error>

Create a file node.

fn mkdir( &self, ctx: &Context, parent: Self::Inode, name: &CStr, mode: u32, umask: u32 ) -> Result<Entry, Error>

Create a directory.

fn unlink( &self, ctx: &Context, parent: Self::Inode, name: &CStr ) -> Result<(), Error>

Remove a file.

fn rmdir( &self, ctx: &Context, parent: Self::Inode, name: &CStr ) -> Result<(), Error>

Remove a directory.

fn rename( &self, ctx: &Context, olddir: Self::Inode, oldname: &CStr, newdir: Self::Inode, newname: &CStr, flags: u32 ) -> Result<(), Error>

Rename a file / directory.

fn link( &self, ctx: &Context, inode: Self::Inode, newparent: Self::Inode, newname: &CStr ) -> Result<Entry, Error>

Create a hard link.

fn create( &self, ctx: &Context, parent: Self::Inode, name: &CStr, args: CreateIn ) -> Result<(Entry, Option<Self::Handle>, OpenOptions), Error>

Create and open a file.

fn write( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, r: &mut dyn ZeroCopyReader, size: u32, offset: u64, lock_owner: Option<u64>, delayed_write: bool, flags: u32, fuse_flags: u32 ) -> Result<usize, Error>

Write data to a file.

fn flush( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, lock_owner: u64 ) -> Result<(), Error>

Flush the contents of a file.

fn fsync( &self, ctx: &Context, inode: Self::Inode, datasync: bool, handle: Self::Handle ) -> Result<(), Error>

Synchronize file contents.

fn fallocate( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, mode: u32, offset: u64, length: u64 ) -> Result<(), Error>

Allocate requested space for file data.

fn statfs(&self, ctx: &Context, inode: Self::Inode) -> Result<statvfs64, Error>

Get information about the file system.

fn setxattr( &self, ctx: &Context, inode: Self::Inode, name: &CStr, value: &[u8], flags: u32 ) -> Result<(), Error>

Set an extended attribute.

fn removexattr( &self, ctx: &Context, inode: Self::Inode, name: &CStr ) -> Result<(), Error>

Remove an extended attribute.

fn fsyncdir( &self, ctx: &Context, inode: Self::Inode, datasync: bool, handle: Self::Handle ) -> Result<(), Error>

Synchronize the contents of a directory.

fn access( &self, ctx: &Context, inode: Self::Inode, mask: u32 ) -> Result<(), Error>

Check file access permissions.

fn lseek( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, offset: u64, whence: u32 ) -> Result<u64, Error>

Reposition read/write file offset.

fn getlk( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, owner: u64, lock: FileLock, flags: u32 ) -> Result<FileLock, Error>

Query file lock status

fn setlk( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, owner: u64, lock: FileLock, flags: u32 ) -> Result<(), Error>

Grab a file read lock

fn setlkw( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, owner: u64, lock: FileLock, flags: u32 ) -> Result<(), Error>

Grab a file write lock

fn ioctl( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, flags: u32, cmd: u32, data: IoctlData<'_>, out_size: u32 ) -> Result<IoctlData<'_>, Error>

send ioctl to the file

fn bmap( &self, ctx: &Context, inode: Self::Inode, block: u64, blocksize: u32 ) -> Result<u64, Error>

Query a file’s block mapping info

fn poll( &self, ctx: &Context, inode: Self::Inode, handle: Self::Handle, khandle: Self::Handle, flags: u32, events: u32 ) -> Result<u32, Error>

Poll a file’s events

fn notify_reply(&self) -> Result<(), Error>

TODO: support this

fn id_remap(&self, ctx: &mut Context) -> Result<(), Error>

Remap the external IDs in context to internal IDs.