aboutsummaryrefslogtreecommitdiffstats
path: root/eth
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-06-19 15:07:37 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-06-19 15:07:37 +0800
commit4180ca7fe47359a80e88186b9127e93af685a81a (patch)
treeb792043d37e4ad855a8d86629b57eeea7bacae9e /eth
parente4f9ec886b498c5744633a4db1c735eec11dc71b (diff)
downloaddexon-4180ca7fe47359a80e88186b9127e93af685a81a.tar.gz
dexon-4180ca7fe47359a80e88186b9127e93af685a81a.tar.zst
dexon-4180ca7fe47359a80e88186b9127e93af685a81a.zip
eth: fix the propagation/announce order for mined blocks
Diffstat (limited to 'eth')
-rw-r--r--eth/handler.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/eth/handler.go b/eth/handler.go
index a5986b779..ad88e9c59 100644
--- a/eth/handler.go
+++ b/eth/handler.go
@@ -6,7 +6,6 @@ import (
"sync"
"time"
- "github.com/ethereum/go-ethereum/pow"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/core"
"github.com/ethereum/go-ethereum/core/types"
@@ -16,6 +15,7 @@ import (
"github.com/ethereum/go-ethereum/logger"
"github.com/ethereum/go-ethereum/logger/glog"
"github.com/ethereum/go-ethereum/p2p"
+ "github.com/ethereum/go-ethereum/pow"
"github.com/ethereum/go-ethereum/rlp"
)
@@ -307,7 +307,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
blocks = nil
}
// Update the receive timestamp of each block
- for i:=0; i<len(blocks); i++ {
+ for i := 0; i < len(blocks); i++ {
blocks[i].ReceivedAt = msg.ReceivedAt
}
// Filter out any explicitly requested blocks, deliver the rest to the downloader
@@ -417,8 +417,8 @@ func (self *ProtocolManager) minedBroadcastLoop() {
for obj := range self.minedBlockSub.Chan() {
switch ev := obj.(type) {
case core.NewMinedBlockEvent:
- self.BroadcastBlock(ev.Block, false)
- self.BroadcastBlock(ev.Block, true)
+ self.BroadcastBlock(ev.Block, true) // First propagate block to peers
+ self.BroadcastBlock(ev.Block, false) // Only then announce to the rest
}
}
}