prometheus/cadvisor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Switch to select on time.After & close channel for track usage

Browse Source
This commit is contained in:
Jimmi Dyson 2015-10-14 09:58:42 +01:00
parent 0d6015c741
commit b4a6819291
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
container/docker/fsHandler.go
View File

@ -78,10 +78,11 @@ func (fh *realFsHandler) update() error {
func (fh *realFsHandler) trackUsage() { func (fh *realFsHandler) trackUsage() {
for { for {
start := time.Now() select {
if _, ok := <-fh.stopChan; !ok { case <-fh.stopChan:
return return
} case <-time.After(fh.period):
start := time.Now()
if err := fh.update(); err != nil { if err := fh.update(); err != nil {
glog.V(2).Infof("failed to collect filesystem stats - %v", err) glog.V(2).Infof("failed to collect filesystem stats - %v", err)
} }
@ -89,8 +90,7 @@ func (fh *realFsHandler) trackUsage() {
if duration > longDu { if duration > longDu {
glog.V(3).Infof("`du` on following dirs took %v: %v", duration, fh.storageDirs) glog.V(3).Infof("`du` on following dirs took %v: %v", duration, fh.storageDirs)
} }
next := start.Add(fh.period) }
time.Sleep(next.Sub(time.Now()))
} }
} }