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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
// SPDX-License-Identifier: GPL-3.0-or-later
package filecheck
import (
"fmt"
"os"
"path/filepath"
"time"
)
func (f *Filecheck) collectDirs(mx map[string]int64) {
now := time.Now()
if f.isTimeToDiscoverDirs(now) {
f.lastDiscDirsTime = now
f.curDirs = f.discoveryDirs()
}
var infos []*statInfo
for _, dir := range f.curDirs {
si := getStatInfo(dir)
infos = append(infos, si)
f.collectDir(mx, si, now)
}
f.updateDirCharts(infos)
}
func (f *Filecheck) collectDir(mx map[string]int64, si *statInfo, now time.Time) {
px := fmt.Sprintf("dir_%s_", si.path)
mx[px+"existence_status_exist"] = 0
mx[px+"existence_status_not_exist"] = 0
if !si.exists {
mx[px+"existence_status_not_exist"] = 1
} else {
mx[px+"existence_status_exist"] = 1
}
if si.fi == nil || !si.fi.IsDir() {
return
}
mx[px+"mtime_ago"] = int64(now.Sub(si.fi.ModTime()).Seconds())
if v, err := calcFilesInDir(si.path); err == nil {
mx[px+"files_count"] = v
}
if f.Dirs.CollectDirSize {
if v, err := calcDirSize(si.path); err == nil {
mx[px+"size_bytes"] = v
}
}
}
func (f *Filecheck) discoveryDirs() (dirs []string) {
return discoverFilesOrDirs(f.Dirs.Include, func(v string, fi os.FileInfo) bool {
return fi.IsDir() && !f.dirsFilter.MatchString(v)
})
}
func (f *Filecheck) isTimeToDiscoverDirs(now time.Time) bool {
return now.After(f.lastDiscDirsTime.Add(f.DiscoveryEvery.Duration()))
}
func calcFilesInDir(dirPath string) (int64, error) {
f, err := os.Open(dirPath)
if err != nil {
return 0, err
}
defer func() { _ = f.Close() }()
names, err := f.Readdirnames(-1)
return int64(len(names)), err
}
func calcDirSize(dirPath string) (int64, error) {
var size int64
err := filepath.Walk(dirPath, func(_ string, fi os.FileInfo, err error) error {
if err != nil {
return err
}
if !fi.IsDir() {
size += fi.Size()
}
return nil
})
return size, err
}
|
