diff options
| author | tnextday <fw2k4@163.com> | 2015-12-03 16:27:02 +0800 |
|---|---|---|
| committer | tnextday <fw2k4@163.com> | 2015-12-03 16:27:02 +0800 |
| commit | daac5de1bae20de28082367db44b7b7afa9e4aaf (patch) | |
| tree | 77b9ca3beb5f33f736b5a66da8ecf4a53ed1e576 /go/operation/chunked_file.go | |
| parent | a9a336fdff076211e7c94a4243b430219e5d891c (diff) | |
| download | seaweedfs-daac5de1bae20de28082367db44b7b7afa9e4aaf.tar.xz seaweedfs-daac5de1bae20de28082367db44b7b7afa9e4aaf.zip | |
more check in `http_util.Delete`
add status code in `DeleteResult` struct
operation.DeleteFiles maybe unsafe, so `ChunkManifest.DeleteChunks` manually delete each chunks
Diffstat (limited to 'go/operation/chunked_file.go')
| -rw-r--r-- | go/operation/chunked_file.go | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/go/operation/chunked_file.go b/go/operation/chunked_file.go index 33cb25703..dbc450fd8 100644 --- a/go/operation/chunked_file.go +++ b/go/operation/chunked_file.go @@ -70,19 +70,11 @@ func (cm *ChunkManifest) GetData() ([]byte, error) { } func (cm *ChunkManifest) DeleteChunks(master string) error { - fileIds := make([]string, 0, len(cm.Chunks)) - for _, ci := range cm.Chunks { - fileIds = append(fileIds, ci.Fid) - } - results, e := DeleteFiles(master, fileIds) - if e != nil { - return e - } deleteError := 0 - for _, ret := range results.Results { - if ret.Error != "" { + for _, ci := range cm.Chunks { + if e := DeleteFile(master, ci.Fid, ""); e != nil { deleteError++ - glog.V(0).Infoln("delete error:", ret.Error, ret.Fid) + glog.V(0).Infoln("delete error:", e, ci.Fid) } } if deleteError > 0 { |