From 8df689bd448390c44ee2c344314257a5987a2e97 Mon Sep 17 00:00:00 2001
From: obscuren <geffobscura@gmail.com>
Date: Tue, 30 Dec 2014 15:42:26 +0100
Subject: Chain tests

---
 _data/chain1               | Bin 18036 -> 0 bytes
 _data/chain2               | Bin 6125 -> 0 bytes
 _data/invalid1             | Bin 0 -> 36072 bytes
 _data/valid1               | Bin 0 -> 18036 bytes
 _data/valid2               | Bin 0 -> 6125 bytes
 _data/valid3               | Bin 0 -> 14712 bytes
 _data/valid4               | Bin 0 -> 12496 bytes
 core/chain_manager_test.go |  53 ++++++++++++++++++++++++++++++++++++++++-----
 8 files changed, 48 insertions(+), 5 deletions(-)
 delete mode 100755 _data/chain1
 delete mode 100755 _data/chain2
 create mode 100755 _data/invalid1
 create mode 100755 _data/valid1
 create mode 100755 _data/valid2
 create mode 100755 _data/valid3
 create mode 100755 _data/valid4

diff --git a/_data/chain1 b/_data/chain1
deleted file mode 100755
index 809a55f1a..000000000
Binary files a/_data/chain1 and /dev/null differ
diff --git a/_data/chain2 b/_data/chain2
deleted file mode 100755
index 3e9d2971a..000000000
Binary files a/_data/chain2 and /dev/null differ
diff --git a/_data/invalid1 b/_data/invalid1
new file mode 100755
index 000000000..9c24b13e8
Binary files /dev/null and b/_data/invalid1 differ
diff --git a/_data/valid1 b/_data/valid1
new file mode 100755
index 000000000..809a55f1a
Binary files /dev/null and b/_data/valid1 differ
diff --git a/_data/valid2 b/_data/valid2
new file mode 100755
index 000000000..3e9d2971a
Binary files /dev/null and b/_data/valid2 differ
diff --git a/_data/valid3 b/_data/valid3
new file mode 100755
index 000000000..685bc9fd7
Binary files /dev/null and b/_data/valid3 differ
diff --git a/_data/valid4 b/_data/valid4
new file mode 100755
index 000000000..fc016057f
Binary files /dev/null and b/_data/valid4 differ
diff --git a/core/chain_manager_test.go b/core/chain_manager_test.go
index 6e85bae9a..108718901 100644
--- a/core/chain_manager_test.go
+++ b/core/chain_manager_test.go
@@ -6,6 +6,7 @@ import (
 	"path"
 	"reflect"
 	"runtime"
+	"strconv"
 	"testing"
 
 	"github.com/ethereum/go-ethereum/core/types"
@@ -13,15 +14,15 @@ import (
 	"github.com/ethereum/go-ethereum/ethutil"
 	"github.com/ethereum/go-ethereum/event"
 	"github.com/ethereum/go-ethereum/rlp"
-	//logpkg "github.com/ethereum/go-ethereum/logger"
 )
 
 //var Logger logpkg.LogSystem
+
 //var Log = logpkg.NewLogger("TEST")
 
 func init() {
 	runtime.GOMAXPROCS(runtime.NumCPU())
-	//Logger = logpkg.NewStdLogSystem(os.Stdout, log.LstdFlags, logpkg.InfoLevel)
+	//Logger = logpkg.NewStdLogSystem(os.Stdout, log.LstdFlags, logpkg.DebugLevel)
 	//logpkg.AddLogSystem(Logger)
 
 	ethutil.ReadConfig("/tmp/ethtest", "/tmp/ethtest", "ETH")
@@ -50,21 +51,22 @@ func loadChain(fn string, t *testing.T) (types.Blocks, error) {
 
 func insertChain(done chan bool, chainMan *ChainManager, chain types.Blocks, t *testing.T) {
 	err := chainMan.InsertChain(chain)
+	done <- true
 	if err != nil {
 		fmt.Println(err)
 		t.FailNow()
 	}
-	done <- true
 }
 
 func TestChainInsertions(t *testing.T) {
-	chain1, err := loadChain("chain1", t)
+	chain1, err := loadChain("valid1", t)
 	if err != nil {
 		fmt.Println(err)
 		t.FailNow()
 	}
+	fmt.Println(len(chain1))
 
-	chain2, err := loadChain("chain2", t)
+	chain2, err := loadChain("valid2", t)
 	if err != nil {
 		fmt.Println(err)
 		t.FailNow()
@@ -94,3 +96,44 @@ func TestChainInsertions(t *testing.T) {
 		t.Error("chain1 isn't canonical and should be")
 	}
 }
+
+func TestChainMultipleInsertions(t *testing.T) {
+	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(chainMan, &eventMux)
+	blockMan := NewBlockManager(txPool, chainMan, &eventMux)
+	chainMan.SetProcessor(blockMan)
+	done := make(chan bool, max)
+	for i, chain := range chains {
+		var i int = i
+		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")
+	}
+}
-- 
cgit