eth/downloader/downloader_pow.go — Version Comparison
|
v1.16.8 |
v1.17.3 |
| Branch |
etc/v1.16.8-full-node |
etc/v1.17.3-full-node |
| Delta |
+971 -0 |
+971 -0 |
Diff between branches
diff --git a/eth/downloader/downloader_pow.go b/eth/downloader/downloader_pow.go
index ecd3812f1..148e17e49 100644
--- a/eth/downloader/downloader_pow.go
+++ b/eth/downloader/downloader_pow.go
@@ -136,17 +136,17 @@ func (d *Downloader) synchronisePoW(id string, hash common.Hash, td *big.Int, mo
// syncWithPeer starts a block synchronization based on the hash chain from the
// specified peer and head hash. This is for PoW networks only (no beacon mode).
func (d *Downloader) syncWithPeer(p *peerConnection, hash common.Hash, td *big.Int) (err error) {
- d.mux.Post(StartEvent{})
+ mode := d.getMode()
+ d.feed.Send(SyncEvent{Type: SyncStarted, Mode: mode})
defer func() {
// reset on error
if err != nil {
- d.mux.Post(FailedEvent{err})
+ d.feed.Send(SyncEvent{Type: SyncFailed, Mode: mode, Err: err})
} else {
latest := d.blockchain.CurrentHeader()
- d.mux.Post(DoneEvent{latest})
+ d.feed.Send(SyncEvent{Type: SyncCompleted, Mode: mode, Latest: latest})
}
}()
- mode := d.getMode()
log.Debug("Synchronising with the network", "peer", p.id, "eth", p.version, "head", hash, "td", td, "mode", mode)
defer func(start time.Time) {