diff options
author | obscuren <geffobscura@gmail.com> | 2014-09-29 18:57:51 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-09-29 18:57:51 +0800 |
commit | ab6ede51d7fedb9270cab08ee732a834be34dab2 (patch) | |
tree | d8252f27d51c456e637140a312cadfe2ced71528 /peer.go | |
parent | ea0357bf02b61db94bd0ad8806ba7337a55a4f79 (diff) | |
download | dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.gz dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.bz2 dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.lz dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.xz dexon-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.zst dexon-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 'peer.go')
-rw-r--r-- | peer.go | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -554,7 +554,9 @@ func (self *Peer) FetchHashes() { blockPool.td = self.td if !blockPool.HasLatestHash() { - self.QueueMessage(ethwire.NewMessage(ethwire.MsgGetBlockHashesTy, []interface{}{self.lastReceivedHash, uint32(256)})) + const amount = 256 + peerlogger.Debugf("Fetching hashes (%d)\n", amount) + self.QueueMessage(ethwire.NewMessage(ethwire.MsgGetBlockHashesTy, []interface{}{self.lastReceivedHash, uint32(amount)})) } } } |