LBRYCommunity/ytsync
1
0
Fork 0
Code Issues 39 Pull requests 8 Projects Releases 197 Packages Wiki Activity

resolve rebase conflicts

Browse source
This commit is contained in:
Niko Storni 2018-07-12 08:28:20 -04:00
parent ad8a9c3003
commit b6eb3db397
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ytsync.go
View file

@ -75,7 +75,7 @@ type Sync struct {
// IsInterrupted can be queried to discover if the sync process was interrupted manually // IsInterrupted can be queried to discover if the sync process was interrupted manually
func (s *Sync) IsInterrupted() bool { func (s *Sync) IsInterrupted() bool {
select { select {
case <-s.stop.Ch(): case <-s.grp.Ch():
return true return true
default: default:
return false return false
@ -284,7 +284,7 @@ func (s *Sync) startWorker(workerNum int) {
log.Println("waiting for a block and refilling addresses before retrying") log.Println("waiting for a block and refilling addresses before retrying")
err = s.walletSetup() err = s.walletSetup()
if err != nil { if err != nil {
s.stop.Stop() s.grp.Stop()
util.SendErrorToSlack("Failed to setup the wallet for a refill: %v", err) util.SendErrorToSlack("Failed to setup the wallet for a refill: %v", err)
break break
} }