fs

package
v1.34.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 9, 2024 License: Apache-2.0 Imports: 29 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	DefaultBlksize    = uint32(1) << 12
	DefaultMaxNameLen = uint32(256)
)
View Source 
const (
	DefaultInodeExpiration = 120 * time.Second
	MaxInodeCache          = 10000000 // in terms of the number of items
	DefaultMaxInodeCache   = 2000000
)
View Source 
const (
	// the expiration duration of the dentry in the cache (used internally)
	DentryValidDuration = 5 * time.Second
	DefaultReaddirLimit = 1024
)
View Source 
const (
	// MinDentryCacheEvictNum is used in the foreground eviction.
	// When clearing the inodes from the cache, it stops as soon as 10 inodes have been evicted.
	MinDentryCacheEvictNum = 10
	// MaxDentryCacheEvictNum is used in the back ground. We can evict 200000 inodes at max.
	MaxDentryCacheEvictNum = 200000

	DentryBgEvictionInterval = 2 * time.Minute
)
View Source 
const (
	// MinInodeCacheEvictNum is used in the foreground eviction.
	// When clearing the inodes from the cache, it stops as soon as 10 inodes have been evicted.
	MinInodeCacheEvictNum = 10
	// MaxInodeCacheEvictNum is used in the back ground. We can evict 200000 inodes at max.
	MaxInodeCacheEvictNum = 200000

	BgEvictionInterval = 2 * time.Minute
)
View Source 
const (
	MinSummaryCacheEvictNum   = 10
	MaxSummaryCacheEvictNum   = 200000
	SummaryBgEvictionInterval = 2 * time.Minute
	DefaultSummaryExpiration  = 2 * time.Minute
	MaxSummaryCache           = 1000000
)
View Source 
const (
	BlobWriterIdleTimeoutPeriod = 10
	DefaultTaskPoolSize         = 30
)
View Source 
const (
	DefaultFlag = 0x0f
)
View Source 
const (
	DeleteExtentsTimeout = 600 * time.Second
)
View Source 
const (
	LogTimeFormat = "20060102150405000"
)
View Source 
const (
	MaxSizePutOnce = int64(1) << 23
)
View Source 
const (
	RootInode = proto.RootIno
)

Variables

View Source 
var (
	// The following two are used in the FUSE cache
	// every time the lookup will be performed on the fly, and the result will not be cached
	LookupValidDuration = 5 * time.Second
	// the expiration duration of the attributes in the FUSE cache
	AttrValidDuration = 30 * time.Second

	DisableMetaCache = true
)

Functions

func NewDir 

func NewDir(s *Super, i *proto.InodeInfo, pino uint64, dirName string) fs.Node

NewDir returns a new directory.

func NewFile 

func NewFile(s *Super, i *proto.InodeInfo, flag uint32, pino uint64, filename string) fs.Node

NewFile returns a new file.

func ParseError 

func ParseError(err error) fuse.Errno

ParseError returns the error type.

func ParseType 

func ParseType(t uint32) fuse.DirentType

ParseType returns the dentry type.

Types

type Dcache added in v1.34.0 

type Dcache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Dcache defines the structure of the inode cache.

func NewDcache added in v1.34.0 

func NewDcache(exp time.Duration, maxElements int) *Dcache

NewDentryCache returns a new inode cache.

func (*Dcache) Delete added in v1.34.0 

func (dc *Dcache) Delete(name string)

Delete deletes the dentry info based on the given name(partentId+name).

func (*Dcache) Get added in v1.34.0 

func (dc *Dcache) Get(name string) *proto.DentryInfo

Get returns the inode info based on the given inode number.

func (*Dcache) Put added in v1.34.0 

func (dc *Dcache) Put(info *proto.DentryInfo)

Put puts the given inode info into the inode cache.

type DentryCache 

type DentryCache struct {
	sync.Mutex
	// contains filtered or unexported fields
}

DentryCache defines the dentry cache.

func NewDentryCache 

func NewDentryCache() *DentryCache

NewDentryCache returns a new dentry cache.

func (*DentryCache) Delete 

func (dc *DentryCache) Delete(name string)

Delete deletes the item based on the given key.

func (*DentryCache) Get 

func (dc *DentryCache) Get(name string) (uint64, bool)

Get gets the item from the cache based on the given key.

func (*DentryCache) Put 

func (dc *DentryCache) Put(name string, ino uint64)

Put puts an item into the cache.

type Dir 

type Dir struct {
	// contains filtered or unexported fields
}

Dir defines the structure of a directory

func (*Dir) Attr 

func (d *Dir) Attr(ctx context.Context, a *fuse.Attr) error

Attr set the attributes of a directory.

func (*Dir) Create 

func (d *Dir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)

Create handles the create request.

func (*Dir) Forget 

func (d *Dir) Forget()

Forget is called when the evict is invoked from the kernel.

func (*Dir) Fsync 

func (d *Dir) Fsync(ctx context.Context, req *fuse.FsyncRequest) error

func (*Dir) Getxattr 

func (d *Dir) Getxattr(ctx context.Context, req *fuse.GetxattrRequest, resp *fuse.GetxattrResponse) error

Getxattr has not been implemented yet. 

func (d *Dir) Link(ctx context.Context, req *fuse.LinkRequest, old fs.Node) (fs.Node, error)

Link handles the link request.

func (*Dir) Listxattr 

func (d *Dir) Listxattr(ctx context.Context, req *fuse.ListxattrRequest, resp *fuse.ListxattrResponse) error

Listxattr has not been implemented yet.

func (*Dir) Lookup 

func (d *Dir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)

Lookup handles the lookup request.

func (*Dir) Mkdir 

func (d *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)

Mkdir handles the mkdir request.

func (*Dir) Mknod added in v1.1.1 

func (d *Dir) Mknod(ctx context.Context, req *fuse.MknodRequest) (fs.Node, error)

func (*Dir) ReadDir added in v1.34.0 

func (d *Dir) ReadDir(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) ([]fuse.Dirent, error)

func (*Dir) ReadDirAll 

func (d *Dir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

ReadDirAll gets all the dentries in a directory and puts them into the cache.

func (*Dir) Release added in v1.34.0 

func (d *Dir) Release(ctx context.Context, req *fuse.ReleaseRequest) (err error)

func (*Dir) Remove 

func (d *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error

Remove handles the remove request.

func (*Dir) Removexattr 

func (d *Dir) Removexattr(ctx context.Context, req *fuse.RemovexattrRequest) error

Removexattr has not been implemented yet.

func (*Dir) Rename 

func (d *Dir) Rename(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node) error

Rename handles the rename request.

func (*Dir) Setattr 

func (d *Dir) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error

Setattr handles the setattr request.

func (*Dir) Setxattr 

func (d *Dir) Setxattr(ctx context.Context, req *fuse.SetxattrRequest) error

Setxattr has not been implemented yet. 

func (d *Dir) Symlink(ctx context.Context, req *fuse.SymlinkRequest) (fs.Node, error)

Symlink handles the symlink request.

type DirContext added in v1.34.0 

type DirContext struct {
	Name string
}

used to locate the position in parent

type DirContexts added in v1.34.0 

type DirContexts struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDirContexts added in v1.34.0 

func NewDirContexts() (dctx *DirContexts)

func (*DirContexts) GetCopy added in v1.34.0 

func (dctx *DirContexts) GetCopy(handle fuse.HandleID) DirContext

func (*DirContexts) Put added in v1.34.0 

func (dctx *DirContexts) Put(handle fuse.HandleID, dirCtx *DirContext)

func (*DirContexts) Remove added in v1.34.0 

func (dctx *DirContexts) Remove(handle fuse.HandleID)

type File 

type File struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

File defines the structure of a file.

func (*File) Attr 

func (f *File) Attr(ctx context.Context, a *fuse.Attr) error

Attr sets the attributes of a file.

func (*File) Flush 

func (f *File) Flush(ctx context.Context, req *fuse.FlushRequest) (err error)

Flush only when fsyncOnClose is enabled.

func (*File) Forget 

func (f *File) Forget()

Forget evicts the inode of the current file. This can only happen when the inode is on the orphan list.

func (*File) Fsync 

func (f *File) Fsync(ctx context.Context, req *fuse.FsyncRequest) (err error)

Fsync hanldes the fsync request.

func (*File) Getxattr 

func (f *File) Getxattr(ctx context.Context, req *fuse.GetxattrRequest, resp *fuse.GetxattrResponse) error

Getxattr has not been implemented yet.

func (*File) Listxattr 

func (f *File) Listxattr(ctx context.Context, req *fuse.ListxattrRequest, resp *fuse.ListxattrResponse) error

Listxattr has not been implemented yet.

func (*File) Open 

func (f *File) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (handle fs.Handle, err error)

Open handles the open request.

func (*File) Read 

func (f *File) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) (err error)

Read handles the read request. 

func (f *File) Readlink(ctx context.Context, req *fuse.ReadlinkRequest) (string, error)

Readlink handles the readlink request.

func (*File) Release 

func (f *File) Release(ctx context.Context, req *fuse.ReleaseRequest) (err error)

Release handles the release request.

func (*File) Removexattr 

func (f *File) Removexattr(ctx context.Context, req *fuse.RemovexattrRequest) error

Removexattr has not been implemented yet.

func (*File) Setattr 

func (f *File) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error

Setattr handles the setattr request.

func (*File) Setxattr 

func (f *File) Setxattr(ctx context.Context, req *fuse.SetxattrRequest) error

Setxattr has not been implemented yet.

func (*File) Write 

func (f *File) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) (err error)

Write handles the write request.

type InodeCache 

type InodeCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

InodeCache defines the structure of the inode cache.

func NewInodeCache 

func NewInodeCache(exp time.Duration, maxElements int) *InodeCache

NewInodeCache returns a new inode cache.

func (*InodeCache) Delete 

func (ic *InodeCache) Delete(ino uint64)

Delete deletes the inode info based on the given inode number.

func (*InodeCache) Get 

func (ic *InodeCache) Get(ino uint64) *proto.InodeInfo

Get returns the inode info based on the given inode number.

func (*InodeCache) Put 

func (ic *InodeCache) Put(info *proto.InodeInfo)

Put puts the given inode info into the inode cache.

type OrphanInodeList 

type OrphanInodeList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

OrphanInodeList defines the orphan inode list, which is a list of orphan inodes. An orphan inode is the inode whose nlink value is 0.

func NewOrphanInodeList 

func NewOrphanInodeList() *OrphanInodeList

NewOrphanInodeList returns a new orphan inode list.

func (*OrphanInodeList) Evict 

func (l *OrphanInodeList) Evict(ino uint64) bool

Evict remove the given inode from the orphan inode list, and evicts it.

func (*OrphanInodeList) Put 

func (l *OrphanInodeList) Put(ino uint64)

Put puts an inode into the orphan inode list.

type SummaryCache added in v1.34.0 

type SummaryCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SummaryCache defines the structure of the content-summary cache.

func NewSummaryCache added in v1.34.0 

func NewSummaryCache(exp time.Duration, maxElement int) *SummaryCache

NewSummaryCache returns a new content-summary cache.

func (*SummaryCache) Delete added in v1.34.0 

func (sc *SummaryCache) Delete(inode uint64)

Delete deletes the content-summary info based on the given inode number.

func (*SummaryCache) Get added in v1.34.0 

func (sc *SummaryCache) Get(inode uint64) *meta.SummaryInfo

Get returns the content-summary info based on the given inode number.

func (*SummaryCache) Put added in v1.34.0 

func (sc *SummaryCache) Put(inode uint64, summaryInfo *meta.SummaryInfo)

Put puts the given summary info into the content-summary cache.

type Super 

type Super struct {
	CacheAction    int
	CacheThreshold int
	EbsBlockSize   int
	// contains filtered or unexported fields
}

Super defines the struct of a super block.

func NewSuper 

func NewSuper(opt *proto.MountOptions) (s *Super, err error)

NewSuper returns a new Super.

func (*Super) Close added in v1.34.0 

func (s *Super) Close()

func (*Super) ClusterName 

func (s *Super) ClusterName() string

ClusterName returns the cluster name.

func (*Super) DisableTrash added in v1.34.0 

func (s *Super) DisableTrash(w http.ResponseWriter, r *http.Request)

func (*Super) EnableAuditLog added in v1.34.0 

func (s *Super) EnableAuditLog(w http.ResponseWriter, r *http.Request)

func (*Super) GetRate added in v1.4.0 

func (s *Super) GetRate(w http.ResponseWriter, r *http.Request)

func (*Super) InodeGet 

func (s *Super) InodeGet(ino uint64) (info *proto.InodeInfo, err error)

func (*Super) Node added in v1.34.0 

func (s *Super) Node(ino, pino uint64, mode uint32) (fs.Node, error)

func (*Super) Notify added in v1.34.0 

func (s *Super) Notify(stat fs.FSStatType, msg interface{})

func (*Super) QueryTrash added in v1.34.0 

func (s *Super) QueryTrash(w http.ResponseWriter, r *http.Request)

func (*Super) Root 

func (s *Super) Root() (fs.Node, error)

Root returns the root directory where it resides.

func (*Super) SetRate added in v1.4.0 

func (s *Super) SetRate(w http.ResponseWriter, r *http.Request)

func (*Super) SetResume added in v1.34.0 

func (s *Super) SetResume(w http.ResponseWriter, r *http.Request)

func (*Super) SetSockAddr added in v1.34.0 

func (s *Super) SetSockAddr(addr string)

func (*Super) SetSuspend added in v1.34.0 

func (s *Super) SetSuspend(w http.ResponseWriter, r *http.Request)

func (*Super) SetTransaction added in v1.34.0 

func (s *Super) SetTransaction(txMaskStr string, timeout int64, retryNum int64, retryInterval int64)

func (*Super) State added in v1.34.0 

func (s *Super) State() (state fs.FSStatType, sockaddr string)

func (*Super) Statfs 

func (s *Super) Statfs(ctx context.Context, req *fuse.StatfsRequest, resp *fuse.StatfsResponse) error

Statfs handles the Statfs request and returns a set of statistics.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.