|
|
@@ -260,18 +260,18 @@ func NewContainer(id ContainerID, cg *cgroup.Cgroup, md *ContainerMetadata, host
|
|
|
|
|
|
c.runLogParser("")
|
|
|
|
|
|
- go func() {
|
|
|
- ticker := time.NewTicker(gcInterval)
|
|
|
- defer ticker.Stop()
|
|
|
- for {
|
|
|
- select {
|
|
|
- case <-c.done:
|
|
|
- return
|
|
|
- case t := <-ticker.C:
|
|
|
- c.gc(t)
|
|
|
- }
|
|
|
- }
|
|
|
- }()
|
|
|
+ // go func() {
|
|
|
+ // ticker := time.NewTicker(gcInterval)
|
|
|
+ // defer ticker.Stop()
|
|
|
+ // for {
|
|
|
+ // select {
|
|
|
+ // case <-c.done:
|
|
|
+ // return
|
|
|
+ // case t := <-ticker.C:
|
|
|
+ // c.gc(t)
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // }()
|
|
|
|
|
|
return c, nil
|
|
|
}
|
|
|
@@ -468,6 +468,8 @@ func (c *Container) Collect(ch chan<- prometheus.Metric) {
|
|
|
ch <- gauge(metrics.NetLatency, rtt, ip.String())
|
|
|
}
|
|
|
}
|
|
|
+ // time.Now()
|
|
|
+ c.gc(time.Now())
|
|
|
}
|
|
|
|
|
|
func (c *Container) onProcessStart(pid uint32) *Process {
|