upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor synced 2024-09-21 03:19:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Wenkai Yin 2016-07-05 11:22:16 +08:00
parent 19ec6177e0
commit e2afc3e51c
2 changed files with 21 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
job/replication/delete.go
View File

@ -74,6 +74,17 @@ func (d *Deleter) Exit() error {
// Enter deletes repository or tags // Enter deletes repository or tags
func (d *Deleter) Enter() (string, error) { func (d *Deleter) Enter() (string, error) {
state, err := d.enter()
if err != nil && retry(err) {
d.logger.Info("waiting for retrying...")
return models.JobRetrying, nil
}
return state, err
}
func (d *Deleter) enter() (string, error) {
if len(d.tags) == 0 { if len(d.tags) == 0 {
tags, err := d.dstClient.ListTag() tags, err := d.dstClient.ListTag()

16
job/replication/transfer.go
View File

@ -154,7 +154,8 @@ type Checker struct {
func (c *Checker) Enter() (string, error) { func (c *Checker) Enter() (string, error) {
state, err := c.enter() state, err := c.enter()
if err != nil && retry(err) { if err != nil && retry(err) {
return models.JobRetrying, err c.logger.Info("waiting for retrying...")
return models.JobRetrying, nil
} }
return state, err return state, err
@ -328,7 +329,8 @@ type ManifestPuller struct {
func (m *ManifestPuller) Enter() (string, error) { func (m *ManifestPuller) Enter() (string, error) {
state, err := m.enter() state, err := m.enter()
if err != nil && retry(err) { if err != nil && retry(err) {
return models.JobRetrying, err m.logger.Info("waiting for retrying...")
return models.JobRetrying, nil
} }
return state, err return state, err
@ -411,7 +413,8 @@ type BlobTransfer struct {
func (b *BlobTransfer) Enter() (string, error) { func (b *BlobTransfer) Enter() (string, error) {
state, err := b.enter() state, err := b.enter()
if err != nil && retry(err) { if err != nil && retry(err) {
return models.JobRetrying, err b.logger.Info("waiting for retrying...")
return models.JobRetrying, nil
} }
return state, err return state, err
@ -446,10 +449,11 @@ type ManifestPusher struct {
// Enter checks the existence of manifest in the source registry first, and if it // Enter checks the existence of manifest in the source registry first, and if it
// exists, pushs it to destination registry. The checking operation is to avoid // exists, pushs it to destination registry. The checking operation is to avoid
// the situation that the tag is deleted during the blobs transfering // the situation that the tag is deleted during the blobs transfering
func (b *ManifestPusher) Enter() (string, error) { func (m *ManifestPusher) Enter() (string, error) {
state, err := b.enter() state, err := m.enter()
if err != nil && retry(err) { if err != nil && retry(err) {
return models.JobRetrying, err m.logger.Info("waiting for retrying...")
return models.JobRetrying, nil
} }
return state, err return state, err