()
| 165 | } |
| 166 | |
| 167 | func (c *counter) countSeriesDemand() int { |
| 168 | c.seriesMtx.RLock() |
| 169 | defer c.seriesMtx.RUnlock() |
| 170 | |
| 171 | return int(c.seriesDemand.Estimate()) |
| 172 | } |
| 173 | |
| 174 | func (c *counter) removeStaleSeries(staleTimeMs int64) { |
| 175 | c.seriesMtx.Lock() |