blob: 04366ab0dbd2e8aea9bf7dfd2137a6454e0be39b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
package mount
import (
"github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/util"
"sync"
)
type InodeToPath struct {
sync.RWMutex
nextInodeId uint64
inode2path map[uint64]util.FullPath
path2inode map[util.FullPath]uint64
}
func NewInodeToPath() *InodeToPath {
return &InodeToPath{
inode2path: make(map[uint64]util.FullPath),
path2inode: make(map[util.FullPath]uint64),
nextInodeId: 2, // the root inode id is 1
}
}
func (i *InodeToPath) GetInode(path util.FullPath) uint64 {
if path == "/" {
return 1
}
i.Lock()
defer i.Unlock()
inode, found := i.path2inode[path]
if !found {
inode = i.nextInodeId
i.nextInodeId++
i.path2inode[path] = inode
i.inode2path[inode] = path
}
return inode
}
func (i *InodeToPath) GetPath(inode uint64) util.FullPath {
if inode == 1 {
return "/"
}
i.RLock()
defer i.RUnlock()
path, found := i.inode2path[inode]
if !found {
glog.Fatal("not found inode %d", inode)
}
return path
}
func (i *InodeToPath) HasPath(path util.FullPath) bool {
if path == "/" {
return true
}
i.RLock()
defer i.RUnlock()
_, found := i.path2inode[path]
return found
}
|
