it works
This commit is contained in:
parent
3f1362f838
commit
d98ea3764f
|
@ -138,7 +138,6 @@ func (st *iavlStore) Subspace(prefix []byte) Iterator {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Printf("%v \n", end)
|
|
||||||
return st.Iterator(prefix, end)
|
return st.Iterator(prefix, end)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -242,7 +241,6 @@ func newIAVLIterator(tree *iavl.Tree, start, end []byte, ascending bool) *iavlIt
|
||||||
quitCh: make(chan struct{}),
|
quitCh: make(chan struct{}),
|
||||||
initCh: make(chan struct{}),
|
initCh: make(chan struct{}),
|
||||||
}
|
}
|
||||||
fmt.Printf("%v %v \n", iter.start, iter.end)
|
|
||||||
go iter.iterateRoutine()
|
go iter.iterateRoutine()
|
||||||
go iter.initRoutine()
|
go iter.initRoutine()
|
||||||
return iter
|
return iter
|
||||||
|
@ -356,6 +354,9 @@ func (iter *iavlIterator) assertIsValid() {
|
||||||
//----------------------------------------
|
//----------------------------------------
|
||||||
|
|
||||||
func cp(bz []byte) (ret []byte) {
|
func cp(bz []byte) (ret []byte) {
|
||||||
|
if bz == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
ret = make([]byte, len(bz))
|
ret = make([]byte, len(bz))
|
||||||
copy(ret, bz)
|
copy(ret, bz)
|
||||||
return ret
|
return ret
|
||||||
|
|
|
@ -150,6 +150,10 @@ func TestIAVLSubspace(t *testing.T) {
|
||||||
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(0)}, []byte("test4"))
|
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(0)}, []byte("test4"))
|
||||||
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(1)}, []byte("test4"))
|
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(1)}, []byte("test4"))
|
||||||
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(255)}, []byte("test4"))
|
iavlStore.Set([]byte{byte(55), byte(255), byte(255), byte(255)}, []byte("test4"))
|
||||||
|
iavlStore.Set([]byte{byte(255), byte(255), byte(0)}, []byte("test4"))
|
||||||
|
iavlStore.Set([]byte{byte(255), byte(255), byte(1)}, []byte("test4"))
|
||||||
|
iavlStore.Set([]byte{byte(255), byte(255), byte(255)}, []byte("test4"))
|
||||||
|
|
||||||
i := 0
|
i := 0
|
||||||
|
|
||||||
iter := iavlStore.Subspace([]byte("test"))
|
iter := iavlStore.Subspace([]byte("test"))
|
||||||
|
|
Loading…
Reference in New Issue