aboutsummaryrefslogtreecommitdiffstats
path: root/eth/handler.go
diff options
context:
space:
mode:
authorkiel barry <kiel.j.barry@gmail.com>2018-05-03 20:15:33 +0800
committerPéter Szilágyi <peterke@gmail.com>2018-05-03 20:15:33 +0800
commit5b3af4c3d1455bc3e4a1c4aa514423683c8aaf7b (patch)
treef7615b921cfb86a68ae57dc2034595ca5c3927e6 /eth/handler.go
parent60b433ab84589c2a33553575677bfa61ae3d1078 (diff)
downloaddexon-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.go28
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(),
}
}