From 07e0168087be4493ebb0e64d5fbd689f85fb73d2 Mon Sep 17 00:00:00 2001 From: Felix Lange Date: Wed, 29 Apr 2026 16:08:46 +0200 Subject: [PATCH] eth/downloader: add syncmode in events --- eth/downloader/downloader.go | 8 ++++---- eth/downloader/events.go | 6 +++++- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go index b7dfa77507..4a575d6856 100644 --- a/eth/downloader/downloader.go +++ b/eth/downloader/downloader.go @@ -437,17 +437,17 @@ func (d *Downloader) SubscribeSyncEvents(ch chan<- SyncEvent) event.Subscription // syncToHead starts a block synchronization based on the hash chain from // the specified head hash. func (d *Downloader) syncToHead() (err error) { - d.feed.Send(SyncEvent{Type: SyncStarted}) + mode := d.getMode() + d.feed.Send(SyncEvent{Type: SyncStarted, Mode: mode}) defer func() { // reset on error if err != nil { - d.feed.Send(SyncEvent{Type: SyncFailed, Err: err}) + d.feed.Send(SyncEvent{Type: SyncFailed, Mode: mode, Err: err}) } else { latest := d.blockchain.CurrentHeader() - d.feed.Send(SyncEvent{Type: SyncCompleted, Latest: latest}) + d.feed.Send(SyncEvent{Type: SyncCompleted, Mode: mode, Latest: latest}) } }() - mode := d.getMode() log.Debug("Backfilling with the network", "mode", mode) defer func(start time.Time) { diff --git a/eth/downloader/events.go b/eth/downloader/events.go index 81cf75fa6f..0fb380a857 100644 --- a/eth/downloader/events.go +++ b/eth/downloader/events.go @@ -16,7 +16,10 @@ package downloader -import "github.com/ethereum/go-ethereum/core/types" +import ( + "github.com/ethereum/go-ethereum/core/types" + "github.com/ethereum/go-ethereum/eth/ethconfig" +) // SyncEventType represents the type of sync event type SyncEventType int @@ -30,6 +33,7 @@ const ( // SyncEvent represents a downloader synchronization event type SyncEvent struct { Type SyncEventType + Mode ethconfig.SyncMode Err error // Set when Type is SyncFailed Latest *types.Header // Set when Type is SyncCompleted }