summaryrefslogtreecommitdiffstats
path: root/models/repo_mirror.go
diff options
context:
space:
mode:
authorThibault Meyer <meyer.thibault@gmail.com>2016-11-10 16:16:32 +0100
committerThibault Meyer <meyer.thibault@gmail.com>2016-11-10 20:59:51 +0100
commita4454f5d0fbeaacb94668012acbb4296465cb28f (patch)
treeeaf39d1935eda44cf16df08234d2bbddd39c3ddd /models/repo_mirror.go
parentc040f2fbb13ef5ba2c6a619322d4801e9f78c885 (diff)
downloadgitea-a4454f5d0fbeaacb94668012acbb4296465cb28f.tar.gz
gitea-a4454f5d0fbeaacb94668012acbb4296465cb28f.zip
Rewrite XORM queries
Diffstat (limited to 'models/repo_mirror.go')
-rw-r--r--models/repo_mirror.go20
1 files changed, 11 insertions, 9 deletions
diff --git a/models/repo_mirror.go b/models/repo_mirror.go
index c598f82bf8..3c78c1cf38 100644
--- a/models/repo_mirror.go
+++ b/models/repo_mirror.go
@@ -199,16 +199,18 @@ func MirrorUpdate() {
log.Trace("Doing: MirrorUpdate")
- if err := x.Where("next_update_unix<=?", time.Now().Unix()).Iterate(new(Mirror), func(idx int, bean interface{}) error {
- m := bean.(*Mirror)
- if m.Repo == nil {
- log.Error(4, "Disconnected mirror repository found: %d", m.ID)
- return nil
- }
+ if err := x.
+ Where("next_update_unix<=?", time.Now().Unix()).
+ Iterate(new(Mirror), func(idx int, bean interface{}) error {
+ m := bean.(*Mirror)
+ if m.Repo == nil {
+ log.Error(4, "Disconnected mirror repository found: %d", m.ID)
+ return nil
+ }
- MirrorQueue.Add(m.RepoID)
- return nil
- }); err != nil {
+ MirrorQueue.Add(m.RepoID)
+ return nil
+ }); err != nil {
log.Error(4, "MirrorUpdate: %v", err)
}
}