Fix condition for dropping empty memory series.

2013-06-25 17:57:35 +02:00 · 2013-06-25 17:57:35 +02:00 · baa5b07829
parent 30b1cf80b5
commit baa5b07829
1 changed files with 2 additions and 5 deletions
--- a/storage/metric/memory.go
+++ b/storage/metric/memory.go
@ -266,12 +266,9 @@ func (s *memorySeriesStorage) Flush(flushOlderThan time.Time, queue chan<- clien

 	s.Lock()
 	for _, fingerprint := range emptySeries {
-		series, _ := s.fingerprintToSeries[*fingerprint]
-		if series.empty() {
-			continue
+		if s.fingerprintToSeries[*fingerprint].empty() {
+			s.dropSeries(fingerprint)
 		}
-
-		s.dropSeries(fingerprint)
 	}
 	s.Unlock()
 }