diff options
| author | obscuren <geffobscura@gmail.com> | 2014-10-29 21:20:42 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-10-29 21:20:42 +0800 |
| commit | 9e2f071d26d5c4ed343d2a91e48fec4e7751b99d (patch) | |
| tree | fdfde82ceb0c6736b82c08c7002055ee95cfef67 /ethchain/state_manager.go | |
| parent | fb4113dab4df8480c77bdcb707fa6b5408755b79 (diff) | |
| download | dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar.gz dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar.bz2 dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar.lz dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar.xz dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.tar.zst dexon-9e2f071d26d5c4ed343d2a91e48fec4e7751b99d.zip | |
Removed events from the state manager
Diffstat (limited to 'ethchain/state_manager.go')
| -rw-r--r-- | ethchain/state_manager.go | 15 |
1 files changed, 3 insertions, 12 deletions
diff --git a/ethchain/state_manager.go b/ethchain/state_manager.go index 774933e48..e45d44752 100644 --- a/ethchain/state_manager.go +++ b/ethchain/state_manager.go @@ -101,7 +101,7 @@ func (self *StateManager) Stop() { func (self *StateManager) updateThread() { for ev := range self.events.Chan() { for _, block := range ev.(Blocks) { - err := self.Process(block, false) + err := self.Process(block) if err != nil { statelogger.Infoln(err) statelogger.Debugf("Block #%v failed (%x...)\n", block.Number, block.Hash()[0:4]) @@ -206,7 +206,7 @@ done: return receipts, handled, unhandled, erroneous, err } -func (sm *StateManager) Process(block *Block, dontReact bool) (err error) { +func (sm *StateManager) Process(block *Block) (err error) { // Processing a blocks may never happen simultaneously sm.mutex.Lock() defer sm.mutex.Unlock() @@ -281,18 +281,9 @@ func (sm *StateManager) Process(block *Block, dontReact bool) (err error) { sm.transState = state.Copy() - // Create a bloom bin for this block - //filter := sm.createBloomFilter(state) - // Persist the data - //fk := append([]byte("bloom"), block.Hash()...) - //sm.eth.Db().Put(fk, filter.Bin()) - statelogger.Infof("Imported block #%d (%x...)\n", block.Number, block.Hash()[0:4]) - if dontReact == false { - sm.eth.EventMux().Post(NewBlockEvent{block}) - state.Manifest().Reset() - } + state.Manifest().Reset() sm.eth.TxPool().RemoveSet(block.Transactions()) } else { |