From b5f9fe087f908f4f9dd6d9f788a38d2325d33619 Mon Sep 17 00:00:00 2001 From: jsvisa Date: Fri, 27 Jun 2025 00:21:38 +0800 Subject: [PATCH] new back filler Signed-off-by: jsvisa --- eth/downloader/downloader.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go index 25989b1a50..d14277b697 100644 --- a/eth/downloader/downloader.go +++ b/eth/downloader/downloader.go @@ -116,6 +116,7 @@ type Downloader struct { // Callbacks dropPeer peerDropFn // Drops a peer for misbehaving badBlock badBlockFn // Reports a block as rejected by the chain + success func() // Callback to signal successful sync completion // Status synchronising atomic.Bool @@ -237,6 +238,7 @@ func New(stateDb ethdb.Database, mode ethconfig.SyncMode, mux *event.TypeMux, ch chainCutoffNumber: cutoffNumber, chainCutoffHash: cutoffHash, dropPeer: dropPeer, + success: success, headerProcCh: make(chan *headerTask, 1), quitCh: make(chan struct{}), SnapSyncer: snap.NewSyncer(stateDb, chain.TrieDB().Scheme()), @@ -666,7 +668,7 @@ func (d *Downloader) Cancel() { func (d *Downloader) ResetSkeleton() { d.skeleton.Terminate() rawdb.DeleteSkeletonSyncStatus(d.stateDB) - d.skeleton = newSkeleton(d.stateDB, d.peers, d.dropPeer, d.skeleton.filler) + d.skeleton = newSkeleton(d.stateDB, d.peers, d.dropPeer, newBeaconBackfiller(d, d.success)) } // Terminate interrupts the downloader, canceling all pending operations.