plugeth/core/chain_manager_test.go

139 lines
3.0 KiB
Go
Raw Normal View History

2014-12-04 09:28:02 +00:00
package core
2014-12-17 11:57:35 +00:00
import (
"fmt"
2014-12-30 12:32:01 +00:00
"os"
2014-12-17 11:57:35 +00:00
"path"
2014-12-30 12:32:01 +00:00
"reflect"
"runtime"
2014-12-30 14:42:26 +00:00
"strconv"
2014-12-17 11:57:35 +00:00
"testing"
"github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/ethdb"
2014-12-17 11:57:35 +00:00
"github.com/ethereum/go-ethereum/ethutil"
"github.com/ethereum/go-ethereum/event"
2014-12-30 12:32:01 +00:00
"github.com/ethereum/go-ethereum/rlp"
2014-12-17 11:57:35 +00:00
)
func init() {
runtime.GOMAXPROCS(runtime.NumCPU())
ethutil.ReadConfig("/tmp/ethtest", "/tmp/ethtest", "ETH")
2015-01-02 10:16:30 +00:00
}
func reset() {
db, err := ethdb.NewMemDatabase()
if err != nil {
panic("Could not create mem-db, failing")
}
ethutil.Config.Db = db
}
2014-12-30 12:32:01 +00:00
func loadChain(fn string, t *testing.T) (types.Blocks, error) {
2015-01-02 12:00:25 +00:00
fh, err := os.OpenFile(path.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum", "_data", fn), os.O_RDONLY, os.ModePerm)
2014-12-17 11:57:35 +00:00
if err != nil {
2014-12-30 12:32:01 +00:00
return nil, err
2014-12-17 11:57:35 +00:00
}
2014-12-30 12:32:01 +00:00
defer fh.Close()
var chain types.Blocks
if err := rlp.Decode(fh, &chain); err != nil {
return nil, err
}
2014-12-30 12:32:01 +00:00
return chain, nil
}
func insertChain(done chan bool, chainMan *ChainManager, chain types.Blocks, t *testing.T) {
err := chainMan.InsertChain(chain)
if err != nil {
fmt.Println(err)
t.FailNow()
}
2015-01-02 10:16:30 +00:00
done <- true
}
func TestChainInsertions(t *testing.T) {
2015-01-02 10:16:30 +00:00
reset()
2014-12-30 14:42:26 +00:00
chain1, err := loadChain("valid1", t)
2014-12-30 12:32:01 +00:00
if err != nil {
fmt.Println(err)
t.FailNow()
}
2014-12-30 14:42:26 +00:00
chain2, err := loadChain("valid2", t)
2014-12-30 12:32:01 +00:00
if err != nil {
fmt.Println(err)
t.FailNow()
}
var eventMux event.TypeMux
chainMan := NewChainManager(&eventMux)
txPool := NewTxPool(&eventMux)
blockMan := NewBlockManager(txPool, chainMan, &eventMux)
chainMan.SetProcessor(blockMan)
const max = 2
done := make(chan bool, max)
go insertChain(done, chainMan, chain1, t)
go insertChain(done, chainMan, chain2, t)
for i := 0; i < max; i++ {
<-done
}
2014-12-30 12:32:01 +00:00
if reflect.DeepEqual(chain2[len(chain2)-1], chainMan.CurrentBlock()) {
t.Error("chain2 is canonical and shouldn't be")
}
if !reflect.DeepEqual(chain1[len(chain1)-1], chainMan.CurrentBlock()) {
t.Error("chain1 isn't canonical and should be")
}
2014-12-17 11:57:35 +00:00
}
2014-12-30 14:42:26 +00:00
func TestChainMultipleInsertions(t *testing.T) {
2015-01-02 10:16:30 +00:00
reset()
2014-12-30 14:42:26 +00:00
const max = 4
chains := make([]types.Blocks, max)
var longest int
for i := 0; i < max; i++ {
var err error
name := "valid" + strconv.Itoa(i+1)
chains[i], err = loadChain(name, t)
if len(chains[i]) >= len(chains[longest]) {
longest = i
}
fmt.Println("loaded", name, "with a length of", len(chains[i]))
if err != nil {
fmt.Println(err)
t.FailNow()
}
}
var eventMux event.TypeMux
chainMan := NewChainManager(&eventMux)
txPool := NewTxPool(&eventMux)
2014-12-30 14:42:26 +00:00
blockMan := NewBlockManager(txPool, chainMan, &eventMux)
chainMan.SetProcessor(blockMan)
done := make(chan bool, max)
for i, chain := range chains {
2015-01-02 10:16:30 +00:00
// XXX the go routine would otherwise reference the same (chain[3]) variable and fail
i := i
chain := chain
2014-12-30 14:42:26 +00:00
go func() {
insertChain(done, chainMan, chain, t)
fmt.Println(i, "done")
}()
}
for i := 0; i < max; i++ {
<-done
}
if !reflect.DeepEqual(chains[longest][len(chains[longest])-1], chainMan.CurrentBlock()) {
t.Error("Invalid canonical chain")
}
}