mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2024-12-25 12:57:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

QSP-42 Remove Double Unsubscribe in Initial Sync (#6368)

Browse Source 
* rem double unsub
* Update beacon-chain/sync/initial-sync/service.go

Co-authored-by: Preston Van Loon <preston@prysmaticlabs.com>
* Merge refs/heads/master into qsp-unsub
* Merge refs/heads/master into qsp-unsub
* Merge refs/heads/master into qsp-unsub
* Merge refs/heads/master into qsp-unsub
* Merge refs/heads/master into qsp-unsub
This commit is contained in:
Raul Jordan 2020-06-23 18:50:52 -05:00 committed by GitHub
parent c3adde3b32
commit 637354f037
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
beacon-chain/sync/initial-sync/service.go
View File

@ -80,9 +80,7 @@ func (s *Service) Start() {
// Wait for state to be initialized. // Wait for state to be initialized.
stateChannel := make(chan *feed.Event, 1) stateChannel := make(chan *feed.Event, 1)
stateSub := s.stateNotifier.StateFeed().Subscribe(stateChannel) stateSub := s.stateNotifier.StateFeed().Subscribe(stateChannel)
defer stateSub.Unsubscribe() for genesisSet := false; !genesisSet; {
genesisSet := false
for !genesisSet {
select { select {
case event := <-stateChannel: case event := <-stateChannel:
if event.Type == statefeed.Initialized { if event.Type == statefeed.Initialized {
@ -97,10 +95,10 @@ func (s *Service) Start() {
} }
case <-s.ctx.Done(): case <-s.ctx.Done():
log.Debug("Context closed, exiting goroutine") log.Debug("Context closed, exiting goroutine")
return break
case err := <-stateSub.Err(): case err := <-stateSub.Err():
log.WithError(err).Error("Subscription to state notifier failed") log.WithError(err).Error("Subscription to state notifier failed")
return break
} }
} }
stateSub.Unsubscribe() stateSub.Unsubscribe()