diff --git a/cache/cache.go b/cache/cache.go index 2b3aa8fb..a2e4a7c5 100644 --- a/cache/cache.go +++ b/cache/cache.go @@ -353,12 +353,6 @@ func (c *Cache) Pop(key string) (p *points.Points, exists bool) { delete(shard.items, key) shard.Unlock() - // we probably can skip that, but I'm a bit worry - // of effectiveness of bloom filter over time - if c.newMetricsChan != nil && c.newMetricCf != nil { - c.newMetricCf.Delete([]byte(p.Metric)) - } - if exists { atomic.AddInt32(&c.stat.size, -int32(len(p.Data))) } @@ -383,12 +377,6 @@ func (c *Cache) PopNotConfirmed(key string) (p *points.Points, exists bool) { } shard.Unlock() - // we probably can skip that, but I'm a bit worry - // of effectiveness of bloom filter over time - if c.newMetricsChan != nil && c.newMetricCf != nil { - c.newMetricCf.Delete([]byte(p.Metric)) - } - if exists { atomic.AddInt32(&c.stat.size, -int32(len(p.Data))) }