|
|
|
@ -285,7 +285,6 @@ func (p *Peer) HandleInbound() { |
|
|
|
|
p.lastPong = time.Now().Unix() |
|
|
|
|
case ethwire.MsgBlockTy: |
|
|
|
|
// Get all blocks and process them
|
|
|
|
|
msg.Data = msg.Data |
|
|
|
|
var block, lastBlock *ethchain.Block |
|
|
|
|
var err error |
|
|
|
|
for i := msg.Data.Len() - 1; i >= 0; i-- { |
|
|
|
@ -438,7 +437,7 @@ func (p *Peer) Start() { |
|
|
|
|
|
|
|
|
|
err := p.pushHandshake() |
|
|
|
|
if err != nil { |
|
|
|
|
log.Printf("Peer can't send outbound version ack", err) |
|
|
|
|
log.Println("Peer can't send outbound version ack", err) |
|
|
|
|
|
|
|
|
|
p.Stop() |
|
|
|
|
|
|
|
|
|