plugeth/trie/trie_test.go

584 lines
14 KiB
Go
Raw Normal View History

2015-07-07 00:54:22 +00:00
// Copyright 2014 The go-ethereum Authors
// This file is part of the go-ethereum library.
2015-07-07 00:54:22 +00:00
//
// The go-ethereum library is free software: you can redistribute it and/or modify
2015-07-07 00:54:22 +00:00
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// The go-ethereum library is distributed in the hope that it will be useful,
2015-07-07 00:54:22 +00:00
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
2015-07-07 00:54:22 +00:00
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
2015-07-07 00:54:22 +00:00
2014-10-31 13:45:03 +00:00
package trie
2014-02-14 22:56:09 +00:00
import (
2014-11-18 18:52:45 +00:00
"bytes"
2015-06-30 12:54:37 +00:00
"encoding/binary"
2014-05-25 22:09:38 +00:00
"fmt"
2015-06-30 12:54:37 +00:00
"io/ioutil"
"math/rand"
2015-06-30 12:54:37 +00:00
"os"
"reflect"
2014-11-18 18:52:45 +00:00
"testing"
"testing/quick"
2014-11-16 02:21:55 +00:00
2015-07-05 23:19:48 +00:00
"github.com/davecgh/go-spew/spew"
2015-03-16 10:27:38 +00:00
"github.com/ethereum/go-ethereum/common"
2015-06-30 12:54:37 +00:00
"github.com/ethereum/go-ethereum/ethdb"
2014-02-14 22:56:09 +00:00
)
2015-07-05 23:19:48 +00:00
func init() {
spew.Config.Indent = " "
spew.Config.DisableMethods = true
2014-02-15 12:21:11 +00:00
}
2015-07-05 23:19:48 +00:00
// Used for testing
func newEmpty() *Trie {
db, _ := ethdb.NewMemDatabase()
trie, _ := New(common.Hash{}, db)
return trie
2015-03-03 11:15:58 +00:00
}
2015-01-08 10:47:04 +00:00
func TestEmptyTrie(t *testing.T) {
2015-07-05 23:19:48 +00:00
var trie Trie
2015-01-08 10:47:04 +00:00
res := trie.Hash()
2015-07-05 23:19:48 +00:00
exp := emptyRoot
if res != common.Hash(exp) {
2015-01-08 10:47:04 +00:00
t.Errorf("expected %x got %x", exp, res)
}
2014-02-15 12:21:11 +00:00
}
2015-03-19 09:57:02 +00:00
func TestNull(t *testing.T) {
2015-07-05 23:19:48 +00:00
var trie Trie
2015-03-19 09:57:02 +00:00
key := make([]byte, 32)
value := []byte("test")
2015-03-19 09:57:02 +00:00
trie.Update(key, value)
if !bytes.Equal(trie.Get(key), value) {
t.Fatal("wrong value")
}
2015-03-19 09:57:02 +00:00
}
2015-07-05 23:19:48 +00:00
func TestMissingRoot(t *testing.T) {
db, _ := ethdb.NewMemDatabase()
trie, err := New(common.HexToHash("0beec7b5ea3f0fdbc95d0dd47f3c5bc275da8a33"), db)
if trie != nil {
t.Error("New returned non-nil trie for invalid root")
}
if _, ok := err.(*MissingNodeError); !ok {
2016-04-15 09:06:57 +00:00
t.Errorf("New returned wrong error: %v", err)
2015-07-05 23:19:48 +00:00
}
}
func TestMissingNode(t *testing.T) {
db, _ := ethdb.NewMemDatabase()
trie, _ := New(common.Hash{}, db)
updateString(trie, "120000", "qwerqwerqwerqwerqwerqwerqwerqwer")
updateString(trie, "123456", "asdfasdfasdfasdfasdfasdfasdfasdf")
root, _ := trie.Commit()
trie, _ = New(root, db)
_, err := trie.TryGet([]byte("120000"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
trie, _ = New(root, db)
_, err = trie.TryGet([]byte("120099"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
trie, _ = New(root, db)
_, err = trie.TryGet([]byte("123456"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
trie, _ = New(root, db)
err = trie.TryUpdate([]byte("120099"), []byte("zxcvzxcvzxcvzxcvzxcvzxcvzxcvzxcv"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
trie, _ = New(root, db)
err = trie.TryDelete([]byte("123456"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
db.Delete(common.FromHex("e1d943cc8f061a0c0b98162830b970395ac9315654824bf21b73b891365262f9"))
trie, _ = New(root, db)
_, err = trie.TryGet([]byte("120000"))
if _, ok := err.(*MissingNodeError); !ok {
t.Errorf("Wrong error: %v", err)
}
trie, _ = New(root, db)
_, err = trie.TryGet([]byte("120099"))
if _, ok := err.(*MissingNodeError); !ok {
t.Errorf("Wrong error: %v", err)
}
trie, _ = New(root, db)
_, err = trie.TryGet([]byte("123456"))
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
trie, _ = New(root, db)
err = trie.TryUpdate([]byte("120099"), []byte("zxcv"))
if _, ok := err.(*MissingNodeError); !ok {
t.Errorf("Wrong error: %v", err)
}
trie, _ = New(root, db)
err = trie.TryDelete([]byte("123456"))
if _, ok := err.(*MissingNodeError); !ok {
t.Errorf("Wrong error: %v", err)
}
}
2015-01-08 10:47:04 +00:00
func TestInsert(t *testing.T) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2014-02-15 12:21:11 +00:00
2015-07-05 23:19:48 +00:00
updateString(trie, "doe", "reindeer")
updateString(trie, "dog", "puppy")
updateString(trie, "dogglesworth", "cat")
2014-02-15 12:21:11 +00:00
2015-07-05 23:19:48 +00:00
exp := common.HexToHash("8aad789dff2f538bca5d8ea56e8abe10f4c7ba3a5dea95fea4cd6e7c3a1168d3")
2015-01-08 10:47:04 +00:00
root := trie.Hash()
2015-07-05 23:19:48 +00:00
if root != exp {
2015-01-08 10:47:04 +00:00
t.Errorf("exp %x got %x", exp, root)
}
2014-02-20 13:40:00 +00:00
2015-07-05 23:19:48 +00:00
trie = newEmpty()
updateString(trie, "A", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa")
2014-02-20 13:40:00 +00:00
2015-07-05 23:19:48 +00:00
exp = common.HexToHash("d23786fb4a010da3ce639d66d5e904a11dbc02746d1ce25029e53290cabf28ab")
root, err := trie.Commit()
if err != nil {
t.Fatalf("commit error: %v", err)
}
if root != exp {
2015-01-08 10:47:04 +00:00
t.Errorf("exp %x got %x", exp, root)
}
2014-02-20 13:40:00 +00:00
}
2014-02-24 11:11:00 +00:00
2015-01-08 10:47:04 +00:00
func TestGet(t *testing.T) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
updateString(trie, "doe", "reindeer")
updateString(trie, "dog", "puppy")
updateString(trie, "dogglesworth", "cat")
for i := 0; i < 2; i++ {
res := getString(trie, "dog")
if !bytes.Equal(res, []byte("puppy")) {
t.Errorf("expected puppy got %x", res)
}
2014-05-25 22:09:38 +00:00
2015-07-05 23:19:48 +00:00
unknown := getString(trie, "unknown")
if unknown != nil {
t.Errorf("expected nil got %x", unknown)
}
2014-06-30 11:08:00 +00:00
2015-07-05 23:19:48 +00:00
if i == 1 {
return
}
trie.Commit()
}
2014-06-30 11:08:00 +00:00
}
2015-01-08 10:47:04 +00:00
func TestDelete(t *testing.T) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2015-01-08 10:47:04 +00:00
vals := []struct{ k, v string }{
{"do", "verb"},
{"ether", "wookiedoo"},
{"horse", "stallion"},
{"shaman", "horse"},
{"doge", "coin"},
{"ether", ""},
{"dog", "puppy"},
{"shaman", ""},
}
2015-01-08 10:47:04 +00:00
for _, val := range vals {
if val.v != "" {
2015-07-05 23:19:48 +00:00
updateString(trie, val.k, val.v)
2015-01-08 10:47:04 +00:00
} else {
2015-07-05 23:19:48 +00:00
deleteString(trie, val.k)
2015-01-08 10:47:04 +00:00
}
2014-06-30 11:08:00 +00:00
}
2015-01-08 10:47:04 +00:00
hash := trie.Hash()
2015-07-05 23:19:48 +00:00
exp := common.HexToHash("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84")
if hash != exp {
2015-01-08 10:47:04 +00:00
t.Errorf("expected %x got %x", exp, hash)
2014-06-30 11:08:00 +00:00
}
2015-01-08 10:47:04 +00:00
}
2014-05-26 23:08:51 +00:00
2015-01-08 10:47:04 +00:00
func TestEmptyValues(t *testing.T) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2014-06-30 11:08:00 +00:00
2015-01-08 10:47:04 +00:00
vals := []struct{ k, v string }{
{"do", "verb"},
{"ether", "wookiedoo"},
{"horse", "stallion"},
{"shaman", "horse"},
{"doge", "coin"},
{"ether", ""},
{"dog", "puppy"},
{"shaman", ""},
2014-06-30 11:08:00 +00:00
}
2015-01-08 10:47:04 +00:00
for _, val := range vals {
2015-07-05 23:19:48 +00:00
updateString(trie, val.k, val.v)
2014-07-01 07:55:20 +00:00
}
2015-01-08 10:47:04 +00:00
hash := trie.Hash()
2015-07-05 23:19:48 +00:00
exp := common.HexToHash("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84")
if hash != exp {
2015-01-08 10:47:04 +00:00
t.Errorf("expected %x got %x", exp, hash)
}
2014-07-01 07:55:20 +00:00
}
2015-01-08 10:47:04 +00:00
func TestReplication(t *testing.T) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2015-01-08 10:47:04 +00:00
vals := []struct{ k, v string }{
{"do", "verb"},
{"ether", "wookiedoo"},
{"horse", "stallion"},
{"shaman", "horse"},
{"doge", "coin"},
{"dog", "puppy"},
{"somethingveryoddindeedthis is", "myothernodedata"},
}
2015-01-08 10:47:04 +00:00
for _, val := range vals {
2015-07-05 23:19:48 +00:00
updateString(trie, val.k, val.v)
2015-01-08 10:47:04 +00:00
}
2015-07-05 23:19:48 +00:00
exp, err := trie.Commit()
if err != nil {
t.Fatalf("commit error: %v", err)
2015-01-08 10:47:04 +00:00
}
2015-07-05 23:19:48 +00:00
// create a new trie on top of the database and check that lookups work.
trie2, err := New(exp, trie.db)
if err != nil {
t.Fatalf("can't recreate trie at %x: %v", exp, err)
}
for _, kv := range vals {
if string(getString(trie2, kv.k)) != kv.v {
t.Errorf("trie2 doesn't have %q => %q", kv.k, kv.v)
}
}
hash, err := trie2.Commit()
if err != nil {
t.Fatalf("commit error: %v", err)
}
if hash != exp {
2015-01-08 10:47:04 +00:00
t.Errorf("root failure. expected %x got %x", exp, hash)
}
2014-07-17 09:21:18 +00:00
2015-07-05 23:19:48 +00:00
// perform some insertions on the new trie.
vals2 := []struct{ k, v string }{
2015-01-08 10:47:04 +00:00
{"do", "verb"},
{"ether", "wookiedoo"},
{"horse", "stallion"},
2015-07-05 23:19:48 +00:00
// {"shaman", "horse"},
// {"doge", "coin"},
// {"ether", ""},
// {"dog", "puppy"},
// {"somethingveryoddindeedthis is", "myothernodedata"},
// {"shaman", ""},
}
2015-07-05 23:19:48 +00:00
for _, val := range vals2 {
updateString(trie2, val.k, val.v)
}
if hash := trie2.Hash(); hash != exp {
2015-07-05 23:19:48 +00:00
t.Errorf("root failure. expected %x got %x", exp, hash)
}
}
2015-07-05 23:19:48 +00:00
func TestLargeValue(t *testing.T) {
trie := newEmpty()
trie.Update([]byte("key1"), []byte{99, 99, 99, 99})
trie.Update([]byte("key2"), bytes.Repeat([]byte{1}, 32))
trie.Hash()
}
type countingDB struct {
Database
gets map[string]int
}
func (db *countingDB) Get(key []byte) ([]byte, error) {
db.gets[string(key)]++
return db.Database.Get(key)
}
// TestCacheUnload checks that decoded nodes are unloaded after a
// certain number of commit operations.
func TestCacheUnload(t *testing.T) {
// Create test trie with two branches.
trie := newEmpty()
key1 := "---------------------------------"
key2 := "---some other branch"
updateString(trie, key1, "this is the branch of key1.")
updateString(trie, key2, "this is the branch of key2.")
root, _ := trie.Commit()
// Commit the trie repeatedly and access key1.
// The branch containing it is loaded from DB exactly two times:
// in the 0th and 6th iteration.
db := &countingDB{Database: trie.db, gets: make(map[string]int)}
trie, _ = New(root, db)
trie.SetCacheLimit(5)
for i := 0; i < 12; i++ {
getString(trie, key1)
trie.Commit()
}
// Check that it got loaded two times.
for dbkey, count := range db.gets {
if count != 2 {
t.Errorf("db key %x loaded %d times, want %d times", []byte(dbkey), count, 2)
}
}
}
// randTest performs random trie operations.
// Instances of this test are created by Generate.
type randTest []randTestStep
type randTestStep struct {
op int
key []byte // for opUpdate, opDelete, opGet
value []byte // for opUpdate
}
const (
opUpdate = iota
opDelete
opGet
opCommit
opHash
opReset
opItercheckhash
opCheckCacheInvariant
opMax // boundary value, not an actual op
)
func (randTest) Generate(r *rand.Rand, size int) reflect.Value {
var allKeys [][]byte
genKey := func() []byte {
if len(allKeys) < 2 || r.Intn(100) < 10 {
// new key
key := make([]byte, r.Intn(50))
r.Read(key)
allKeys = append(allKeys, key)
return key
}
// use existing key
return allKeys[r.Intn(len(allKeys))]
}
var steps randTest
for i := 0; i < size; i++ {
step := randTestStep{op: r.Intn(opMax)}
switch step.op {
case opUpdate:
step.key = genKey()
step.value = make([]byte, 8)
binary.BigEndian.PutUint64(step.value, uint64(i))
case opGet, opDelete:
step.key = genKey()
}
steps = append(steps, step)
}
return reflect.ValueOf(steps)
}
func runRandTest(rt randTest) bool {
db, _ := ethdb.NewMemDatabase()
tr, _ := New(common.Hash{}, db)
values := make(map[string]string) // tracks content of the trie
for _, step := range rt {
switch step.op {
case opUpdate:
tr.Update(step.key, step.value)
values[string(step.key)] = string(step.value)
case opDelete:
tr.Delete(step.key)
delete(values, string(step.key))
case opGet:
v := tr.Get(step.key)
want := values[string(step.key)]
if string(v) != want {
fmt.Printf("mismatch for key 0x%x, got 0x%x want 0x%x", step.key, v, want)
return false
}
case opCommit:
if _, err := tr.Commit(); err != nil {
panic(err)
}
case opHash:
tr.Hash()
case opReset:
hash, err := tr.Commit()
if err != nil {
panic(err)
}
newtr, err := New(hash, db)
if err != nil {
panic(err)
}
tr = newtr
case opItercheckhash:
checktr, _ := New(common.Hash{}, nil)
it := NewIterator(tr.NodeIterator(nil))
for it.Next() {
checktr.Update(it.Key, it.Value)
}
if tr.Hash() != checktr.Hash() {
fmt.Println("hashes not equal")
return false
}
case opCheckCacheInvariant:
return checkCacheInvariant(tr.root, nil, tr.cachegen, false, 0)
}
}
return true
}
func checkCacheInvariant(n, parent node, parentCachegen uint16, parentDirty bool, depth int) bool {
var children []node
var flag nodeFlag
switch n := n.(type) {
case *shortNode:
flag = n.flags
children = []node{n.Val}
case *fullNode:
flag = n.flags
children = n.Children[:]
default:
return true
}
showerror := func() {
fmt.Printf("at depth %d node %s", depth, spew.Sdump(n))
fmt.Printf("parent: %s", spew.Sdump(parent))
}
if flag.gen > parentCachegen {
fmt.Printf("cache invariant violation: %d > %d\n", flag.gen, parentCachegen)
showerror()
return false
}
if depth > 0 && !parentDirty && flag.dirty {
fmt.Printf("cache invariant violation: child is dirty but parent isn't\n")
showerror()
return false
}
for _, child := range children {
if !checkCacheInvariant(child, n, flag.gen, flag.dirty, depth+1) {
return false
}
}
return true
}
func TestRandom(t *testing.T) {
if err := quick.Check(runRandTest, nil); err != nil {
t.Fatal(err)
}
2015-07-05 23:19:48 +00:00
}
2015-06-30 12:54:37 +00:00
func BenchmarkGet(b *testing.B) { benchGet(b, false) }
func BenchmarkGetDB(b *testing.B) { benchGet(b, true) }
func BenchmarkUpdateBE(b *testing.B) { benchUpdate(b, binary.BigEndian) }
func BenchmarkUpdateLE(b *testing.B) { benchUpdate(b, binary.LittleEndian) }
func BenchmarkHashBE(b *testing.B) { benchHash(b, binary.BigEndian) }
func BenchmarkHashLE(b *testing.B) { benchHash(b, binary.LittleEndian) }
const benchElemCount = 20000
func benchGet(b *testing.B, commit bool) {
2015-07-05 23:19:48 +00:00
trie := new(Trie)
2015-06-30 12:54:37 +00:00
if commit {
_, tmpdb := tempDB()
2015-07-05 23:19:48 +00:00
trie, _ = New(common.Hash{}, tmpdb)
2015-06-30 12:54:37 +00:00
}
k := make([]byte, 32)
for i := 0; i < benchElemCount; i++ {
binary.LittleEndian.PutUint64(k, uint64(i))
trie.Update(k, k)
}
binary.LittleEndian.PutUint64(k, benchElemCount/2)
if commit {
trie.Commit()
}
b.ResetTimer()
for i := 0; i < b.N; i++ {
trie.Get(k)
}
b.StopTimer()
if commit {
ldb := trie.db.(*ethdb.LDBDatabase)
ldb.Close()
os.RemoveAll(ldb.Path())
}
2015-06-30 12:54:37 +00:00
}
func benchUpdate(b *testing.B, e binary.ByteOrder) *Trie {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2015-06-30 12:54:37 +00:00
k := make([]byte, 32)
for i := 0; i < b.N; i++ {
e.PutUint64(k, uint64(i))
trie.Update(k, k)
}
return trie
}
func benchHash(b *testing.B, e binary.ByteOrder) {
2015-07-05 23:19:48 +00:00
trie := newEmpty()
2015-06-30 12:54:37 +00:00
k := make([]byte, 32)
for i := 0; i < benchElemCount; i++ {
e.PutUint64(k, uint64(i))
trie.Update(k, k)
}
b.ResetTimer()
for i := 0; i < b.N; i++ {
trie.Hash()
}
}
2015-07-05 23:19:48 +00:00
func tempDB() (string, Database) {
2015-06-30 12:54:37 +00:00
dir, err := ioutil.TempDir("", "trie-bench")
if err != nil {
panic(fmt.Sprintf("can't create temporary directory: %v", err))
}
db, err := ethdb.NewLDBDatabase(dir, 256, 0)
2015-06-30 12:54:37 +00:00
if err != nil {
panic(fmt.Sprintf("can't create temporary database: %v", err))
}
return dir, db
}
2015-07-05 23:19:48 +00:00
func getString(trie *Trie, k string) []byte {
return trie.Get([]byte(k))
}
func updateString(trie *Trie, k, v string) {
trie.Update([]byte(k), []byte(v))
}
func deleteString(trie *Trie, k string) {
trie.Delete([]byte(k))
}