aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/dir.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-04-15 02:29:04 -0700
committerChris Lu <chris.lu@gmail.com>2021-04-15 02:29:04 -0700
commit16c0304416bc0dd9fd56439e39c754c57d604608 (patch)
tree279f6b2f33c155f7ff88a02eae0fb66790711c82 /weed/filesys/dir.go
parent217e0f906623a6d2f25f4dce7280d16bf3786a72 (diff)
downloadseaweedfs-16c0304416bc0dd9fd56439e39c754c57d604608.tar.xz
seaweedfs-16c0304416bc0dd9fd56439e39c754c57d604608.zip
ensure to delete on filer also
Diffstat (limited to 'weed/filesys/dir.go')
-rw-r--r--weed/filesys/dir.go5
1 files changed, 1 insertions, 4 deletions
diff --git a/weed/filesys/dir.go b/weed/filesys/dir.go
index ed8ffff61..e74c5aaac 100644
--- a/weed/filesys/dir.go
+++ b/weed/filesys/dir.go
@@ -396,13 +396,10 @@ func (dir *Dir) removeOneFile(req *fuse.RemoveRequest) error {
if err != nil {
return err
}
- if entry == nil {
- return nil
- }
// first, ensure the filer store can correctly delete
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})
if err != nil {
glog.V(3).Infof("not found remove file %s: %v", filePath, err)