aboutsummaryrefslogtreecommitdiffstats
path: root/peer.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-07-24 18:04:15 +0800
committerobscuren <geffobscura@gmail.com>2014-07-24 18:04:15 +0800
commit32d125131f602d63f66ee7eb09439074f0b94a91 (patch)
treede8cdb558d390f8200962af2d24d4402b6762409 /peer.go
parent958b482ada677028e11698c219ed5b1e70b224e6 (diff)
downloadgo-tangerine-32d125131f602d63f66ee7eb09439074f0b94a91.tar.gz
go-tangerine-32d125131f602d63f66ee7eb09439074f0b94a91.tar.zst
go-tangerine-32d125131f602d63f66ee7eb09439074f0b94a91.zip
Refactored to new state and vm
Diffstat (limited to 'peer.go')
-rw-r--r--peer.go27
1 files changed, 12 insertions, 15 deletions
diff --git a/peer.go b/peer.go
index 89032364e..1b8ebb5a4 100644
--- a/peer.go
+++ b/peer.go
@@ -470,23 +470,20 @@ func (p *Peer) HandleInbound() {
p.pushPeers()
case ethwire.MsgPeersTy:
// Received a list of peers (probably because MsgGetPeersTy was send)
- // Only act on message if we actually requested for a peers list
- if p.requestedPeerList {
- data := msg.Data
- // Create new list of possible peers for the ethereum to process
- peers := make([]string, data.Len())
- // Parse each possible peer
- for i := 0; i < data.Len(); i++ {
- value := data.Get(i)
- peers[i] = unpackAddr(value.Get(0), value.Get(1).Uint())
- }
+ data := msg.Data
+ // Create new list of possible peers for the ethereum to process
+ peers := make([]string, data.Len())
+ // Parse each possible peer
+ for i := 0; i < data.Len(); i++ {
+ value := data.Get(i)
+ peers[i] = unpackAddr(value.Get(0), value.Get(1).Uint())
+ }
- // Connect to the list of peers
- p.ethereum.ProcessPeerList(peers)
- // Mark unrequested again
- p.requestedPeerList = false
+ // Connect to the list of peers
+ p.ethereum.ProcessPeerList(peers)
+ // Mark unrequested again
+ p.requestedPeerList = false
- }
case ethwire.MsgGetChainTy:
var parent *ethchain.Block
// Length minus one since the very last element in the array is a count