aboutsummaryrefslogtreecommitdiffstats
path: root/block_pool.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-09-29 18:57:51 +0800
committerobscuren <geffobscura@gmail.com>2014-09-29 18:57:51 +0800
commitab6ede51d7fedb9270cab08ee732a834be34dab2 (patch)
treed8252f27d51c456e637140a312cadfe2ced71528 /block_pool.go
parentea0357bf02b61db94bd0ad8806ba7337a55a4f79 (diff)
downloadgo-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.gz
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.bz2
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.lz
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.xz
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.zst
go-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.zip
Working on new (blocking) event machine.
The new event machine will be used for loose coupling and handle the communications between the services: 1) Block pool finds blocks which "links" with our current canonical chain 2) Posts the blocks on to the event machine 3) State manager receives blocks & processes them 4) Broadcasts new post block event
Diffstat (limited to 'block_pool.go')
-rw-r--r--block_pool.go38
1 files changed, 24 insertions, 14 deletions
diff --git a/block_pool.go b/block_pool.go
index 4ac096bda..957b7601b 100644
--- a/block_pool.go
+++ b/block_pool.go
@@ -1,6 +1,7 @@
package eth
import (
+ "bytes"
"container/list"
"math"
"math/big"
@@ -236,22 +237,31 @@ out:
case <-self.quit:
break out
case <-procTimer.C:
- // XXX We can optimize this lifting this on to a new goroutine.
- // We'd need to make sure that the pools are properly protected by a mutex
- // XXX This should moved in The Great Refactor(TM)
- amount := self.ProcessCanonical(func(block *ethchain.Block) {
- err := self.eth.StateManager().Process(block, false)
- if err != nil {
- poollogger.Infoln(err)
- poollogger.Debugf("Block #%v failed (%x...)\n", block.Number, block.Hash()[0:4])
- poollogger.Debugln(block)
+ blocks := self.Blocks()
+ ethchain.BlockBy(ethchain.Number).Sort(blocks)
+
+ if len(blocks) > 0 {
+ if self.eth.BlockChain().HasBlock(blocks[0].PrevHash) {
+ for i, block := range blocks[1:] {
+ // NOTE: The Ith element in this loop refers to the previous block in
+ // outer "blocks"
+ if bytes.Compare(block.PrevHash, blocks[i].Hash()) != 0 {
+ blocks = blocks[:i]
+
+ break
+ }
+ }
+ } else {
+ blocks = nil
}
- })
+ }
+
+ // Handle in batches of 4k
+ max := int(math.Min(4000, float64(len(blocks))))
+ for _, block := range blocks[:max] {
+ self.eth.Eventer().Post("block", block)
- // Do not propagate to the network on catchups
- if amount == 1 {
- block := self.eth.BlockChain().CurrentBlock
- self.eth.Broadcast(ethwire.MsgBlockTy, []interface{}{block.Value().Val})
+ self.Remove(block.Hash())
}
}
}