From 008bc09da882f13251c7a16597a79718f45914a9 Mon Sep 17 00:00:00 2001 From: Julius Volz Date: Wed, 19 Jun 2013 14:19:53 +0200 Subject: [PATCH] Move check for empty memory series to separate method. --- storage/metric/memory.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/storage/metric/memory.go b/storage/metric/memory.go index 6187b79230..252d1ac60e 100644 --- a/storage/metric/memory.go +++ b/storage/metric/memory.go @@ -141,6 +141,10 @@ func (s *stream) getRangeValues(in model.Interval) model.Values { return result } +func (s *stream) empty() bool { + return len(s.values) == 0 +} + func newStream(metric model.Metric) *stream { return &stream{ metric: metric, @@ -258,7 +262,7 @@ func (s *memorySeriesStorage) Flush(flushOlderThan time.Time, queue chan<- model s.Lock() for _, fingerprint := range emptySeries { - if len(s.fingerprintToSeries[fingerprint].values) == 0 { + if s.fingerprintToSeries[fingerprint].empty() { s.dropSeries(&fingerprint) } }