Skip to content

Commit 733335f

Browse files
committed
safer way
1 parent 269ebd6 commit 733335f

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

pkg/objects/file.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -160,15 +160,17 @@ func (f File) uploadNormalObject(body io.Reader, sourceState FileState, hdr swif
160160
if serr, ok := err.(*swift.Error); ok {
161161
//upload failed due to rate limit, object is definitely not uploaded
162162
//prevent additional rate limit caused by an unnecessary delete request
163-
if serr.StatusCode != 498 {
164-
//delete potentially incomplete upload
165-
err = f.Job.Target.Connection.ObjectDelete(containerName, objectName)
166-
if err != nil {
167-
util.Log(util.LogError, "DELETE %s/%s failed: %s", containerName, objectName, err.Error())
168-
}
163+
if serr.StatusCode == 498 {
164+
return false
169165
}
170166
}
171167

168+
//delete potentially incomplete upload
169+
err = f.Job.Target.Connection.ObjectDelete(containerName, objectName)
170+
if err != nil {
171+
util.Log(util.LogError, "DELETE %s/%s failed: %s", containerName, objectName, err.Error())
172+
}
173+
172174
return false
173175
}
174176

0 commit comments

Comments
 (0)