Browse Source

retry delete fileId

pull/316/head
DaLin 10 years ago
parent
commit
d532cf27eb
  1. 18
      weed/operation/delete_content.go

18
weed/operation/delete_content.go

@ -26,11 +26,13 @@ func DeleteFile(master string, fileId string, jwt security.EncodedJwt) error {
if err != nil { if err != nil {
return fmt.Errorf("Failed to lookup %s:%v", fileId, err) return fmt.Errorf("Failed to lookup %s:%v", fileId, err)
} }
err = util.Delete(fileUrl, jwt)
if err != nil {
return fmt.Errorf("Failed to delete %s:%v", fileUrl, err)
for i := 0; i < 5; i++ {
err = util.Delete(fileUrl, jwt)
if err == nil {
return nil
}
} }
return nil
return fmt.Errorf("Failed to delete %s:%v", fileUrl, err)
} }
func ParseFileId(fid string) (vid string, key_cookie string, err error) { func ParseFileId(fid string) (vid string, key_cookie string, err error) {
@ -38,7 +40,7 @@ func ParseFileId(fid string) (vid string, key_cookie string, err error) {
if commaIndex <= 0 { if commaIndex <= 0 {
return "", "", errors.New("Wrong fid format.") return "", "", errors.New("Wrong fid format.")
} }
return fid[:commaIndex], fid[commaIndex+1:], nil
return fid[:commaIndex], fid[commaIndex + 1:], nil
} }
type DeleteFilesResult struct { type DeleteFilesResult struct {
@ -97,15 +99,15 @@ func DeleteFiles(master string, fileIds []string) (*DeleteFilesResult, error) {
for _, fid := range fidList { for _, fid := range fidList {
values.Add("fid", fid) values.Add("fid", fid)
} }
jsonBlob, err := util.Post("http://"+server+"/delete", values)
jsonBlob, err := util.Post("http://" + server + "/delete", values)
if err != nil { if err != nil {
ret.Errors = append(ret.Errors, err.Error()+" "+string(jsonBlob))
ret.Errors = append(ret.Errors, err.Error() + " " + string(jsonBlob))
return return
} }
var result []DeleteResult var result []DeleteResult
err = json.Unmarshal(jsonBlob, &result) err = json.Unmarshal(jsonBlob, &result)
if err != nil { if err != nil {
ret.Errors = append(ret.Errors, err.Error()+" "+string(jsonBlob))
ret.Errors = append(ret.Errors, err.Error() + " " + string(jsonBlob))
return return
} }
ret.Results = append(ret.Results, result...) ret.Results = append(ret.Results, result...)

Loading…
Cancel
Save