diff options
author | obscuren <geffobscura@gmail.com> | 2014-10-02 07:36:59 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-10-02 07:36:59 +0800 |
commit | a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8 (patch) | |
tree | 9236dd9464bbf17b582cbf122b1f9eeeb288cc66 /peer.go | |
parent | 5fa0173c4147baee54ad1846a23cd4410c50420b (diff) | |
download | dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar.gz dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar.bz2 dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar.lz dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar.xz dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.tar.zst dexon-a34a971b508e1bc1fbeb3c2d02cbb8686d2491d8.zip |
improved blockchain downloading
Diffstat (limited to 'peer.go')
-rw-r--r-- | peer.go | 75 |
1 files changed, 41 insertions, 34 deletions
@@ -129,9 +129,9 @@ type Peer struct { statusKnown bool // Last received pong message - lastPong int64 - lastBlockReceived time.Time - LastHashReceived time.Time + lastPong int64 + lastBlockReceived time.Time + doneFetchingHashes bool host []byte port uint16 @@ -164,36 +164,38 @@ func NewPeer(conn net.Conn, ethereum *Ethereum, inbound bool) *Peer { pubkey := ethereum.KeyManager().PublicKey()[1:] return &Peer{ - outputQueue: make(chan *ethwire.Msg, outputBufferSize), - quit: make(chan bool), - ethereum: ethereum, - conn: conn, - inbound: inbound, - disconnect: 0, - connected: 1, - port: 30303, - pubkey: pubkey, - blocksRequested: 10, - caps: ethereum.ServerCaps(), - version: ethereum.ClientIdentity().String(), - protocolCaps: ethutil.NewValue(nil), - td: big.NewInt(0), + outputQueue: make(chan *ethwire.Msg, outputBufferSize), + quit: make(chan bool), + ethereum: ethereum, + conn: conn, + inbound: inbound, + disconnect: 0, + connected: 1, + port: 30303, + pubkey: pubkey, + blocksRequested: 10, + caps: ethereum.ServerCaps(), + version: ethereum.ClientIdentity().String(), + protocolCaps: ethutil.NewValue(nil), + td: big.NewInt(0), + doneFetchingHashes: true, } } func NewOutboundPeer(addr string, ethereum *Ethereum, caps Caps) *Peer { p := &Peer{ - outputQueue: make(chan *ethwire.Msg, outputBufferSize), - quit: make(chan bool), - ethereum: ethereum, - inbound: false, - connected: 0, - disconnect: 0, - port: 30303, - caps: caps, - version: ethereum.ClientIdentity().String(), - protocolCaps: ethutil.NewValue(nil), - td: big.NewInt(0), + outputQueue: make(chan *ethwire.Msg, outputBufferSize), + quit: make(chan bool), + ethereum: ethereum, + inbound: false, + connected: 0, + disconnect: 0, + port: 30303, + caps: caps, + version: ethereum.ClientIdentity().String(), + protocolCaps: ethutil.NewValue(nil), + td: big.NewInt(0), + doneFetchingHashes: true, } // Set up the connection in another goroutine so we don't block the main thread @@ -503,20 +505,22 @@ func (p *Peer) HandleInbound() { it := msg.Data.NewIterator() for it.Next() { hash := it.Value().Bytes() + p.lastReceivedHash = hash + if blockPool.HasCommonHash(hash) { foundCommonHash = true break } - p.lastReceivedHash = hash - p.LastHashReceived = time.Now() - blockPool.AddHash(hash, p) } if !foundCommonHash && msg.Data.Len() != 0 { p.FetchHashes() + } else { + peerlogger.Infof("Found common hash (%x...)\n", p.lastReceivedHash[0:4]) + p.doneFetchingHashes = true } case ethwire.MsgBlockTy: @@ -543,11 +547,15 @@ func (p *Peer) HandleInbound() { func (self *Peer) FetchBlocks(hashes [][]byte) { if len(hashes) > 0 { + peerlogger.Debugf("Fetching blocks (%d)\n", len(hashes)) + self.QueueMessage(ethwire.NewMessage(ethwire.MsgGetBlocksTy, ethutil.ByteSliceToInterface(hashes))) } } func (self *Peer) FetchHashes() { + self.doneFetchingHashes = false + blockPool := self.ethereum.blockPool if self.td.Cmp(self.ethereum.HighestTDPeer()) >= 0 { @@ -562,7 +570,7 @@ func (self *Peer) FetchHashes() { } func (self *Peer) FetchingHashes() bool { - return time.Since(self.LastHashReceived) < 200*time.Millisecond + return !self.doneFetchingHashes } // General update method @@ -576,10 +584,9 @@ out: if self.IsCap("eth") { var ( sinceBlock = time.Since(self.lastBlockReceived) - sinceHash = time.Since(self.LastHashReceived) ) - if sinceBlock > 5*time.Second && sinceHash > 5*time.Second { + if sinceBlock > 5*time.Second { self.catchingUp = false } } |