try testing slightly different way
This commit is contained in:
parent
cd940cc375
commit
e54db33346
|
@ -12,6 +12,7 @@ package firestorm
|
||||||
import (
|
import (
|
||||||
"runtime"
|
"runtime"
|
||||||
"testing"
|
"testing"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/blevesearch/bleve/index"
|
"github.com/blevesearch/bleve/index"
|
||||||
"github.com/blevesearch/bleve/index/store/gtreap"
|
"github.com/blevesearch/bleve/index/store/gtreap"
|
||||||
|
@ -42,7 +43,7 @@ func TestDictUpdater(t *testing.T) {
|
||||||
for len(f.(*Firestorm).dictUpdater.incoming) > 0 {
|
for len(f.(*Firestorm).dictUpdater.incoming) > 0 {
|
||||||
runtime.Gosched()
|
runtime.Gosched()
|
||||||
}
|
}
|
||||||
f.(*Firestorm).dictUpdater.update()
|
f.(*Firestorm).dictUpdater.waitTasksDone(5 * time.Second)
|
||||||
|
|
||||||
// assert that dictionary rows are correct
|
// assert that dictionary rows are correct
|
||||||
reader, err := f.(*Firestorm).store.Reader()
|
reader, err := f.(*Firestorm).store.Reader()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user