diff options
| author | obscuren <geffobscura@gmail.com> | 2014-10-02 23:03:15 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-10-02 23:03:15 +0800 |
| commit | 82be3054961864dfd5bbeaec2ab961f593203dbf (patch) | |
| tree | efde516d8219f253f2bc87f26ad6d4169c2dc587 /ethchain/state_manager.go | |
| parent | a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8 (diff) | |
| download | dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar.gz dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar.bz2 dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar.lz dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar.xz dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.tar.zst dexon-82be3054961864dfd5bbeaec2ab961f593203dbf.zip | |
Fixed inconsistencies
Diffstat (limited to 'ethchain/state_manager.go')
| -rw-r--r-- | ethchain/state_manager.go | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/ethchain/state_manager.go b/ethchain/state_manager.go index f38666572..93fd1ec58 100644 --- a/ethchain/state_manager.go +++ b/ethchain/state_manager.go @@ -104,18 +104,21 @@ func (self *StateManager) Stop() { } func (self *StateManager) updateThread() { - blockChan := self.eth.Eventer().Register("block") + blockChan := self.eth.Eventer().Register("blocks") out: for { select { case event := <-blockChan: - block := event.Data.(*Block) - err := self.Process(block, false) - if err != nil { - statelogger.Infoln(err) - statelogger.Debugf("Block #%v failed (%x...)\n", block.Number, block.Hash()[0:4]) - statelogger.Debugln(block) + blocks := event.Data.(Blocks) + for _, block := range blocks { + err := self.Process(block, false) + if err != nil { + statelogger.Infoln(err) + statelogger.Debugf("Block #%v failed (%x...)\n", block.Number, block.Hash()[0:4]) + statelogger.Debugln(block) + break + } } case <-self.quit: |