|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
log.Trace("Doing: Update") |
|
|
log.Trace("Doing: Update") |
|
|
|
|
|
|
|
|
handler := func(idx int, bean any) error { |
|
|
|
|
|
|
|
|
handler := func(bean any) error { |
|
|
var repo *repo_model.Repository |
|
|
var repo *repo_model.Repository |
|
|
var mirrorType SyncType |
|
|
var mirrorType SyncType |
|
|
var referenceID int64 |
|
|
var referenceID int64 |
|
|
|
|
|
|
|
|
pullMirrorsRequested := 0 |
|
|
pullMirrorsRequested := 0 |
|
|
if pullLimit != 0 { |
|
|
if pullLimit != 0 { |
|
|
if err := repo_model.MirrorsIterate(ctx, pullLimit, func(idx int, bean any) error { |
|
|
if err := repo_model.MirrorsIterate(ctx, pullLimit, func(idx int, bean any) error { |
|
|
if err := handler(idx, bean); err != nil { |
|
|
|
|
|
|
|
|
if err := handler(bean); err != nil { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
pullMirrorsRequested++ |
|
|
pullMirrorsRequested++ |
|
|
|
|
|
|
|
|
pushMirrorsRequested := 0 |
|
|
pushMirrorsRequested := 0 |
|
|
if pushLimit != 0 { |
|
|
if pushLimit != 0 { |
|
|
if err := repo_model.PushMirrorsIterate(ctx, pushLimit, func(idx int, bean any) error { |
|
|
if err := repo_model.PushMirrorsIterate(ctx, pushLimit, func(idx int, bean any) error { |
|
|
if err := handler(idx, bean); err != nil { |
|
|
|
|
|
|
|
|
if err := handler(bean); err != nil { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
pushMirrorsRequested++ |
|
|
pushMirrorsRequested++ |