From a8468a2e5eda80d17179c8a9fe245d02809bc3c1 Mon Sep 17 00:00:00 2001 From: Julius Volz Date: Tue, 28 May 2013 16:14:30 +0200 Subject: [PATCH] Fix reversed disk flush cutoff behavior. --- storage/metric/tiered.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/storage/metric/tiered.go b/storage/metric/tiered.go index 7976d24203..0af4538e36 100644 --- a/storage/metric/tiered.go +++ b/storage/metric/tiered.go @@ -215,14 +215,14 @@ func (t *TieredStorage) flushMemory(ttl time.Duration) { for _, stream := range t.memoryArena.fingerprintToSeries { finder := func(i int) bool { - return !cutOff.After(stream.values[i].Timestamp) + return stream.values[i].Timestamp.After(cutOff) } stream.Lock() i := sort.Search(len(stream.values), finder) - toArchive := stream.values[i:] - toKeep := stream.values[:i] + toArchive := stream.values[:i] + toKeep := stream.values[i:] queued := make(model.Samples, 0, len(toArchive)) for _, value := range toArchive {