(period time.Duration)
| 160 | } |
| 161 | |
| 162 | func (p *VMPool) runCleaner(period time.Duration) { |
| 163 | defer p.cleaner.Done() |
| 164 | ticker := time.NewTicker(period) |
| 165 | defer ticker.Stop() |
| 166 | for { |
| 167 | select { |
| 168 | case <-ticker.C: |
| 169 | p.cleanExpired() |
| 170 | case <-p.stop: |
| 171 | return |
| 172 | } |
| 173 | } |
| 174 | } |
| 175 | |
| 176 | func (p *VMPool) cleanExpired() { |
| 177 | now := time.Now() |
no test coverage detected