test delta cache with SetLinearImport
parent
c4a945750d
commit
5866471a07
|
@ -20,6 +20,14 @@ func mknode(id int64) element.Node {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestReadWriteDeltaCoords(t *testing.T) {
|
func TestReadWriteDeltaCoords(t *testing.T) {
|
||||||
|
checkReadWriteDeltaCoords(t, false)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestReadWriteDeltaCoordsLinearImport(t *testing.T) {
|
||||||
|
checkReadWriteDeltaCoords(t, true)
|
||||||
|
}
|
||||||
|
|
||||||
|
func checkReadWriteDeltaCoords(t *testing.T, withLinearImport bool) {
|
||||||
cache_dir, _ := ioutil.TempDir("", "goposm_test")
|
cache_dir, _ := ioutil.TempDir("", "goposm_test")
|
||||||
defer os.RemoveAll(cache_dir)
|
defer os.RemoveAll(cache_dir)
|
||||||
|
|
||||||
|
@ -28,6 +36,10 @@ func TestReadWriteDeltaCoords(t *testing.T) {
|
||||||
t.Fatal()
|
t.Fatal()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if withLinearImport {
|
||||||
|
cache.SetLinearImport(true)
|
||||||
|
}
|
||||||
|
|
||||||
// create list with nodes from Id 0->999 in random order
|
// create list with nodes from Id 0->999 in random order
|
||||||
nodeIds := rand.Perm(1000)
|
nodeIds := rand.Perm(1000)
|
||||||
nodes := make([]element.Node, 1000)
|
nodes := make([]element.Node, 1000)
|
||||||
|
@ -42,11 +54,8 @@ func TestReadWriteDeltaCoords(t *testing.T) {
|
||||||
cache.PutCoords(nodes[i : i+10])
|
cache.PutCoords(nodes[i : i+10])
|
||||||
}
|
}
|
||||||
|
|
||||||
cache.Close()
|
if withLinearImport {
|
||||||
|
cache.SetLinearImport(false)
|
||||||
cache, err = newDeltaCoordsCache(cache_dir)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
for i := 0; i < len(nodes); i++ {
|
for i := 0; i < len(nodes); i++ {
|
||||||
|
@ -68,12 +77,6 @@ func TestReadWriteDeltaCoords(t *testing.T) {
|
||||||
|
|
||||||
// test delete
|
// test delete
|
||||||
cache.PutCoords([]element.Node{mknode(999999)})
|
cache.PutCoords([]element.Node{mknode(999999)})
|
||||||
cache.Close()
|
|
||||||
|
|
||||||
cache, err = newDeltaCoordsCache(cache_dir)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
_, err = cache.GetCoord(999999)
|
_, err = cache.GetCoord(999999)
|
||||||
if err == NotFound {
|
if err == NotFound {
|
||||||
|
@ -83,17 +86,4 @@ func TestReadWriteDeltaCoords(t *testing.T) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
cache.Close()
|
|
||||||
|
|
||||||
cache, err = newDeltaCoordsCache(cache_dir)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
defer cache.Close()
|
|
||||||
|
|
||||||
_, err = cache.GetCoord(999999)
|
|
||||||
if err != NotFound {
|
|
||||||
t.Fatal("deleted node returned not NotFound")
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue