forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-19 21:31:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

eth/downloader: fix issue #16539 (#16546)

Browse source
This commit is contained in:
Daniel Liu 2025-02-11 16:35:07 +08:00
parent 3ebf97e721
commit 652c66e9d4
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
eth/downloader/downloader.go
View file

@ -313,7 +313,7 @@ func (d *Downloader) UnregisterPeer(id string) error {
d.cancelLock.RUnlock()
if master {
d.Cancel()
d.cancel()
}
return nil
}
@ -511,8 +511,10 @@ func (d *Downloader) spawnSync(fetchers []func() error) error {
return err
}
// Cancel cancels all of the operations and resets the queue.
func (d *Downloader) Cancel() {
// cancel aborts all of the operations and resets the queue. However, cancel does
// not wait for the running download goroutines to finish. This method should be
// used when cancelling the downloads from inside the downloader.
func (d *Downloader) cancel() {
// Close the current cancel channel
d.cancelLock.Lock()
if d.cancelCh != nil {
@ -524,6 +526,12 @@ func (d *Downloader) Cancel() {
}
}
d.cancelLock.Unlock()
}
// Cancel aborts all of the operations and waits for all download goroutines to
// finish before returning.
func (d *Downloader) Cancel() {
d.cancel()
d.cancelWg.Wait()
}