avoid using empty fileId to delete
fix https://github.com/chrislusf/seaweedfs/issues/183
This commit is contained in:
@@ -43,6 +43,9 @@ func (fl *FileListInLevelDb) CreateFile(dirId filer.DirectoryId, fileName string
|
|||||||
}
|
}
|
||||||
func (fl *FileListInLevelDb) DeleteFile(dirId filer.DirectoryId, fileName string) (fid string, err error) {
|
func (fl *FileListInLevelDb) DeleteFile(dirId filer.DirectoryId, fileName string) (fid string, err error) {
|
||||||
if fid, err = fl.FindFile(dirId, fileName); err != nil {
|
if fid, err = fl.FindFile(dirId, fileName); err != nil {
|
||||||
|
if err == leveldb.ErrNotFound {
|
||||||
|
return "", nil
|
||||||
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = fl.db.Delete(genKey(dirId, fileName), nil)
|
err = fl.db.Delete(genKey(dirId, fileName), nil)
|
||||||
|
|||||||
@@ -209,7 +209,7 @@ func (fs *FilerServer) DeleteHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
err = fs.filer.DeleteDirectory(r.URL.Path, isRecursive)
|
err = fs.filer.DeleteDirectory(r.URL.Path, isRecursive)
|
||||||
} else {
|
} else {
|
||||||
fid, err = fs.filer.DeleteFile(r.URL.Path)
|
fid, err = fs.filer.DeleteFile(r.URL.Path)
|
||||||
if err == nil {
|
if err == nil && fid != "" {
|
||||||
err = operation.DeleteFile(fs.master, fid, fs.jwt(fid))
|
err = operation.DeleteFile(fs.master, fid, fs.jwt(fid))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user