aboutsummaryrefslogtreecommitdiffstats
path: root/peer.go
diff options
context:
space:
mode:
authorTaylor Gerring <taylor.gerring@gmail.com>2014-11-27 20:23:31 +0800
committerTaylor Gerring <taylor.gerring@gmail.com>2014-11-27 20:23:31 +0800
commitef7961b7d27be930a4d9dc81527a55497d3dea2e (patch)
tree5746b715b1b66c5767779e2e4ca66be345333e13 /peer.go
parentc17a3cb0ceec44c10bc84d05f0d81f08894c792c (diff)
parent8cf9ed0ea588e97f2baf0f834248727e8fbca18f (diff)
downloadgo-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.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/peer.go b/peer.go
index b54978854..ff3593604 100644
--- a/peer.go
+++ b/peer.go
@@ -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()
)