debug logging for stacktest

grafana · Mar 11, 2019 · 8e3f270 · 8e3f270
1 parent 26f8e6f
commit 8e3f270
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/idx/memory/find_cache.go b/idx/memory/find_cache.go
@@ -31,6 +31,7 @@ func NewFindCache(size int) *FindCache {
 		cache:     make(map[uint32]*lru.Cache),
 		size:      size,
 		newSeries: make(map[uint32]chan struct{}),
+		backoff:   make(map[uint32]time.Time),
 	}
 	return fc
 }
@@ -69,7 +70,7 @@ func (c *FindCache) Add(orgId uint32, pattern string, nodes []*Node) {
 		}
 		c.Lock()
 		c.cache[orgId] = cache
-		c.newSeries[orgId] = make(chan struct{}, 100)
+		c.newSeries[orgId] = make(chan struct{}, 10)
 		c.Unlock()
 	}
 	cache.Add(pattern, nodes)

diff --git a/stacktest/fakemetrics/fakemetrics.go b/stacktest/fakemetrics/fakemetrics.go
@@ -102,7 +102,9 @@ func (f *FakeMetrics) run() {
 			}
 			err := f.o.Flush(f.metrics)
 			if err != nil {
-				panic(fmt.Sprintf("failed to send data to output: %s", err))
+				log.Errorf("fakemetrics: failed to send data to output: %s", err)
+				f.closed = true
+				return
 			}
 		}
 	}

diff --git a/stacktest/tests/end2end_carbon/end2end_carbon_test.go b/stacktest/tests/end2end_carbon/end2end_carbon_test.go
@@ -52,7 +52,7 @@ func TestMain(m *testing.M) {
 	cmd := exec.Command("docker-compose", "up", "--force-recreate")
 	cmd.Dir = docker.Path("docker/docker-dev")
 
-	tracker, err = track.NewTracker(cmd, false, false, "launch-stdout", "launch-stderr")
+	tracker, err = track.NewTracker(cmd, true, true, "launch-stdout", "launch-stderr")
 	if err != nil {
 		log.Fatal(err.Error())
 	}