diff options
| author | Lunny Xiao <xiaolunwen@gmail.com> | 2022-03-01 03:41:06 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-28 20:41:06 +0100 |
| commit | b75ad7b87f122a1386cb0e576ce83cc000f6d010 (patch) | |
| tree | 14835b769ae37a82e463e38b03f49d0bea515b69 /models/repo/mirror.go | |
| parent | 59959ab222cee6e679aa373b37c6c4bce348e825 (diff) | |
| download | gitea-b75ad7b87f122a1386cb0e576ce83cc000f6d010.tar.gz gitea-b75ad7b87f122a1386cb0e576ce83cc000f6d010.zip | |
Improve mirror iterator (#18928)
* Improve mirror iterator
* fix test
Diffstat (limited to 'models/repo/mirror.go')
| -rw-r--r-- | models/repo/mirror.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/models/repo/mirror.go b/models/repo/mirror.go index e73226534e..8494331ff7 100644 --- a/models/repo/mirror.go +++ b/models/repo/mirror.go @@ -120,11 +120,12 @@ func DeleteMirrorByRepoID(repoID int64) error { } // MirrorsIterate iterates all mirror repositories. -func MirrorsIterate(f func(idx int, bean interface{}) error) error { +func MirrorsIterate(limit int, f func(idx int, bean interface{}) error) error { return db.GetEngine(db.DefaultContext). Where("next_update_unix<=?", time.Now().Unix()). And("next_update_unix!=0"). OrderBy("updated_unix ASC"). + Limit(limit). Iterate(new(Mirror), f) } |