aboutsummaryrefslogtreecommitdiffstats
path: root/models/repo_mirror.go
diff options
context:
space:
mode:
Diffstat (limited to 'models/repo_mirror.go')
-rw-r--r--models/repo_mirror.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/models/repo_mirror.go b/models/repo_mirror.go
index b086b87cf1..35685b3220 100644
--- a/models/repo_mirror.go
+++ b/models/repo_mirror.go
@@ -95,7 +95,7 @@ func getMirrorByRepoID(e db.Engine, repoID int64) (*Mirror, error) {
// GetMirrorByRepoID returns mirror information of a repository.
func GetMirrorByRepoID(repoID int64) (*Mirror, error) {
- return getMirrorByRepoID(db.DefaultContext().Engine(), repoID)
+ return getMirrorByRepoID(db.GetEngine(db.DefaultContext), repoID)
}
func updateMirror(e db.Engine, m *Mirror) error {
@@ -105,18 +105,18 @@ func updateMirror(e db.Engine, m *Mirror) error {
// UpdateMirror updates the mirror
func UpdateMirror(m *Mirror) error {
- return updateMirror(db.DefaultContext().Engine(), m)
+ return updateMirror(db.GetEngine(db.DefaultContext), m)
}
// DeleteMirrorByRepoID deletes a mirror by repoID
func DeleteMirrorByRepoID(repoID int64) error {
- _, err := db.DefaultContext().Engine().Delete(&Mirror{RepoID: repoID})
+ _, err := db.GetEngine(db.DefaultContext).Delete(&Mirror{RepoID: repoID})
return err
}
// MirrorsIterate iterates all mirror repositories.
func MirrorsIterate(f func(idx int, bean interface{}) error) error {
- return db.DefaultContext().Engine().
+ return db.GetEngine(db.DefaultContext).
Where("next_update_unix<=?", time.Now().Unix()).
And("next_update_unix!=0").
Iterate(new(Mirror), f)
@@ -124,6 +124,6 @@ func MirrorsIterate(f func(idx int, bean interface{}) error) error {
// InsertMirror inserts a mirror to database
func InsertMirror(mirror *Mirror) error {
- _, err := db.DefaultContext().Engine().Insert(mirror)
+ _, err := db.GetEngine(db.DefaultContext).Insert(mirror)
return err
}