cerc-io/go-ethereum
18
0
Fork 0
Code Issues 9 Pull Requests Packages Projects Releases 66 Wiki Activity

Write state diff to CSV #2

Merged
elizabethengelman merged 47 commits from ee-state-diff into statediff-for-archive-node 2019-01-28 21:31:02 +00:00
Conversation 0 Commits 47 Files Changed 90 +8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit cf4ed9c2b3 - Show all commits

8
statediff/builder.go
View File

@ -49,10 +49,13 @@ func (sdb *builder) BuildStateDiff(oldStateRoot, newStateRoot common.Hash, block
// Generate tries for old and new states // Generate tries for old and new states
oldTrie, err := trie.New(oldStateRoot, sdb.trieDB) oldTrie, err := trie.New(oldStateRoot, sdb.trieDB)
if err != nil { if err != nil {
log.Debug("error creating oldTrie", err)
//getting this error: error creating oldTrie missing trie node ddfbb83966d870891aa47147269447a83564d1defaefad5f9844a3a3a2a08433 (path )
return nil, err return nil, err
} }
newTrie, err := trie.New(newStateRoot, sdb.trieDB) newTrie, err := trie.New(newStateRoot, sdb.trieDB)
if err != nil { if err != nil {
log.Debug("error creating newTrie", err)
return nil, err return nil, err
} }
@ -61,6 +64,7 @@ func (sdb *builder) BuildStateDiff(oldStateRoot, newStateRoot common.Hash, block
newIt := newTrie.NodeIterator([]byte{}) newIt := newTrie.NodeIterator([]byte{})
creations, err := sdb.collectDiffNodes(oldIt, newIt) creations, err := sdb.collectDiffNodes(oldIt, newIt)
if err != nil { if err != nil {
log.Debug("error collecting creation diff nodes", err)
return nil, err return nil, err
} }
@ -69,6 +73,7 @@ func (sdb *builder) BuildStateDiff(oldStateRoot, newStateRoot common.Hash, block
newIt = newTrie.NodeIterator(make([]byte, 0)) newIt = newTrie.NodeIterator(make([]byte, 0))
deletions, err := sdb.collectDiffNodes(newIt, oldIt) deletions, err := sdb.collectDiffNodes(newIt, oldIt)
if err != nil { if err != nil {
log.Debug("error collecting deletion diff nodes", err)
return nil, err return nil, err
} }
@ -80,14 +85,17 @@ func (sdb *builder) BuildStateDiff(oldStateRoot, newStateRoot common.Hash, block
// Build and return the statediff // Build and return the statediff
updatedAccounts, err := sdb.buildDiffIncremental(creations, deletions, updatedKeys) updatedAccounts, err := sdb.buildDiffIncremental(creations, deletions, updatedKeys)
if err != nil { if err != nil {
log.Debug("error building diff incremental for updated", err)
return nil, err return nil, err
} }
createdAccounts, err := sdb.buildDiffEventual(creations, true) createdAccounts, err := sdb.buildDiffEventual(creations, true)
if err != nil { if err != nil {
log.Debug("error building diff incremental for created", err)
return nil, err return nil, err
} }
deletedAccounts, err := sdb.buildDiffEventual(deletions, false) deletedAccounts, err := sdb.buildDiffEventual(deletions, false)
if err != nil { if err != nil {
log.Debug("error building diff incremental for deleted", err)
return nil, err return nil, err
} }