wu

Author: Dieterbe

api/dataprocessor_test.go

@@ -499,7 +499,6 @@ func TestGetSeriesCachedStore(t *testing.T) {
 	metrics := mdata.NewAggMetrics(store, &cache.MockCache{}, false, 0, 0, 0)
 	srv.BindMemoryStore(metrics)
 	metric := test.GetAMKey(1)
-	var c *cache.CCache
 	var itgen *chunk.IterGen
 	var prevts uint32
 
@@ -527,7 +526,7 @@ func TestGetSeriesCachedStore(t *testing.T) {
 	}
 
 	// going through all testcases
-	for _, tc := range testcases {
+	for j, tc := range testcases {
 		fmt.Println("TESTCASE", tc)
 		pattern := tc.Pattern
 
@@ -541,12 +540,16 @@ func TestGetSeriesCachedStore(t *testing.T) {
 		// and various ranges between
 		// we increment from and to in thirds of a span,
 		// because incrementing by 1 would be needlessly expensive
-		step := span / 3
+		step := span / 2
+		i := 0
 		for from := start; from <= lastTs; from += step {
 			for to := from; to <= lastTs; to += step {
-				fmt.Println(from, to)
+				if j == 7 && i%20 == 0 {
+					fmt.Println(">", i)
+				}
+				i++
 				// use fresh store and cache
-				c = cache.NewCCache()
+				c := cache.NewCCache()
 				srv.BindCache(c)
 				store.Reset()
 
@@ -591,7 +594,7 @@ func TestGetSeriesCachedStore(t *testing.T) {
 				// we use the tsTracker to increase together with the iterators and compare at each step
 				tsTracker := expectResFrom
 
-				tsSlice := make([]uint32, 0)
+				var tsSlice []uint32
 				for i, it := range iters {
 					for it.Next() {
 						ts, _ := it.Values()
@@ -676,8 +679,8 @@ func TestGetSeriesCachedStore(t *testing.T) {
 				c.Stop()
 			}
 		}
+		fmt.Println("DID", i, "iterations")
 	}
-	fmt.Println("all done")
 }
 
 func TestGetSeriesAggMetrics(t *testing.T) {