mirror/mxpv-podsync
1
0
Fork 0
mirror of https://github.com/mxpv/podsync.git synced 2024-05-11 05:55:04 +00:00
Code Issues Releases Activity

Fix closing feed updates channel too early

Browse Source
This commit is contained in:
Contextualist
2022-06-14 21:52:13 -04:00
parent 81f9894587
commit 59ea55d337
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/podsync/main.go
View File

@ -155,6 +155,10 @@ func main() {
return
}
// Queue of feeds to update
updates := make(chan *feed.Config, 16)
defer close(updates)
group, ctx := errgroup.WithContext(ctx)
defer func() {
if err := group.Wait(); err != nil && (err != context.Canceled && err != http.ErrServerClosed) {
@ -163,10 +167,6 @@ func main() {
log.Info("gracefully stopped")
}()
// Queue of feeds to update
updates := make(chan *feed.Config, 16)
defer close(updates)
// Create Cron
c := cron.New(cron.WithChain(cron.SkipIfStillRunning(cron.DiscardLogger)))
m := make(map[string]cron.EntryID)