Skip to content

Commit

Permalink
Lint models/repo_mirror.go
Browse files Browse the repository at this point in the history
  • Loading branch information
Bwko committed Nov 26, 2016
1 parent 0a76d26 commit 7bf7042
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions models/repo_mirror.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ import (
"code.gitea.io/gitea/modules/sync"
)

// MirrorQueue holds an UniqueQueue object of the mirror
var MirrorQueue = sync.NewUniqueQueue(setting.Repository.MirrorQueueLength)

// Mirror represents mirror information of a repository.
Expand All @@ -37,16 +38,19 @@ type Mirror struct {
address string `xorm:"-"`
}

// BeforeInsert will be invoked by XORM before inserting a record
func (m *Mirror) BeforeInsert() {
m.UpdatedUnix = time.Now().Unix()
m.NextUpdateUnix = m.NextUpdate.Unix()
}

// BeforeUpdate is invoked from XORM before updating this object.
func (m *Mirror) BeforeUpdate() {
m.UpdatedUnix = time.Now().Unix()
m.NextUpdateUnix = m.NextUpdate.Unix()
}

// AfterSet is invoked from XORM after setting the value of a field of this object.
func (m *Mirror) AfterSet(colName string, _ xorm.Cell) {
var err error
switch colName {
Expand Down Expand Up @@ -180,10 +184,12 @@ func updateMirror(e Engine, m *Mirror) error {
return err
}

// UpdateMirror updates the mirror
func UpdateMirror(m *Mirror) error {
return updateMirror(x, m)
}

// DeleteMirrorByRepoID deletes a mirror by repoID
func DeleteMirrorByRepoID(repoID int64) error {
_, err := x.Delete(&Mirror{RepoID: repoID})
return err
Expand Down Expand Up @@ -241,6 +247,7 @@ func SyncMirrors() {
}
}

// InitSyncMirrors initializes a go routine to sync the mirros
func InitSyncMirrors() {
go SyncMirrors()
}

0 comments on commit 7bf7042

Please sign in to comment.