aboutsummaryrefslogtreecommitdiffstats
path: root/peer.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 /peer.go
parentea0357bf02b61db94bd0ad8806ba7337a55a4f79 (diff)
downloadgo-tangerine-ab6ede51d7fedb9270cab08ee732a834be34dab2.tar.gz
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 'peer.go')
-rw-r--r--peer.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/peer.go b/peer.go
index 11ec6e003..f5d0fe4ed 100644
--- a/peer.go
+++ b/peer.go
@@ -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)}))
}
}
}