lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-19 22:37:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

ensure to delete on filer also

Browse Source
This commit is contained in:
Chris Lu
2021-04-15 02:29:04 -07:00
parent 217e0f9066
commit 16c0304416
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/filesys/dir.go
View File

@@ -396,13 +396,10 @@ func (dir *Dir) removeOneFile(req *fuse.RemoveRequest) error {
if err != nil { if err != nil {
return err return err
} }
if entry == nil {
return nil
}
// first, ensure the filer store can correctly delete // first, ensure the filer store can correctly delete
glog.V(3).Infof("remove file: %v", req) glog.V(3).Infof("remove file: %v", req)
isDeleteData := entry.HardLinkCounter <= 1 isDeleteData := entry != nil && entry.HardLinkCounter <= 1
err = filer_pb.Remove(dir.wfs, dirFullPath, req.Name, isDeleteData, false, false, false, []int32{dir.wfs.signature}) err = filer_pb.Remove(dir.wfs, dirFullPath, req.Name, isDeleteData, false, false, false, []int32{dir.wfs.signature})
if err != nil { if err != nil {
glog.V(3).Infof("not found remove file %s: %v", filePath, err) glog.V(3).Infof("not found remove file %s: %v", filePath, err)