diff options
| author | obscuren <geffobscura@gmail.com> | 2014-10-31 21:53:42 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-10-31 21:53:42 +0800 |
| commit | 4914a78c8c650d7fc74570f25a682598aaeb6973 (patch) | |
| tree | eca4eef360d5202d51d5d8766072848ebcb185e3 /block_pool.go | |
| parent | af34749a6b47ff8f9b4cb55d9ea65e1235d63b68 (diff) | |
| download | dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar.gz dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar.bz2 dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar.lz dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar.xz dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.tar.zst dexon-4914a78c8c650d7fc74570f25a682598aaeb6973.zip | |
ethwire => wire
Diffstat (limited to 'block_pool.go')
| -rw-r--r-- | block_pool.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/block_pool.go b/block_pool.go index 1cf3ab907..0e182623f 100644 --- a/block_pool.go +++ b/block_pool.go @@ -11,8 +11,8 @@ import ( "github.com/ethereum/go-ethereum/chain" "github.com/ethereum/go-ethereum/ethutil" - "github.com/ethereum/go-ethereum/ethwire" "github.com/ethereum/go-ethereum/logger" + "github.com/ethereum/go-ethereum/wire" ) var poollogger = logger.NewLogger("BPOOL") @@ -103,7 +103,7 @@ func (self *BlockPool) FetchHashes(peer *Peer) bool { const amount = 256 peerlogger.Debugf("Fetching hashes (%d) %x...\n", amount, peer.lastReceivedHash[0:4]) - peer.QueueMessage(ethwire.NewMessage(ethwire.MsgGetBlockHashesTy, []interface{}{peer.lastReceivedHash, uint32(amount)})) + peer.QueueMessage(wire.NewMessage(wire.MsgGetBlockHashesTy, []interface{}{peer.lastReceivedHash, uint32(amount)})) } return true @@ -150,7 +150,7 @@ func (self *BlockPool) addBlock(b *chain.Block, peer *Peer, newBlock bool) { fmt.Println("3.", !self.fetchingHashes) if !self.eth.ChainManager().HasBlock(b.PrevHash) && self.pool[string(b.PrevHash)] == nil && !self.fetchingHashes { poollogger.Infof("Unknown chain, requesting (%x...)\n", b.PrevHash[0:4]) - peer.QueueMessage(ethwire.NewMessage(ethwire.MsgGetBlockHashesTy, []interface{}{b.Hash(), uint32(256)})) + peer.QueueMessage(wire.NewMessage(wire.MsgGetBlockHashesTy, []interface{}{b.Hash(), uint32(256)})) } } } else if self.pool[hash] != nil { |