118 lines
3.8 KiB
Diff
118 lines
3.8 KiB
Diff
diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go
|
|
index 7ede530a9..60ff8dbc6 100644
|
|
--- a/eth/downloader/downloader.go
|
|
+++ b/eth/downloader/downloader.go
|
|
@@ -143,6 +143,8 @@
|
|
quitCh chan struct{} // Quit channel to signal termination
|
|
quitLock sync.RWMutex // Lock to prevent double closes
|
|
|
|
+ downloads sync.WaitGroup // Keeps track of the currently active downloads
|
|
+
|
|
// Testing hooks
|
|
syncInitHook func(uint64, uint64) // Method to call upon initiating a new sync run
|
|
bodyFetchHook func([]*types.Header) // Method to call upon starting a block body fetch
|
|
@@ -228,6 +230,7 @@
|
|
},
|
|
trackStateReq: make(chan *stateReq),
|
|
}
|
|
+ dl.downloads.Add(1) // Add a sentinel value to avoid waiting with zero count and getting a race condition signaled when terminating Downloader before starting sync
|
|
go dl.qosTuner()
|
|
go dl.stateFetcher()
|
|
return dl
|
|
@@ -403,7 +406,9 @@
|
|
// specified peer and head hash.
|
|
func (d *Downloader) syncWithPeer(p *peerConnection, hash common.Hash, td *big.Int) (err error) {
|
|
d.mux.Post(StartEvent{})
|
|
+ d.downloads.Add(1)
|
|
defer func() {
|
|
+ d.downloads.Done()
|
|
// reset on error
|
|
if err != nil {
|
|
d.mux.Post(FailedEvent{err})
|
|
@@ -539,6 +544,13 @@
|
|
|
|
// Cancel any pending download requests
|
|
d.Cancel()
|
|
+
|
|
+ // Remove sentinel value from WaitGroup before calling Wait()
|
|
+ go func() { d.downloads.Done() }()
|
|
+
|
|
+ // Wait, so external dependencies aren't destroyed
|
|
+ // until the download processing is done.
|
|
+ d.downloads.Wait()
|
|
}
|
|
|
|
// fetchHeight retrieves the head header of the remote peer to aid in estimating
|
|
diff --git a/eth/handler.go b/eth/handler.go
|
|
index c2426544f..08818a507 100644
|
|
--- a/eth/handler.go
|
|
+++ b/eth/handler.go
|
|
@@ -230,6 +230,9 @@ func (pm *ProtocolManager) Stop() {
|
|
// Quit fetcher, txsyncLoop.
|
|
close(pm.quitSync)
|
|
|
|
+ // Stop downloader and make sure that all the running downloads are complete.
|
|
+ pm.downloader.Terminate()
|
|
+
|
|
// Disconnect existing sessions.
|
|
// This also closes the gate for any new registrations on the peer set.
|
|
// sessions which are already established but not added to pm.peers yet
|
|
diff --git a/eth/sync.go b/eth/sync.go
|
|
index 2da1464bc..f14e84303 100644
|
|
--- a/eth/sync.go
|
|
+++ b/eth/sync.go
|
|
@@ -135,7 +135,6 @@ func (pm *ProtocolManager) syncer() {
|
|
// Start and ensure cleanup of sync mechanisms
|
|
pm.fetcher.Start()
|
|
defer pm.fetcher.Stop()
|
|
- defer pm.downloader.Terminate()
|
|
|
|
// Wait for different events to fire synchronisation operations
|
|
forceSync := time.NewTicker(forceSyncCycle)
|
|
diff --git a/les/handler.go b/les/handler.go
|
|
index 864abe605..67e459594 100644
|
|
--- a/les/handler.go
|
|
+++ b/les/handler.go
|
|
@@ -241,6 +241,9 @@ func (pm *ProtocolManager) Stop() {
|
|
|
|
close(pm.quitSync) // quits syncer, fetcher
|
|
|
|
+ // Stop downloader and make sure that all the running downloads are complete.
|
|
+ pm.downloader.Terminate()
|
|
+
|
|
// Disconnect existing sessions.
|
|
// This also closes the gate for any new registrations on the peer set.
|
|
// sessions which are already established but not added to pm.peers yet
|
|
diff --git a/les/sync.go b/les/sync.go
|
|
index c0e17f97d..983dc7f36 100644
|
|
--- a/les/sync.go
|
|
+++ b/les/sync.go
|
|
@@ -36,7 +36,6 @@ func (pm *ProtocolManager) syncer() {
|
|
// Start and ensure cleanup of sync mechanisms
|
|
//pm.fetcher.Start()
|
|
//defer pm.fetcher.Stop()
|
|
- defer pm.downloader.Terminate()
|
|
|
|
// Wait for different events to fire synchronisation operations
|
|
//forceSync := time.Tick(forceSyncCycle)
|
|
diff --git a/les/backend.go b/les/backend.go
|
|
index 6a324cb0..e3844bf8 100644
|
|
--- a/les/backend.go
|
|
+++ b/les/backend.go
|
|
@@ -20,7 +20,6 @@ package les
|
|
import (
|
|
"fmt"
|
|
"sync"
|
|
- "time"
|
|
|
|
"github.com/ethereum/go-ethereum/accounts"
|
|
"github.com/ethereum/go-ethereum/common"
|
|
@@ -250,7 +249,6 @@ func (s *LightEthereum) Stop() error {
|
|
|
|
s.eventMux.Stop()
|
|
|
|
- time.Sleep(time.Millisecond * 200)
|
|
s.chainDb.Close()
|
|
close(s.shutdownChan)
|
|
|