aboutsummaryrefslogtreecommitdiffstats
path: root/ethchain
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-07-21 18:21:42 +0800
committerobscuren <geffobscura@gmail.com>2014-07-21 18:21:42 +0800
commit8f91d47bf3c26b850f0f40f79856141087e6ef82 (patch)
tree95e14a764593dee08eabc0d6cff6285c9e695542 /ethchain
parent93261b98c2bc664af30676129def291ff9e8a9ce (diff)
parent5d2669dbd35b9449cbbb249dcec89e2a64c90f30 (diff)
downloaddexon-8f91d47bf3c26b850f0f40f79856141087e6ef82.tar.gz
dexon-8f91d47bf3c26b850f0f40f79856141087e6ef82.tar.zst
dexon-8f91d47bf3c26b850f0f40f79856141087e6ef82.zip
Merge branch 'master' into develop
Diffstat (limited to 'ethchain')
-rw-r--r--ethchain/block.go33
-rw-r--r--ethchain/state_manager.go17
2 files changed, 34 insertions, 16 deletions
diff --git a/ethchain/block.go b/ethchain/block.go
index a0f9ecd86..447d55f99 100644
--- a/ethchain/block.go
+++ b/ethchain/block.go
@@ -7,7 +7,7 @@ import (
"github.com/ethereum/eth-go/ethtrie"
"github.com/ethereum/eth-go/ethutil"
"math/big"
- "strconv"
+ _ "strconv"
"time"
)
@@ -252,20 +252,43 @@ func (self *Block) SetReceipts(receipts []*Receipt, txs []*Transaction) {
func (block *Block) setTransactions(txs []*Transaction) {
block.transactions = txs
+ /*
+ trie := ethtrie.NewTrie(ethutil.Config.Db, "")
+ for i, tx := range txs {
+ trie.Update(strconv.Itoa(i), string(tx.RlpEncode()))
+ }
+
+ switch trie.Root.(type) {
+ case string:
+ block.TxSha = []byte(trie.Root.(string))
+ case []byte:
+ block.TxSha = trie.Root.([]byte)
+ default:
+ panic(fmt.Sprintf("invalid root type %T", trie.Root))
+ }
+ */
+}
+
+func CreateTxSha(receipts Receipts) (sha []byte) {
trie := ethtrie.NewTrie(ethutil.Config.Db, "")
- for i, tx := range txs {
- trie.Update(strconv.Itoa(i), string(tx.RlpEncode()))
+ for i, receipt := range receipts {
+ trie.Update(string(ethutil.NewValue(i).Encode()), string(ethutil.NewValue(receipt.RlpData()).Encode()))
}
switch trie.Root.(type) {
case string:
- block.TxSha = []byte(trie.Root.(string))
+ sha = []byte(trie.Root.(string))
case []byte:
- block.TxSha = trie.Root.([]byte)
+ sha = trie.Root.([]byte)
default:
panic(fmt.Sprintf("invalid root type %T", trie.Root))
}
+ return sha
+}
+
+func (self *Block) SetTxHash(receipts Receipts) {
+ self.TxSha = CreateTxSha(receipts)
}
func (block *Block) Value() *ethutil.Value {
diff --git a/ethchain/state_manager.go b/ethchain/state_manager.go
index f28f45eab..6a6c67492 100644
--- a/ethchain/state_manager.go
+++ b/ethchain/state_manager.go
@@ -201,11 +201,16 @@ func (sm *StateManager) Process(block *Block, dontReact bool) (err error) {
fmt.Printf("## %x %x ##\n", block.Hash(), block.Number)
}
- _, err = sm.ApplyDiff(state, parent, block)
+ receipts, err := sm.ApplyDiff(state, parent, block)
if err != nil {
return err
}
+ txSha := CreateTxSha(receipts)
+ if bytes.Compare(txSha, block.TxSha) != 0 {
+ return fmt.Errorf("Error validating tx sha. Received %x, got %x", block.TxSha, txSha)
+ }
+
// Block validation
if err = sm.ValidateBlock(block); err != nil {
statelogger.Errorln("Error validating block:", err)
@@ -219,17 +224,7 @@ func (sm *StateManager) Process(block *Block, dontReact bool) (err error) {
return err
}
- /*
- if ethutil.Config.Paranoia {
- valid, _ := ethtrie.ParanoiaCheck(state.trie)
- if !valid {
- err = fmt.Errorf("PARANOIA: World state trie corruption")
- }
- }
- */
-
if !block.State().Cmp(state) {
-
err = fmt.Errorf("Invalid merkle root.\nrec: %x\nis: %x", block.State().trie.Root, state.trie.Root)
return
}