From 75282b27ba6ae6a45a49eb78afcf39218372ca84 Mon Sep 17 00:00:00 2001
From: beorn7 <beorn@soundcloud.com>
Date: Sat, 4 Feb 2017 23:40:22 +0100
Subject: [PATCH] storage: Added checks for invariants

---
 storage/local/persistence.go | 3 +++
 storage/local/series.go      | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/storage/local/persistence.go b/storage/local/persistence.go
index ebaceeaea..a76d5de8e 100644
--- a/storage/local/persistence.go
+++ b/storage/local/persistence.go
@@ -706,6 +706,9 @@ func (p *persistence) checkpointSeriesMapAndHeads(fingerprintToSeries *seriesMap
 				}
 			}
 			// chunkDescsOffset.
+			if m.series.chunkDescsOffset < 0 && m.series.persistWatermark > 0 {
+				panic("encountered unknown chunk desc offset in combination with positive persist watermark")
+			}
 			if _, err = codable.EncodeVarint(w, int64(m.series.chunkDescsOffset+m.series.persistWatermark)); err != nil {
 				return
 			}
diff --git a/storage/local/series.go b/storage/local/series.go
index d9c36d0ef..63e4a0e2a 100644
--- a/storage/local/series.go
+++ b/storage/local/series.go
@@ -283,6 +283,9 @@ func (s *memorySeries) evictChunkDescs(lenToEvict int) {
 	if lenToEvict < 1 {
 		return
 	}
+	if s.chunkDescsOffset < 0 {
+		panic("chunk desc eviction requested with unknown chunk desc offset")
+	}
 	lenToKeep := len(s.chunkDescs) - lenToEvict
 	s.savedFirstTime = s.firstTime()
 	s.chunkDescsOffset += lenToEvict