diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-10-14 00:12:28 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-10-14 00:12:28 -0700 |
| commit | ff66269b62ddffe70127bbb9835ae5e7b24e8ce7 (patch) | |
| tree | 469ac5785c44913288437e2ca765042583aeba28 /weed/filer2 | |
| parent | 3ddcd870983e68e24ad569127f9a989d7bc986dc (diff) | |
| download | seaweedfs-ff66269b62ddffe70127bbb9835ae5e7b24e8ce7.tar.xz seaweedfs-ff66269b62ddffe70127bbb9835ae5e7b24e8ce7.zip | |
use grpc to replace http APIs for batch volume id lookup and batch delete
1. remove batch volume id lookup http API /vol/lookup
2. remove batch delete http API /delete
Diffstat (limited to 'weed/filer2')
| -rw-r--r-- | weed/filer2/filer.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go index d722e60ac..1c9f2cde4 100644 --- a/weed/filer2/filer.go +++ b/weed/filer2/filer.go @@ -176,7 +176,7 @@ func (f *Filer) DeleteEntryMetaAndData(p FullPath, isRecursive bool, shouldDelet } if shouldDeleteChunks { - f.deleteChunks(entry.Chunks) + f.DeleteChunks(entry.Chunks) } if p == "/" { @@ -229,18 +229,18 @@ func (f *Filer) cacheSetDirectory(dirpath string, dirEntry *Entry, level int) { f.directoryCache.Set(dirpath, dirEntry, time.Duration(minutes)*time.Minute) } -func (f *Filer) deleteChunks(chunks []*filer_pb.FileChunk) { +func (f *Filer) DeleteChunks(chunks []*filer_pb.FileChunk) { for _, chunk := range chunks { f.DeleteFileByFileId(chunk.FileId) } } func (f *Filer) DeleteFileByFileId(fileId string) { - fileUrlOnVolume, err := f.MasterClient.LookupFileId(fileId) + volumeServer, err := f.MasterClient.LookupVolumeServer(fileId) if err != nil { glog.V(0).Infof("can not find file %s: %v", fileId, err) } - if err := operation.DeleteFromVolumeServer(fileUrlOnVolume, ""); err != nil { + if _, err := operation.DeleteFilesAtOneVolumeServer(volumeServer, []string{fileId}); err != nil { glog.V(0).Infof("deleting file %s: %v", fileId, err) } } @@ -251,7 +251,7 @@ func (f *Filer) deleteChunksIfNotNew(oldEntry, newEntry *Entry) { return } if newEntry == nil { - f.deleteChunks(oldEntry.Chunks) + f.DeleteChunks(oldEntry.Chunks) } var toDelete []*filer_pb.FileChunk @@ -268,5 +268,5 @@ func (f *Filer) deleteChunksIfNotNew(oldEntry, newEntry *Entry) { toDelete = append(toDelete, oldChunk) } } - f.deleteChunks(toDelete) + f.DeleteChunks(toDelete) } |
