dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Invalidate diskio cache if the metadata mtime has changed (#6835)

This commit is contained in:
Jonathan Hurter 2019-12-30 22:52:03 +01:00 committed by Daniel Nelson
parent dd67a1c764
commit 01e31e9d53
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugins/inputs/diskio/diskio_linux.go
View File

@ -11,6 +11,7 @@ import (
) )
type diskInfoCache struct { type diskInfoCache struct {
modifiedAt int64 // Unix Nano timestamp of the last modification of the device. This value is used to invalidate the cache
udevDataPath string udevDataPath string
values map[string]string values map[string]string
} }
@ -31,7 +32,8 @@ func (s *DiskIO) diskInfo(devName string) (map[string]string, error) {
s.infoCache = map[string]diskInfoCache{} s.infoCache = map[string]diskInfoCache{}
} }
ic, ok := s.infoCache[devName] ic, ok := s.infoCache[devName]
if ok {
if ok && stat.Mtim.Nano() == ic.modifiedAt {
return ic.values, nil return ic.values, nil
} }
@ -42,6 +44,7 @@ func (s *DiskIO) diskInfo(devName string) (map[string]string, error) {
di := map[string]string{} di := map[string]string{}
s.infoCache[devName] = diskInfoCache{ s.infoCache[devName] = diskInfoCache{
modifiedAt: stat.Mtim.Nano(),
udevDataPath: udevDataPath, udevDataPath: udevDataPath,
values: di, values: di,
} }