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

reduce sync delay

Browse source 
fix stopper bug
This commit is contained in:
Niko Storni 2019-12-27 01:27:29 +01:00
parent 8028c6621c
commit 59471f9c26
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
manager/manager.go
View file

@ -161,7 +161,7 @@ func (s *SyncManager) Start() error {
for _, q := range queuesToSync { for _, q := range queuesToSync {
//temporary override for sync-until to give tom the time to review the channels //temporary override for sync-until to give tom the time to review the channels
if q == StatusQueued { if q == StatusQueued {
s.syncProperties.SyncUntil = time.Now().AddDate(0, 0, -1).Unix() s.syncProperties.SyncUntil = time.Now().Add(-8 * time.Hour).Unix()
} }
channels, err := s.apiConfig.FetchChannels(q, s.syncProperties) channels, err := s.apiConfig.FetchChannels(q, s.syncProperties)
if err != nil { if err != nil {

4
manager/ytsync.go
View file

@ -246,6 +246,8 @@ func (s *Sync) setExceptions() {
} }
} }
var stopGroup = stop.New()
func (s *Sync) FullCycle() (e error) { func (s *Sync) FullCycle() (e error) {
if os.Getenv("HOME") == "" { if os.Getenv("HOME") == "" {
return errors.Err("no $HOME env var found") return errors.Err("no $HOME env var found")
@ -258,7 +260,7 @@ func (s *Sync) FullCycle() (e error) {
s.syncedVideosMux = &sync.RWMutex{} s.syncedVideosMux = &sync.RWMutex{}
s.walletMux = &sync.RWMutex{} s.walletMux = &sync.RWMutex{}
s.grp = stop.New() s.grp = stopGroup
s.queue = make(chan video) s.queue = make(chan video)
interruptChan := make(chan os.Signal, 1) interruptChan := make(chan os.Signal, 1)
signal.Notify(interruptChan, os.Interrupt, syscall.SIGTERM) signal.Notify(interruptChan, os.Interrupt, syscall.SIGTERM)