diff options
author | kiel barry <kiel.j.barry@gmail.com> | 2018-05-03 20:15:33 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2018-05-03 20:15:33 +0800 |
commit | 5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b (patch) | |
tree | f7615b921cfb86a68ae57dc2034595ca5c3927e6 /eth/handler.go | |
parent | 60b433ab84589c2a33553575677bfa61ae3d1078 (diff) | |
download | dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar.gz dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar.bz2 dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar.lz dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar.xz dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.tar.zst dexon-5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b.zip |
eth: golint updates for this or self warning (#16632)
* eth/*:golint updates for this or self warning
* eth/*: golint updates for this or self warning, pr updated per feedback
Diffstat (limited to 'eth/handler.go')
-rw-r--r-- | eth/handler.go | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/eth/handler.go b/eth/handler.go index 4069359c9..c8f7e13f1 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -725,25 +725,25 @@ func (pm *ProtocolManager) BroadcastTx(hash common.Hash, tx *types.Transaction) } // Mined broadcast loop -func (self *ProtocolManager) minedBroadcastLoop() { +func (pm *ProtocolManager) minedBroadcastLoop() { // automatically stops if unsubscribe - for obj := range self.minedBlockSub.Chan() { + for obj := range pm.minedBlockSub.Chan() { switch ev := obj.Data.(type) { case core.NewMinedBlockEvent: - self.BroadcastBlock(ev.Block, true) // First propagate block to peers - self.BroadcastBlock(ev.Block, false) // Only then announce to the rest + pm.BroadcastBlock(ev.Block, true) // First propagate block to peers + pm.BroadcastBlock(ev.Block, false) // Only then announce to the rest } } } -func (self *ProtocolManager) txBroadcastLoop() { +func (pm *ProtocolManager) txBroadcastLoop() { for { select { - case event := <-self.txCh: - self.BroadcastTx(event.Tx.Hash(), event.Tx) + case event := <-pm.txCh: + pm.BroadcastTx(event.Tx.Hash(), event.Tx) // Err() channel will be closed when unsubscribing. - case <-self.txSub.Err(): + case <-pm.txSub.Err(): return } } @@ -760,13 +760,13 @@ type NodeInfo struct { } // NodeInfo retrieves some protocol metadata about the running host node. -func (self *ProtocolManager) NodeInfo() *NodeInfo { - currentBlock := self.blockchain.CurrentBlock() +func (pm *ProtocolManager) NodeInfo() *NodeInfo { + currentBlock := pm.blockchain.CurrentBlock() return &NodeInfo{ - Network: self.networkId, - Difficulty: self.blockchain.GetTd(currentBlock.Hash(), currentBlock.NumberU64()), - Genesis: self.blockchain.Genesis().Hash(), - Config: self.blockchain.Config(), + Network: pm.networkId, + Difficulty: pm.blockchain.GetTd(currentBlock.Hash(), currentBlock.NumberU64()), + Genesis: pm.blockchain.Genesis().Hash(), + Config: pm.blockchain.Config(), Head: currentBlock.Hash(), } } |