Updated peers

pull/150/head
obscuren 11 years ago
parent 233f5200ef
commit 1b7cba1878
  1. 2
      ethereum.go
  2. 16
      peer.go

@ -60,7 +60,7 @@ func New() (*Ethereum, error) {
}
ethereum.TxPool = ethchain.NewTxPool()
ethereum.TxPool.Speaker = ethereum
ethereum.BlockManager = ethchain.NewBlockManager()
ethereum.BlockManager = ethchain.NewBlockManager(ethereum)
ethereum.TxPool.BlockManager = ethereum.BlockManager
ethereum.BlockManager.TransactionPool = ethereum.TxPool

@ -128,7 +128,7 @@ out:
p.lastSend = time.Now()
case <-tickleTimer.C:
p.writeMessage(&ethwire.Msg{Type: ethwire.MsgPingTy})
p.writeMessage(ethwire.NewMessage(ethwire.MsgPingTy, ""))
// Break out of the for loop if a quit message is posted
case <-p.quit:
@ -170,12 +170,12 @@ out:
// Version message
p.handleHandshake(msg)
case ethwire.MsgBlockTy:
/*
err := p.ethereum.BlockManager.ProcessBlock(ethchain.NewBlock(msg.Data))
if err != nil {
log.Println(err)
}
*/
block := ethchain.NewBlockFromRlpValue(msg.Data.Get(0))
block.MakeContracts()
err := p.ethereum.BlockManager.ProcessBlock(block)
if err != nil {
log.Println(err)
}
case ethwire.MsgTxTy:
//p.ethereum.TxPool.QueueTransaction(ethchain.NewTransactionFromData(msg.Data))
p.ethereum.TxPool.QueueTransaction(ethchain.NewTransactionFromRlpValue(msg.Data.Get(0)))
@ -203,7 +203,7 @@ out:
}
case ethwire.MsgPingTy:
// Respond back with pong
p.QueueMessage(&ethwire.Msg{Type: ethwire.MsgPongTy})
p.QueueMessage(ethwire.NewMessage(ethwire.MsgPongTy, ""))
case ethwire.MsgPongTy:
p.lastPong = time.Now().Unix()
}

Loading…
Cancel
Save