diff options
author | Taylor Gerring <taylor.gerring@gmail.com> | 2014-11-27 20:23:31 +0800 |
---|---|---|
committer | Taylor Gerring <taylor.gerring@gmail.com> | 2014-11-27 20:23:31 +0800 |
commit | ef7961b7d27be930a4d9dc81527a55497d3dea2e (patch) | |
tree | 5746b715b1b66c5767779e2e4ca66be345333e13 /peer.go | |
parent | c17a3cb0ceec44c10bc84d05f0d81f08894c792c (diff) | |
parent | 8cf9ed0ea588e97f2baf0f834248727e8fbca18f (diff) | |
download | go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar.gz go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar.bz2 go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar.lz go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar.xz go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.tar.zst go-tangerine-ef7961b7d27be930a4d9dc81527a55497d3dea2e.zip |
Merge pull request #194 from ethereum/poc8
Update tests branch to PoC8
Diffstat (limited to 'peer.go')
-rw-r--r-- | peer.go | 12 |
1 files changed, 6 insertions, 6 deletions
@@ -12,7 +12,7 @@ import ( "sync/atomic" "time" - "github.com/ethereum/go-ethereum/chain" + "github.com/ethereum/go-ethereum/chain/types" "github.com/ethereum/go-ethereum/ethutil" "github.com/ethereum/go-ethereum/logger" "github.com/ethereum/go-ethereum/wire" @@ -24,7 +24,7 @@ const ( // The size of the output buffer for writing messages outputBufferSize = 50 // Current protocol version - ProtocolVersion = 42 + ProtocolVersion = 43 // Current P2P version P2PVersion = 2 // Ethereum network version @@ -155,7 +155,7 @@ type Peer struct { pingTime time.Duration pingStartTime time.Time - lastRequestedBlock *chain.Block + lastRequestedBlock *types.Block protocolCaps *ethutil.Value } @@ -429,7 +429,7 @@ func (p *Peer) HandleInbound() { // in the TxPool where it will undergo validation and // processing when a new block is found for i := 0; i < msg.Data.Len(); i++ { - tx := chain.NewTransactionFromValue(msg.Data.Get(i)) + tx := types.NewTransactionFromValue(msg.Data.Get(i)) p.ethereum.TxPool().QueueTransaction(tx) } case wire.MsgGetPeersTy: @@ -535,7 +535,7 @@ func (p *Peer) HandleInbound() { it := msg.Data.NewIterator() for it.Next() { - block := chain.NewBlockFromRlpValue(it.Value()) + block := types.NewBlockFromRlpValue(it.Value()) blockPool.Add(block, p) p.lastBlockReceived = time.Now() @@ -543,7 +543,7 @@ func (p *Peer) HandleInbound() { case wire.MsgNewBlockTy: var ( blockPool = p.ethereum.blockPool - block = chain.NewBlockFromRlpValue(msg.Data.Get(0)) + block = types.NewBlockFromRlpValue(msg.Data.Get(0)) td = msg.Data.Get(1).BigInt() ) |