mirrors
/
goop
mirror of https://github.com/nyancrimew/goop.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

get number of jobs from JobTracker

This commit is contained in:
maia tillie arson crimew 2021-10-21 00:39:15 +02:00
parent 39fbbe315d
commit 1a084596d5
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/goop/clone.go
View File

@ -223,7 +223,7 @@ func FetchGit(baseUrl, baseDir string) error {
jt.AddJob(fmt.Sprintf(".git/objects/pack/pack-%s.idx", sha1[1]))
jt.AddJob(fmt.Sprintf(".git/objects/pack/pack-%s.pack", sha1[1]))
}
concurrency := utils.MinInt(maxConcurrency, len(hashes))
concurrency := utils.MinInt(maxConcurrency, int(jt.QueuedJobs()))
for w := 1; w <= concurrency; w++ {
go workers.DownloadWorker(c, baseUrl, baseDir, jt, false, false)
}
@ -391,7 +391,7 @@ func FetchGit(baseUrl, baseDir string) error {
jt.AddJob(string(e[1]))
}
}
concurrency := utils.MinInt(maxConcurrency, len(errors))
concurrency := utils.MinInt(maxConcurrency, int(jt.QueuedJobs()))
for w := 1; w <= concurrency; w++ {
go workers.DownloadWorker(c, baseUrl, baseDir, jt, true, true)
}
@ -417,7 +417,7 @@ func FetchGit(baseUrl, baseDir string) error {
jt.AddJob(string(e[1]))
}
}
concurrency = utils.MinInt(maxConcurrency, len(deleted))
concurrency = utils.MinInt(maxConcurrency, int(jt.QueuedJobs()))
for w := 1; w <= concurrency; w++ {
go workers.DownloadWorker(c, baseUrl, baseDir, jt, true, true)
}
@ -444,7 +444,7 @@ func FetchGit(baseUrl, baseDir string) error {
jt.AddJob(entry.Name)
}
}
concurrency = utils.MinInt(maxConcurrency, len(idx.Entries))
concurrency = utils.MinInt(maxConcurrency, int(jt.QueuedJobs()))
for w := 1; w <= concurrency; w++ {
go workers.DownloadWorker(c, baseUrl, baseDir, jt, true, true)
}