compactor: make TestPeriodic die early

This commit is contained in:
Xiang
2017-03-28 13:50:16 -07:00
parent 123b25845c
commit a915ff8419

View File

@ -45,7 +45,10 @@ func TestPeriodic(t *testing.T) {
// advance one hour, one revision for each interval // advance one hour, one revision for each interval
for j := 0; j < n; j++ { for j := 0; j < n; j++ {
fc.Advance(checkCompactionInterval) fc.Advance(checkCompactionInterval)
rg.Wait(1) _, err := rg.Wait(1)
if err != nil {
t.Fatal(err)
}
} }
// ready to acknowledge hour "i" // ready to acknowledge hour "i"
// block until compactor calls clock.After() // block until compactor calls clock.After()