seaweedfs/weed/mount/inode_to_path.go

195 lines
4.3 KiB
Go
Raw Normal View History

2022-02-12 09:54:16 +00:00
package mount
import (
"github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/util"
"github.com/hanwen/go-fuse/v2/fuse"
2022-02-12 09:54:16 +00:00
"sync"
)
type InodeToPath struct {
sync.RWMutex
nextInodeId uint64
2022-02-13 13:49:29 +00:00
inode2path map[uint64]*InodeEntry
2022-02-12 09:54:16 +00:00
path2inode map[util.FullPath]uint64
}
2022-02-13 13:49:29 +00:00
type InodeEntry struct {
util.FullPath
2022-02-14 09:09:31 +00:00
nlookup uint64
isDirectory bool
isChildrenCached bool
2022-02-13 13:49:29 +00:00
}
2022-02-12 09:54:16 +00:00
2022-02-28 20:16:53 +00:00
func NewInodeToPath(root util.FullPath) *InodeToPath {
2022-02-14 09:09:31 +00:00
t := &InodeToPath{
2022-02-25 08:53:27 +00:00
inode2path: make(map[uint64]*InodeEntry),
path2inode: make(map[util.FullPath]uint64),
2022-02-12 09:54:16 +00:00
}
2022-02-28 20:16:53 +00:00
t.inode2path[1] = &InodeEntry{root, 1, true, false}
t.path2inode[root] = 1
2022-02-14 09:09:31 +00:00
return t
2022-02-12 09:54:16 +00:00
}
2022-03-14 07:03:29 +00:00
func (i *InodeToPath) Lookup(path util.FullPath, unixTime int64, isDirectory bool, isHardlink bool, possibleInode uint64, isLookup bool) uint64 {
2022-02-12 09:54:16 +00:00
i.Lock()
defer i.Unlock()
inode, found := i.path2inode[path]
if !found {
2022-02-25 08:53:27 +00:00
if possibleInode == 0 {
2022-03-14 07:03:29 +00:00
inode = path.AsInode(unixTime)
} else {
inode = possibleInode
}
if !isHardlink {
2022-02-25 08:53:27 +00:00
for _, found := i.inode2path[inode]; found; inode++ {
_, found = i.inode2path[inode]
}
2022-02-17 00:49:03 +00:00
}
2022-02-25 08:53:27 +00:00
}
i.path2inode[path] = inode
if _, found := i.inode2path[inode]; found {
2022-02-17 00:49:03 +00:00
if isLookup {
i.inode2path[inode].nlookup++
}
2022-02-25 08:53:27 +00:00
} else {
if !isLookup {
2022-03-14 07:03:29 +00:00
i.inode2path[inode] = &InodeEntry{path, 0, isDirectory, false}
2022-02-25 08:53:27 +00:00
} else {
2022-03-14 07:03:29 +00:00
i.inode2path[inode] = &InodeEntry{path, 1, isDirectory, false}
2022-02-25 08:53:27 +00:00
}
2022-02-13 13:49:29 +00:00
}
2022-02-25 08:53:27 +00:00
2022-02-13 13:49:29 +00:00
return inode
}
2022-03-14 07:03:29 +00:00
func (i *InodeToPath) AllocateInode(path util.FullPath, unixTime int64) uint64 {
if path == "/" {
return 1
}
i.Lock()
defer i.Unlock()
2022-03-14 07:03:29 +00:00
inode := path.AsInode(unixTime)
for _, found := i.inode2path[inode]; found; inode++ {
_, found = i.inode2path[inode]
}
return inode
}
2022-02-13 13:49:29 +00:00
func (i *InodeToPath) GetInode(path util.FullPath) uint64 {
if path == "/" {
return 1
}
i.Lock()
defer i.Unlock()
inode, found := i.path2inode[path]
if !found {
2022-02-13 13:59:10 +00:00
// glog.Fatalf("GetInode unknown inode for %s", path)
// this could be the parent for mount point
2022-02-12 09:54:16 +00:00
}
return inode
}
func (i *InodeToPath) GetPath(inode uint64) (util.FullPath, fuse.Status) {
2022-02-12 09:54:16 +00:00
i.RLock()
defer i.RUnlock()
path, found := i.inode2path[inode]
if !found {
return "", fuse.ENOENT
2022-02-12 09:54:16 +00:00
}
return path.FullPath, fuse.OK
2022-02-12 09:54:16 +00:00
}
func (i *InodeToPath) HasPath(path util.FullPath) bool {
i.RLock()
defer i.RUnlock()
_, found := i.path2inode[path]
return found
}
2022-02-13 06:21:30 +00:00
2022-02-14 09:09:31 +00:00
func (i *InodeToPath) MarkChildrenCached(fullpath util.FullPath) {
i.RLock()
defer i.RUnlock()
inode, found := i.path2inode[fullpath]
if !found {
glog.Fatalf("MarkChildrenCached not found inode %v", fullpath)
}
path, found := i.inode2path[inode]
path.isChildrenCached = true
}
func (i *InodeToPath) IsChildrenCached(fullpath util.FullPath) bool {
i.RLock()
defer i.RUnlock()
inode, found := i.path2inode[fullpath]
if !found {
return false
}
path, found := i.inode2path[inode]
if found {
return path.isChildrenCached
}
return false
}
2022-02-13 06:21:30 +00:00
func (i *InodeToPath) HasInode(inode uint64) bool {
if inode == 1 {
return true
}
i.RLock()
defer i.RUnlock()
_, found := i.inode2path[inode]
return found
}
2022-02-13 11:09:24 +00:00
func (i *InodeToPath) RemovePath(path util.FullPath) {
i.Lock()
defer i.Unlock()
inode, found := i.path2inode[path]
if found {
delete(i.path2inode, path)
delete(i.inode2path, inode)
}
}
2022-02-13 13:49:29 +00:00
func (i *InodeToPath) MovePath(sourcePath, targetPath util.FullPath) (replacedInode uint64) {
2022-02-14 00:34:57 +00:00
i.Lock()
defer i.Unlock()
sourceInode, sourceFound := i.path2inode[sourcePath]
targetInode, targetFound := i.path2inode[targetPath]
if sourceFound {
delete(i.path2inode, sourcePath)
i.path2inode[targetPath] = sourceInode
} else {
// it is possible some source folder items has not been visited before
// so no need to worry about their source inodes
return
}
i.inode2path[sourceInode].FullPath = targetPath
if targetFound {
delete(i.inode2path, targetInode)
} else {
i.inode2path[sourceInode].nlookup++
}
return targetInode
2022-02-14 00:34:57 +00:00
}
2022-02-14 09:09:31 +00:00
func (i *InodeToPath) Forget(inode, nlookup uint64, onForgetDir func(dir util.FullPath)) {
2022-02-13 13:49:29 +00:00
i.Lock()
2022-02-13 11:31:47 +00:00
path, found := i.inode2path[inode]
if found {
2022-02-13 13:49:29 +00:00
path.nlookup -= nlookup
if path.nlookup <= 0 {
delete(i.path2inode, path.FullPath)
delete(i.inode2path, inode)
}
2022-02-13 11:31:47 +00:00
}
2022-02-14 09:09:31 +00:00
i.Unlock()
if found {
if path.isDirectory && path.nlookup <= 0 && onForgetDir != nil {
path.isChildrenCached = false
2022-02-14 09:09:31 +00:00
onForgetDir(path.FullPath)
}
}
2022-02-13 11:31:47 +00:00
}