simon987/od-database-crawler
1
0
Fork 0
mirror of https://github.com/terorie/od-database-crawler.git synced 2025-12-13 15:19:03 +00:00
Code Issues Projects Releases Wiki Activity

Bugfix: Don't schedule new tasks during shutdown

Browse Source
This commit is contained in:
Richard Patel
2019-02-03 17:02:44 +01:00
parent 885af5bb3b
commit cea6c1658b
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
scheduler.go
View File

@@ -21,10 +21,15 @@ var totalQueued int64
func Schedule(c context.Context, remotes <-chan *OD) { func Schedule(c context.Context, remotes <-chan *OD) {
go Stats(c) go Stats(c)
for remote := range remotes { for {
select {
case remote := <-remotes:
if !scheduleNewTask(c, remote) { if !scheduleNewTask(c, remote) {
return return
} }
case <-c.Done():
return
}
} }
} }