mirror of https://github.com/prometheus/prometheus
commit
95400cb785
|
@ -131,7 +131,7 @@ func testProcessor001Process(t test.Tester) {
|
||||||
|
|
||||||
reader, err := os.Open(path.Join("fixtures", scenario.in))
|
reader, err := os.Open(path.Join("fixtures", scenario.in))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d. couldn't open scenario input file %s: %s", scenario.in, err)
|
t.Fatalf("%d. couldn't open scenario input file %s: %s", i, scenario.in, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
err = Processor001.Process(reader, time.Now(), scenario.baseLabels, inputChannel)
|
err = Processor001.Process(reader, time.Now(), scenario.baseLabels, inputChannel)
|
||||||
|
|
|
@ -131,7 +131,7 @@ func testProcessor002Process(t test.Tester) {
|
||||||
|
|
||||||
reader, err := os.Open(path.Join("fixtures", scenario.in))
|
reader, err := os.Open(path.Join("fixtures", scenario.in))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("%d. couldn't open scenario input file %s: %s", scenario.in, err)
|
t.Fatalf("%d. couldn't open scenario input file %s: %s", i, scenario.in, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
err = Processor002.Process(reader, time.Now(), scenario.baseLabels, inputChannel)
|
err = Processor002.Process(reader, time.Now(), scenario.baseLabels, inputChannel)
|
||||||
|
|
|
@ -217,7 +217,6 @@ func (t *TieredStorage) Serve(started chan<- bool) {
|
||||||
t.mu.Lock()
|
t.mu.Lock()
|
||||||
if t.state != tieredStorageStarting {
|
if t.state != tieredStorageStarting {
|
||||||
panic("Illegal State: Attempted to restart TieredStorage.")
|
panic("Illegal State: Attempted to restart TieredStorage.")
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
t.state = tieredStorageServing
|
t.state = tieredStorageServing
|
||||||
|
|
Loading…
Reference in New Issue